aboutsummaryrefslogtreecommitdiff
path: root/weed/replication/sink/b2sink/b2_sink.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-01-29 09:09:55 -0800
committerChris Lu <chris.lu@gmail.com>2020-01-29 09:09:55 -0800
commitd335f04de6861b571190c13bd7d65e9a0c02f187 (patch)
treead534357d50c4027718a7fe2e60391b6545a7db0 /weed/replication/sink/b2sink/b2_sink.go
parent27b94cb65b34c084790f0a1884956702ee51acc2 (diff)
downloadseaweedfs-d335f04de6861b571190c13bd7d65e9a0c02f187.tar.xz
seaweedfs-d335f04de6861b571190c13bd7d65e9a0c02f187.zip
support env variables to overwrite toml file
Diffstat (limited to 'weed/replication/sink/b2sink/b2_sink.go')
-rw-r--r--weed/replication/sink/b2sink/b2_sink.go10
1 files changed, 5 insertions, 5 deletions
diff --git a/weed/replication/sink/b2sink/b2_sink.go b/weed/replication/sink/b2sink/b2_sink.go
index 35c2230fa..8c80a64bd 100644
--- a/weed/replication/sink/b2sink/b2_sink.go
+++ b/weed/replication/sink/b2sink/b2_sink.go
@@ -31,12 +31,12 @@ func (g *B2Sink) GetSinkToDirectory() string {
return g.dir
}
-func (g *B2Sink) Initialize(configuration util.Configuration) error {
+func (g *B2Sink) Initialize(configuration util.Configuration, prefix string) error {
return g.initialize(
- configuration.GetString("b2_account_id"),
- configuration.GetString("b2_master_application_key"),
- configuration.GetString("bucket"),
- configuration.GetString("directory"),
+ configuration.GetString(prefix+"b2_account_id"),
+ configuration.GetString(prefix+"b2_master_application_key"),
+ configuration.GetString(prefix+"bucket"),
+ configuration.GetString(prefix+"directory"),
)
}