add support for gcs

.gitignore

@@ -15,3 +15,7 @@ test/
 # dep/glide
 vendor/
 bin/
+
+# IntelliJ IDEA
+.idea/
+skbn.iml

Gopkg.toml

@@ -10,6 +10,14 @@
   name = "github.com/aws/aws-sdk-go"
   version = "1.16.7"
 
+[[override]]
+  name = "golang.org/x/oauth2"
+  revision = "e64efc72b421e893cbf63f17ba2221e7d6d0b0f3"
+
+[[constraint]]
+  name = "cloud.google.com/go"
+  version = "0.37.0"
+
 [[constraint]]
   name = "github.com/djherbis/buffer"
   version = "1.0.0"

README.md

@@ -13,6 +13,7 @@ Skbn currently supports the following providers:
 * AWS S3
 * Minio S3
 * Azure Blob Storage
+* Google Cloud Storage
 
 ## Install
 
@@ -67,6 +68,14 @@ skbn cp \
     --dst k8s://<namespace>/<podName>/<containerName>/<path>
 ```
 
+### Copy files from Kubernetes to Google Cloud Storage
+
+```
+skbn cp \
+    --src k8s://<namespace>/<podName>/<containerName>/<path> \
+    --dst gcs://<bucket>/<path>
+```
+
 ## Advanced usage
 
 ### Copy files from source to destination in parallel
@@ -166,6 +175,11 @@ In addition, the `AWS_REGION` environment variable should be set (default is `eu
 
 Skbn uses `AZURE_STORAGE_ACCOUNT` and `AZURE_STORAGE_ACCESS_KEY` environment variables for authentication.
 
+### Google Cloud Storage
+
+Skbn uses Google [Application Default Credentials](https://cloud.google.com/docs/authentication/production). 
+Basically, it will first look for the `GOOGLE_APPLICATION_CREDENTIALS` environment variable. If it is not defined, it will look for the default service account, or throw an error if none is configured. 
+
 ## Examples
 
 1. [In-cluster example](/examples/in-cluster)

cmd/skbn.go

@@ -6,7 +6,7 @@ import (
 	"log"
 	"os"
 
-	"github.com/maorfr/skbn/pkg/skbn"
+	"skbn/pkg/skbn"
 
 	"github.com/spf13/cobra"
 )

examples/code/example.go

@@ -2,8 +2,9 @@ package main
 
 import (
 	"log"
+	"time"
 
-	"github.com/maorfr/skbn/pkg/skbn"
+	"skbn/pkg/skbn"
 )
 
 func main() {
@@ -12,7 +13,10 @@ func main() {
 	parallel := 0     // all at once
 	bufferSize := 1.0 // 1GB of in memory buffer size
 
+	start := time.Now()
 	if err := skbn.Copy(src, dst, parallel, bufferSize); err != nil {
 		log.Fatal(err)
 	}
+	elapsed := time.Since(start)
+	log.Printf("Copy execution time: %s", elapsed)
 }