aboutsummaryrefslogtreecommitdiff
path: root/weed/replication/sink
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-10-06 13:08:38 -0700
committerChris Lu <chris.lu@gmail.com>2018-10-06 13:08:38 -0700
commit84d4a2c8a067518f403a3777790c67955d64ade3 (patch)
tree6f8a2fa21d0005aa87b21c90ed89346b9a62cc19 /weed/replication/sink
parentf8c2704d2b3afdaf77d5fa7be290fbee9e54e8dc (diff)
downloadseaweedfs-84d4a2c8a067518f403a3777790c67955d64ade3.tar.xz
seaweedfs-84d4a2c8a067518f403a3777790c67955d64ade3.zip
add filer replication to google cloud storage
Diffstat (limited to 'weed/replication/sink')
-rw-r--r--weed/replication/sink/gcssink/gcs_sink.go5
1 files changed, 1 insertions, 4 deletions
diff --git a/weed/replication/sink/gcssink/gcs_sink.go b/weed/replication/sink/gcssink/gcs_sink.go
index 2e0cf10f8..db71aa1f9 100644
--- a/weed/replication/sink/gcssink/gcs_sink.go
+++ b/weed/replication/sink/gcssink/gcs_sink.go
@@ -17,7 +17,6 @@ import (
type GcsSink struct {
client *storage.Client
- projectId string
bucket string
dir string
filerSource *source.FilerSource
@@ -38,7 +37,6 @@ func (g *GcsSink) GetSinkToDirectory() string {
func (g *GcsSink) Initialize(configuration util.Configuration) error {
return g.initialize(
configuration.GetString("google_application_credentials"),
- configuration.GetString("projectId"),
configuration.GetString("bucket"),
configuration.GetString("directory"),
)
@@ -48,8 +46,7 @@ func (g *GcsSink) SetSourceFiler(s *source.FilerSource) {
g.filerSource = s
}
-func (g *GcsSink) initialize(google_application_credentials, projectId, bucketName, dir string) (error) {
- g.projectId = projectId
+func (g *GcsSink) initialize(google_application_credentials, bucketName, dir string) (error) {
g.bucket = bucketName
g.dir = dir