3 files changed, 16 insertions, 10 deletions
diff --git a/weed/replication/sink/fetch_write.go b/weed/replication/sink/filersink/fetch_write.go
index ef7c201c9..c14566723 100644
--- a/weed/replication/sink/fetch_write.go
+++ b/weed/replication/sink/filersink/fetch_write.go
@@ -1,4 +1,4 @@
-package sink
+package filersink
 
 import (
 	"context"
diff --git a/weed/replication/sink/filer_sink.go b/weed/replication/sink/filersink/filer_sink.go
index f0a7e68d3..1cbf52864 100644
--- a/weed/replication/sink/filer_sink.go
+++ b/weed/replication/sink/filersink/filer_sink.go
@@ -1,4 +1,4 @@
-package sink
+package filersink
 
 import (
 	"context"
@@ -11,14 +11,6 @@ import (
 	"github.com/chrislusf/seaweedfs/weed/util"
 )
 
-type ReplicationSink interface {
-	DeleteEntry(key string, entry *filer_pb.Entry, deleteIncludeChunks bool) error
-	CreateEntry(key string, entry *filer_pb.Entry) error
-	UpdateEntry(key string, oldEntry, newEntry *filer_pb.Entry, deleteIncludeChunks bool) error
-	GetSinkToDirectory() string
-	SetSourceFiler(s *source.FilerSource)
-}
-
 type FilerSink struct {
 	filerSource *source.FilerSource
 	grpcAddress string
diff --git a/weed/replication/sink/replication_sink.go b/weed/replication/sink/replication_sink.go
new file mode 100644
index 000000000..bb4a8aa83
--- /dev/null
+++ b/weed/replication/sink/replication_sink.go
@@ -0,0 +1,14 @@
+package sink
+
+import (
+	"github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+	"github.com/chrislusf/seaweedfs/weed/replication/source"
+)
+
+type ReplicationSink interface {
+	DeleteEntry(key string, entry *filer_pb.Entry, deleteIncludeChunks bool) error
+	CreateEntry(key string, entry *filer_pb.Entry) error
+	UpdateEntry(key string, oldEntry, newEntry *filer_pb.Entry, deleteIncludeChunks bool) error
+	GetSinkToDirectory() string
+	SetSourceFiler(s *source.FilerSource)
+}