go fmt

weed/command/filer_replication.go

@@ -2,9 +2,9 @@ package command
 
 import (
 	"github.com/chrislusf/seaweedfs/weed/glog"
+	"github.com/chrislusf/seaweedfs/weed/replication"
 	"github.com/chrislusf/seaweedfs/weed/server"
 	"github.com/spf13/viper"
-	"github.com/chrislusf/seaweedfs/weed/replication"
 )
 
 func init() {

weed/filer2/filer_notify.go

@@ -1,9 +1,9 @@
 package filer2
 
 import (
+	"github.com/chrislusf/seaweedfs/weed/glog"
 	"github.com/chrislusf/seaweedfs/weed/notification"
 	"github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
-	"github.com/chrislusf/seaweedfs/weed/glog"
 )
 
 func (f *Filer) NotifyUpdateEvent(oldEntry, newEntry *Entry, deleteChunks bool) {

weed/notification/configuration.go

@@ -2,9 +2,9 @@ package notification
 
 import (
 	"github.com/chrislusf/seaweedfs/weed/glog"
-	"github.com/spf13/viper"
 	"github.com/chrislusf/seaweedfs/weed/util"
 	"github.com/golang/protobuf/proto"
+	"github.com/spf13/viper"
 )
 
 type MessageQueue interface {

weed/replication/notification_kafka.go

@@ -1,17 +1,17 @@
 package replication
 
 import (
+	"fmt"
+
 	"github.com/Shopify/sarama"
+	"github.com/chrislusf/seaweedfs/weed/glog"
+	"github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
 	"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"
 )
 
 func init() {
-	NotificationInputs = append(NotificationInputs, &KafkaInput{
+	NotificationInputs = append(NotificationInputs, &KafkaInput{})
-	})
 }
 
 type KafkaInput struct {

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 {

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 {

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"

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 {

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 {