diff options
Diffstat (limited to 'weed/replication/sink/filersink/filer_sink.go')
| -rw-r--r-- | weed/replication/sink/filersink/filer_sink.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/weed/replication/sink/filersink/filer_sink.go b/weed/replication/sink/filersink/filer_sink.go index a58c8f296..a69c9dc8e 100644 --- a/weed/replication/sink/filersink/filer_sink.go +++ b/weed/replication/sink/filersink/filer_sink.go @@ -23,6 +23,7 @@ type FilerSink struct { replication string collection string ttlSec int32 + diskType string dataCenter string grpcDialOption grpc.DialOption } @@ -46,6 +47,7 @@ func (fs *FilerSink) Initialize(configuration util.Configuration, prefix string) configuration.GetString(prefix+"replication"), configuration.GetString(prefix+"collection"), configuration.GetInt(prefix+"ttlSec"), + configuration.GetString(prefix+"disk"), security.LoadClientTLS(util.GetViper(), "grpc.client")) } @@ -54,12 +56,13 @@ func (fs *FilerSink) SetSourceFiler(s *source.FilerSource) { } func (fs *FilerSink) DoInitialize(grpcAddress string, dir string, - replication string, collection string, ttlSec int, grpcDialOption grpc.DialOption) (err error) { + replication string, collection string, ttlSec int, diskType string, grpcDialOption grpc.DialOption) (err error) { fs.grpcAddress = grpcAddress fs.dir = dir fs.replication = replication fs.collection = collection fs.ttlSec = int32(ttlSec) + fs.diskType = diskType fs.grpcDialOption = grpcDialOption return nil } |