diff options
Diffstat (limited to 'weed/mq')
| -rw-r--r-- | weed/mq/broker/brokder_grpc_admin.go | 12 | ||||
| -rw-r--r-- | weed/mq/broker/broker_segment_serde.go | 10 | ||||
| -rw-r--r-- | weed/mq/broker/broker_server.go | 12 | ||||
| -rw-r--r-- | weed/mq/segment/message_serde.go | 2 | ||||
| -rw-r--r-- | weed/mq/segment/message_serde_test.go | 2 | ||||
| -rw-r--r-- | weed/mq/topic.go | 4 |
6 files changed, 21 insertions, 21 deletions
diff --git a/weed/mq/broker/brokder_grpc_admin.go b/weed/mq/broker/brokder_grpc_admin.go index 0dfb69c50..cbd17b3b9 100644 --- a/weed/mq/broker/brokder_grpc_admin.go +++ b/weed/mq/broker/brokder_grpc_admin.go @@ -2,12 +2,12 @@ package broker import ( "context" - "github.com/chrislusf/seaweedfs/weed/cluster" - "github.com/chrislusf/seaweedfs/weed/glog" - "github.com/chrislusf/seaweedfs/weed/mq" - "github.com/chrislusf/seaweedfs/weed/pb" - "github.com/chrislusf/seaweedfs/weed/pb/master_pb" - "github.com/chrislusf/seaweedfs/weed/pb/mq_pb" + "github.com/seaweedfs/seaweedfs/weed/cluster" + "github.com/seaweedfs/seaweedfs/weed/glog" + "github.com/seaweedfs/seaweedfs/weed/mq" + "github.com/seaweedfs/seaweedfs/weed/pb" + "github.com/seaweedfs/seaweedfs/weed/pb/master_pb" + "github.com/seaweedfs/seaweedfs/weed/pb/mq_pb" "sort" "sync" ) diff --git a/weed/mq/broker/broker_segment_serde.go b/weed/mq/broker/broker_segment_serde.go index 25fca005b..c0741071f 100644 --- a/weed/mq/broker/broker_segment_serde.go +++ b/weed/mq/broker/broker_segment_serde.go @@ -3,12 +3,12 @@ package broker import ( "bytes" "fmt" - "github.com/chrislusf/seaweedfs/weed/filer" - "github.com/chrislusf/seaweedfs/weed/mq" - "github.com/chrislusf/seaweedfs/weed/pb" - "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" - "github.com/chrislusf/seaweedfs/weed/pb/mq_pb" "github.com/golang/protobuf/jsonpb" + "github.com/seaweedfs/seaweedfs/weed/filer" + "github.com/seaweedfs/seaweedfs/weed/mq" + "github.com/seaweedfs/seaweedfs/weed/pb" + "github.com/seaweedfs/seaweedfs/weed/pb/filer_pb" + "github.com/seaweedfs/seaweedfs/weed/pb/mq_pb" "time" ) diff --git a/weed/mq/broker/broker_server.go b/weed/mq/broker/broker_server.go index b95db0ecf..512667d15 100644 --- a/weed/mq/broker/broker_server.go +++ b/weed/mq/broker/broker_server.go @@ -1,15 +1,15 @@ package broker import ( - "github.com/chrislusf/seaweedfs/weed/cluster" - "github.com/chrislusf/seaweedfs/weed/pb/mq_pb" - "github.com/chrislusf/seaweedfs/weed/wdclient" + "github.com/seaweedfs/seaweedfs/weed/cluster" + "github.com/seaweedfs/seaweedfs/weed/pb/mq_pb" + "github.com/seaweedfs/seaweedfs/weed/wdclient" "google.golang.org/grpc" "time" - "github.com/chrislusf/seaweedfs/weed/pb" - "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" - "github.com/chrislusf/seaweedfs/weed/pb/master_pb" + "github.com/seaweedfs/seaweedfs/weed/pb" + "github.com/seaweedfs/seaweedfs/weed/pb/filer_pb" + "github.com/seaweedfs/seaweedfs/weed/pb/master_pb" ) type MessageQueueBrokerOption struct { diff --git a/weed/mq/segment/message_serde.go b/weed/mq/segment/message_serde.go index 8efa9fe21..66a76c57d 100644 --- a/weed/mq/segment/message_serde.go +++ b/weed/mq/segment/message_serde.go @@ -1,8 +1,8 @@ package segment import ( - "github.com/chrislusf/seaweedfs/weed/pb/message_fbs" flatbuffers "github.com/google/flatbuffers/go" + "github.com/seaweedfs/seaweedfs/weed/pb/message_fbs" ) type MessageBatchBuilder struct { diff --git a/weed/mq/segment/message_serde_test.go b/weed/mq/segment/message_serde_test.go index bf561d2c0..cb7ad1501 100644 --- a/weed/mq/segment/message_serde_test.go +++ b/weed/mq/segment/message_serde_test.go @@ -1,8 +1,8 @@ package segment import ( - "github.com/chrislusf/seaweedfs/weed/pb/message_fbs" flatbuffers "github.com/google/flatbuffers/go" + "github.com/seaweedfs/seaweedfs/weed/pb/message_fbs" "github.com/stretchr/testify/assert" "testing" ) diff --git a/weed/mq/topic.go b/weed/mq/topic.go index 12a749133..96544bac9 100644 --- a/weed/mq/topic.go +++ b/weed/mq/topic.go @@ -2,8 +2,8 @@ package mq import ( "fmt" - "github.com/chrislusf/seaweedfs/weed/filer" - "github.com/chrislusf/seaweedfs/weed/pb/mq_pb" + "github.com/seaweedfs/seaweedfs/weed/filer" + "github.com/seaweedfs/seaweedfs/weed/pb/mq_pb" "time" ) |