diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-09-22 00:53:52 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-09-22 00:53:52 -0700 |
| commit | 01ceace18edda7e747a903276023a8b1be3af757 (patch) | |
| tree | dde77c83ce71139c43f1a323e233fb44e235ae1f /weed/replication/replicator.go | |
| parent | 402ab598b63f08bc4950c9f278c86338d0c78643 (diff) | |
| download | seaweedfs-01ceace18edda7e747a903276023a8b1be3af757.tar.xz seaweedfs-01ceace18edda7e747a903276023a8b1be3af757.zip | |
adjust sink options
Diffstat (limited to 'weed/replication/replicator.go')
| -rw-r--r-- | weed/replication/replicator.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/replication/replicator.go b/weed/replication/replicator.go index 66d194128..3e4bccc10 100644 --- a/weed/replication/replicator.go +++ b/weed/replication/replicator.go @@ -43,7 +43,7 @@ func (r *Replicator) Replicate(key string, message *filer_pb.EventNotification) if !strings.HasPrefix(key, r.source.Dir) { return nil } - key = r.sink.GetDirectory() + key[len(r.source.Dir):] + key = r.sink.GetSinkToDirectory() + key[len(r.source.Dir):] if message.OldEntry != nil && message.NewEntry == nil { return r.sink.DeleteEntry(key, message.OldEntry, message.DeleteChunks) } |