aboutsummaryrefslogtreecommitdiff
path: root/weed/replication/notification_kafka.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-10-11 00:08:13 -0700
committerChris Lu <chris.lu@gmail.com>2018-10-11 00:08:13 -0700
commit08266b7256e8b81bf4e846cd392a6b988dca60e8 (patch)
tree1b368539ba9b94d8f51f67b5d9c3ecf04ad54662 /weed/replication/notification_kafka.go
parent1d7e01b754069d188094e110fe8c5a5141ac3519 (diff)
downloadseaweedfs-08266b7256e8b81bf4e846cd392a6b988dca60e8.tar.xz
seaweedfs-08266b7256e8b81bf4e846cd392a6b988dca60e8.zip
go fmt
Diffstat (limited to 'weed/replication/notification_kafka.go')
-rw-r--r--weed/replication/notification_kafka.go8
1 files changed, 4 insertions, 4 deletions
diff --git a/weed/replication/notification_kafka.go b/weed/replication/notification_kafka.go
index 87f28f738..3bf917376 100644
--- a/weed/replication/notification_kafka.go
+++ b/weed/replication/notification_kafka.go
@@ -1,17 +1,17 @@
package replication
import (
+ "encoding/json"
"fmt"
+ "io/ioutil"
+ "sync"
+ "time"
"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"
- "io/ioutil"
- "encoding/json"
- "sync"
- "time"
)
func init() {