diff options
Diffstat (limited to 'weed/replication')
| -rw-r--r-- | weed/replication/notification_kafka.go | 10 | ||||
| -rw-r--r-- | weed/replication/notifications.go | 2 | ||||
| -rw-r--r-- | weed/replication/replicator.go | 9 | ||||
| -rw-r--r-- | weed/replication/sink/fetch_write.go | 7 | ||||
| -rw-r--r-- | weed/replication/sink/filer_sink.go | 6 | ||||
| -rw-r--r-- | weed/replication/source/filer_source.go | 13 |
6 files changed, 25 insertions, 22 deletions
diff --git a/weed/replication/notification_kafka.go b/weed/replication/notification_kafka.go index aaf08a96c..d10175757 100644 --- a/weed/replication/notification_kafka.go +++ b/weed/replication/notification_kafka.go @@ -1,17 +1,17 @@ package replication import ( + "fmt" + "github.com/Shopify/sarama" - "github.com/chrislusf/seaweedfs/weed/util" - "github.com/golang/protobuf/proto" "github.com/chrislusf/seaweedfs/weed/glog" - "fmt" "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" + "github.com/chrislusf/seaweedfs/weed/util" + "github.com/golang/protobuf/proto" ) func init() { - NotificationInputs = append(NotificationInputs, &KafkaInput{ - }) + NotificationInputs = append(NotificationInputs, &KafkaInput{}) } type KafkaInput struct { diff --git a/weed/replication/notifications.go b/weed/replication/notifications.go index ff40c3aad..6ae95d36b 100644 --- a/weed/replication/notifications.go +++ b/weed/replication/notifications.go @@ -1,8 +1,8 @@ package replication import ( - "github.com/chrislusf/seaweedfs/weed/util" "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" + "github.com/chrislusf/seaweedfs/weed/util" ) type NotificationInput interface { diff --git a/weed/replication/replicator.go b/weed/replication/replicator.go index add7f5e2b..66d194128 100644 --- a/weed/replication/replicator.go +++ b/weed/replication/replicator.go @@ -1,12 +1,13 @@ package replication import ( - "github.com/chrislusf/seaweedfs/weed/replication/sink" - "github.com/chrislusf/seaweedfs/weed/util" - "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" - "github.com/chrislusf/seaweedfs/weed/replication/source" "strings" + "github.com/chrislusf/seaweedfs/weed/glog" + "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" + "github.com/chrislusf/seaweedfs/weed/replication/sink" + "github.com/chrislusf/seaweedfs/weed/replication/source" + "github.com/chrislusf/seaweedfs/weed/util" ) type Replicator struct { diff --git a/weed/replication/sink/fetch_write.go b/weed/replication/sink/fetch_write.go index e432aa45c..4408a712e 100644 --- a/weed/replication/sink/fetch_write.go +++ b/weed/replication/sink/fetch_write.go @@ -2,10 +2,11 @@ package sink import ( "context" - "sync" - "strings" "fmt" - "github.com/chrislusf/seaweedfs/weed/glog" + "strings" + "sync" + + "github.com/chrislusf/seaweedfs/weed/glog" "github.com/chrislusf/seaweedfs/weed/operation" "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" "github.com/chrislusf/seaweedfs/weed/util" diff --git a/weed/replication/sink/filer_sink.go b/weed/replication/sink/filer_sink.go index a39402aeb..422bdeabc 100644 --- a/weed/replication/sink/filer_sink.go +++ b/weed/replication/sink/filer_sink.go @@ -1,14 +1,14 @@ package sink import ( - "fmt" "context" + "fmt" - "github.com/chrislusf/seaweedfs/weed/util" - "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" "github.com/chrislusf/seaweedfs/weed/filer2" "github.com/chrislusf/seaweedfs/weed/glog" + "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" "github.com/chrislusf/seaweedfs/weed/replication/source" + "github.com/chrislusf/seaweedfs/weed/util" ) type ReplicationSink interface { diff --git a/weed/replication/source/filer_source.go b/weed/replication/source/filer_source.go index 8d10dc59a..69e74a63c 100644 --- a/weed/replication/source/filer_source.go +++ b/weed/replication/source/filer_source.go @@ -1,14 +1,15 @@ package source import ( - "io" - "github.com/chrislusf/seaweedfs/weed/util" - "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" - "fmt" - "github.com/chrislusf/seaweedfs/weed/glog" - "strings" "context" + "fmt" + "io" "net/http" + "strings" + + "github.com/chrislusf/seaweedfs/weed/glog" + "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" + "github.com/chrislusf/seaweedfs/weed/util" ) type ReplicationSource interface { |