diff --git a/admin/Admin.go b/admin/Admin.go index db0b1e2..58c336d 100644 --- a/admin/Admin.go +++ b/admin/Admin.go @@ -7,10 +7,10 @@ package admin import ( - "talos-sdk-golang/thrift/consumer" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/thrift/quota" - "talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/thrift/consumer" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/thrift/quota" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" ) type Admin interface { diff --git a/admin/TalosAdmin.go b/admin/TalosAdmin.go index beb9409..8ab6446 100644 --- a/admin/TalosAdmin.go +++ b/admin/TalosAdmin.go @@ -9,13 +9,13 @@ package admin import ( "strings" - "talos-sdk-golang/client" - "talos-sdk-golang/thrift/auth" - "talos-sdk-golang/thrift/consumer" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/thrift/quota" - "talos-sdk-golang/thrift/topic" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/client" + "github.com/XiaoMi/talos-sdk-golang/thrift/auth" + "github.com/XiaoMi/talos-sdk-golang/thrift/consumer" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/thrift/quota" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/utils" ) type TalosAdmin struct { diff --git a/client/ScheduleInfoCache.go b/client/ScheduleInfoCache.go index 17ec3ea..5664e62 100644 --- a/client/ScheduleInfoCache.go +++ b/client/ScheduleInfoCache.go @@ -10,9 +10,9 @@ import ( "sync" "time" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/thrift/topic" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/utils" log "github.com/sirupsen/logrus" ) diff --git a/client/SimpleTopicAbnormalCallback.go b/client/SimpleTopicAbnormalCallback.go index 249ccb9..9863f5b 100644 --- a/client/SimpleTopicAbnormalCallback.go +++ b/client/SimpleTopicAbnormalCallback.go @@ -7,7 +7,7 @@ package client import ( - "talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" log "github.com/sirupsen/logrus" ) diff --git a/client/TalosClientConfig.go b/client/TalosClientConfig.go index b93029f..7f11ee1 100644 --- a/client/TalosClientConfig.go +++ b/client/TalosClientConfig.go @@ -9,7 +9,7 @@ package client import ( "strconv" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/utils" ) type TalosClientConfig struct { diff --git a/client/TalosClientFactory.go b/client/TalosClientFactory.go index ab7d46e..f1604ce 100644 --- a/client/TalosClientFactory.go +++ b/client/TalosClientFactory.go @@ -13,13 +13,13 @@ import ( "runtime" "time" - "talos-sdk-golang/thrift/auth" - "talos-sdk-golang/thrift/common" - "talos-sdk-golang/thrift/consumer" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/thrift/quota" - "talos-sdk-golang/thrift/topic" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/thrift/auth" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/consumer" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/thrift/quota" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/utils" "git.apache.org/thrift.git/lib/go/thrift" ) diff --git a/client/TalosErrors.go b/client/TalosErrors.go index 8da1098..22bd7a8 100644 --- a/client/TalosErrors.go +++ b/client/TalosErrors.go @@ -9,7 +9,7 @@ package client import ( "fmt" - "talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" ) type TalosErrorCodePeeker interface { diff --git a/client/TalosHttpClient.go b/client/TalosHttpClient.go index 57d7271..8c53ebe 100644 --- a/client/TalosHttpClient.go +++ b/client/TalosHttpClient.go @@ -34,8 +34,8 @@ import ( "strings" "time" - "talos-sdk-golang/thrift/auth" - "talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/auth" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" "git.apache.org/thrift.git/lib/go/thrift" "github.com/gofrs/uuid" diff --git a/client/TopicAbnormalCallback.go b/client/TopicAbnormalCallback.go index ec51962..5e0a3a2 100644 --- a/client/TopicAbnormalCallback.go +++ b/client/TopicAbnormalCallback.go @@ -7,7 +7,7 @@ package client import ( - "talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" ) type TopicAbnormalCallback interface { diff --git a/client/compression/Compression.go b/client/compression/Compression.go index cefac8a..96b8c70 100644 --- a/client/compression/Compression.go +++ b/client/compression/Compression.go @@ -12,9 +12,9 @@ import ( "fmt" "io/ioutil" - "talos-sdk-golang/client/serialization" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/client/serialization" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/utils" "github.com/eapache/go-xerial-snappy" ) diff --git a/client/serialization/MessageSerialization.go b/client/serialization/MessageSerialization.go index a0163fa..8934e03 100644 --- a/client/serialization/MessageSerialization.go +++ b/client/serialization/MessageSerialization.go @@ -9,7 +9,7 @@ package serialization import ( "bytes" - "talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" log "github.com/sirupsen/logrus" ) diff --git a/client/serialization/MessageSerializer.go b/client/serialization/MessageSerializer.go index 654642d..f6ba7aa 100644 --- a/client/serialization/MessageSerializer.go +++ b/client/serialization/MessageSerializer.go @@ -11,7 +11,7 @@ import ( "encoding/binary" "fmt" - "talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" ) type MessageSerializer interface { diff --git a/client/serialization/MessageSerializerV1.go b/client/serialization/MessageSerializerV1.go index 63476b9..59013ca 100644 --- a/client/serialization/MessageSerializerV1.go +++ b/client/serialization/MessageSerializerV1.go @@ -10,7 +10,7 @@ import ( "bytes" "encoding/binary" - "talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" log "github.com/sirupsen/logrus" ) diff --git a/client/serialization/MessageSerializerV2.go b/client/serialization/MessageSerializerV2.go index 6a5de99..6912158 100644 --- a/client/serialization/MessageSerializerV2.go +++ b/client/serialization/MessageSerializerV2.go @@ -11,8 +11,8 @@ import ( "encoding/binary" "fmt" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/utils" log "github.com/sirupsen/logrus" ) diff --git a/client/serialization/MessageSerializerV3.go b/client/serialization/MessageSerializerV3.go index 480cd7f..86b485d 100644 --- a/client/serialization/MessageSerializerV3.go +++ b/client/serialization/MessageSerializerV3.go @@ -10,8 +10,8 @@ import ( "bytes" "encoding/binary" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/utils" log "github.com/sirupsen/logrus" ) diff --git a/consumer/MessageProcessor.go b/consumer/MessageProcessor.go index ae0adea..4f1a66f 100644 --- a/consumer/MessageProcessor.go +++ b/consumer/MessageProcessor.go @@ -7,7 +7,7 @@ package consumer import ( - "talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" ) type MessageProcessor interface { diff --git a/consumer/MessageReader.go b/consumer/MessageReader.go index bf8f702..ff4e1e0 100644 --- a/consumer/MessageReader.go +++ b/consumer/MessageReader.go @@ -10,11 +10,10 @@ import ( "sync/atomic" "time" - "talos-sdk-golang/thrift/consumer" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/thrift/topic" - - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/thrift/consumer" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/utils" log "github.com/sirupsen/logrus" ) diff --git a/consumer/PartitionFetcher.go b/consumer/PartitionFetcher.go index 2445ee1..08c7960 100644 --- a/consumer/PartitionFetcher.go +++ b/consumer/PartitionFetcher.go @@ -10,11 +10,11 @@ import ( "sync" "sync/atomic" - "talos-sdk-golang/client" - "talos-sdk-golang/thrift/consumer" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/thrift/topic" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/client" + "github.com/XiaoMi/talos-sdk-golang/thrift/consumer" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/utils" log "github.com/sirupsen/logrus" ) diff --git a/consumer/SimpleConsumer.go b/consumer/SimpleConsumer.go index eacfab8..52ebd32 100644 --- a/consumer/SimpleConsumer.go +++ b/consumer/SimpleConsumer.go @@ -10,12 +10,12 @@ import ( "strconv" "sync/atomic" - "talos-sdk-golang/client" - "talos-sdk-golang/client/compression" - "talos-sdk-golang/thrift/auth" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/thrift/topic" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/client" + "github.com/XiaoMi/talos-sdk-golang/client/compression" + "github.com/XiaoMi/talos-sdk-golang/thrift/auth" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/utils" log "github.com/sirupsen/logrus" ) diff --git a/consumer/TalosConsumer.go b/consumer/TalosConsumer.go index 65acc94..cbfe4e8 100644 --- a/consumer/TalosConsumer.go +++ b/consumer/TalosConsumer.go @@ -13,12 +13,12 @@ import ( "sync" "time" - "talos-sdk-golang/admin" - "talos-sdk-golang/client" - "talos-sdk-golang/thrift/auth" - "talos-sdk-golang/thrift/consumer" - "talos-sdk-golang/thrift/topic" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/admin" + "github.com/XiaoMi/talos-sdk-golang/client" + "github.com/XiaoMi/talos-sdk-golang/thrift/auth" + "github.com/XiaoMi/talos-sdk-golang/thrift/consumer" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/utils" log "github.com/sirupsen/logrus" ) diff --git a/consumer/TalosConsumerConfig.go b/consumer/TalosConsumerConfig.go index 8541340..21f494d 100644 --- a/consumer/TalosConsumerConfig.go +++ b/consumer/TalosConsumerConfig.go @@ -9,8 +9,8 @@ package consumer import ( "strconv" - "talos-sdk-golang/client" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/client" + "github.com/XiaoMi/talos-sdk-golang/utils" log "github.com/sirupsen/logrus" ) diff --git a/consumer/TalosMessageReader.go b/consumer/TalosMessageReader.go index 28b6e50..2c93272 100644 --- a/consumer/TalosMessageReader.go +++ b/consumer/TalosMessageReader.go @@ -10,9 +10,9 @@ import ( "sync/atomic" "time" - "talos-sdk-golang/thrift/common" - "talos-sdk-golang/thrift/consumer" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/consumer" + "github.com/XiaoMi/talos-sdk-golang/utils" log "github.com/sirupsen/logrus" ) diff --git a/example/admin/TalosAdminDemo.go b/example/admin/TalosAdminDemo.go index dde5f48..55144ce 100644 --- a/example/admin/TalosAdminDemo.go +++ b/example/admin/TalosAdminDemo.go @@ -7,15 +7,13 @@ package main import ( - "talos-sdk-golang/utils" - - "talos-sdk-golang/admin" - "talos-sdk-golang/client" - - "talos-sdk-golang/thrift/auth" - "talos-sdk-golang/thrift/authorization" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/admin" + "github.com/XiaoMi/talos-sdk-golang/client" + "github.com/XiaoMi/talos-sdk-golang/thrift/auth" + "github.com/XiaoMi/talos-sdk-golang/thrift/authorization" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/utils" "git.apache.org/thrift.git/lib/go/thrift" log "github.com/sirupsen/logrus" diff --git a/example/simple_consumer/TalosSimpleConsumerDemo.go b/example/simple_consumer/TalosSimpleConsumerDemo.go index 6fad901..a0b9873 100644 --- a/example/simple_consumer/TalosSimpleConsumerDemo.go +++ b/example/simple_consumer/TalosSimpleConsumerDemo.go @@ -10,9 +10,9 @@ import ( "flag" "time" - "talos-sdk-golang/consumer" - "talos-sdk-golang/thrift/common" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/consumer" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/utils" log "github.com/sirupsen/logrus" ) diff --git a/example/simple_consumer/simpleConsumer.conf b/example/simple_consumer/simpleConsumer.conf index 8d62a22..d7a61ad 100644 --- a/example/simple_consumer/simpleConsumer.conf +++ b/example/simple_consumer/simpleConsumer.conf @@ -2,12 +2,12 @@ # 【请注意】所有的 value 值都不要加双引号"", 请仿照e.g.以及Wiki链接填写 ############################################################### -galaxy.talos.service.endpoint= +galaxy.talos.service.endpoint=http://staging-cnbj4-fusion-talos.api.xiaomi.net -galaxy.talos.topic.name= +galaxy.talos.topic.name=get_topic_offset -galaxy.talos.access.key= +galaxy.talos.access.key=AKKB5UEGSRJ3X63RTI -galaxy.talos.access.secret= +galaxy.talos.access.secret=lB262sFSMOFgKHs+ptLTtXr2Osr1azkvnmFYv6Oq -galaxy.talos.partition.id= \ No newline at end of file +galaxy.talos.partition.id=1 \ No newline at end of file diff --git a/example/simple_producer/TalosSimpleProducerDemo.go b/example/simple_producer/TalosSimpleProducerDemo.go index 7e0ffb0..9b330ee 100644 --- a/example/simple_producer/TalosSimpleProducerDemo.go +++ b/example/simple_producer/TalosSimpleProducerDemo.go @@ -11,9 +11,9 @@ import ( "sync/atomic" "time" - "talos-sdk-golang/producer" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/producer" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/utils" "git.apache.org/thrift.git/lib/go/thrift" log "github.com/sirupsen/logrus" diff --git a/example/simple_producer/simpleProducer.conf b/example/simple_producer/simpleProducer.conf index 8d62a22..423e52f 100644 --- a/example/simple_producer/simpleProducer.conf +++ b/example/simple_producer/simpleProducer.conf @@ -2,12 +2,12 @@ # 【请注意】所有的 value 值都不要加双引号"", 请仿照e.g.以及Wiki链接填写 ############################################################### -galaxy.talos.service.endpoint= +galaxy.talos.service.endpoint=http://staging-cnbj4-fusion-talos.api.xiaomi.net -galaxy.talos.topic.name= +galaxy.talos.topic.name=get_topic_offset -galaxy.talos.access.key= +galaxy.talos.access.key=AKKB5UEGSRJ3X63RTI -galaxy.talos.access.secret= +galaxy.talos.access.secret=lB262sFSMOFgKHs+ptLTtXr2Osr1azkvnmFYv6Oq -galaxy.talos.partition.id= \ No newline at end of file +galaxy.talos.partition.id=2 \ No newline at end of file diff --git a/example/talos_consumer/TalosConsumerDemo.go b/example/talos_consumer/TalosConsumerDemo.go index 23032a3..139499c 100644 --- a/example/talos_consumer/TalosConsumerDemo.go +++ b/example/talos_consumer/TalosConsumerDemo.go @@ -11,10 +11,10 @@ import ( "sync/atomic" "time" - "talos-sdk-golang/client" - "talos-sdk-golang/consumer" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/client" + "github.com/XiaoMi/talos-sdk-golang/consumer" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/utils" log "github.com/sirupsen/logrus" ) diff --git a/example/talos_consumer/talosConsumer.conf b/example/talos_consumer/talosConsumer.conf index bc1d111..f923302 100644 --- a/example/talos_consumer/talosConsumer.conf +++ b/example/talos_consumer/talosConsumer.conf @@ -5,13 +5,13 @@ # Talos域名 # Talos集群名字 # 请参见 Wiki 集群信息 -galaxy.talos.service.endpoint= +galaxy.talos.service.endpoint=http://staging-cnbj4-fusion-talos.api.xiaomi.net -galaxy.talos.topic.name= +galaxy.talos.topic.name=get_topic_offset -galaxy.talos.access.key= +galaxy.talos.access.key=AKKB5UEGSRJ3X63RTI -galaxy.talos.access.secret= +galaxy.talos.access.secret=lB262sFSMOFgKHs+ptLTtXr2Osr1azkvnmFYv6Oq # client的前缀(部门缩写) # e.g. galaxy.talos.client.prefix=departmentName- diff --git a/example/talos_producer/TalosProducerDemo.go b/example/talos_producer/TalosProducerDemo.go index 434960d..c46d6ed 100644 --- a/example/talos_producer/TalosProducerDemo.go +++ b/example/talos_producer/TalosProducerDemo.go @@ -12,11 +12,11 @@ import ( "sync/atomic" "time" - "talos-sdk-golang/client" - "talos-sdk-golang/producer" - "talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/client" + "github.com/XiaoMi/talos-sdk-golang/producer" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/utils" log "github.com/sirupsen/logrus" ) diff --git a/example/talos_producer/talosProducer.conf b/example/talos_producer/talosProducer.conf index 8aaccb0..e793661 100644 --- a/example/talos_producer/talosProducer.conf +++ b/example/talos_producer/talosProducer.conf @@ -5,10 +5,10 @@ # Talos域名 # Talos集群名字 # 请参见 Wiki 集群信息 -galaxy.talos.service.endpoint= +galaxy.talos.service.endpoint=http://staging-cnbj4-fusion-talos.api.xiaomi.net -galaxy.talos.topic.name= +galaxy.talos.topic.name=get_topic_offset -galaxy.talos.access.key= +galaxy.talos.access.key=AKKB5UEGSRJ3X63RTI -galaxy.talos.access.secret= +galaxy.talos.access.secret=lB262sFSMOFgKHs+ptLTtXr2Osr1azkvnmFYv6Oq diff --git a/go.mod b/go.mod index f92b792..13feb32 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module talos-sdk-golang +module github.com/XiaoMi/talos-sdk-golang go 1.12 diff --git a/go.sum b/go.sum index 4245a3b..791747e 100644 --- a/go.sum +++ b/go.sum @@ -1,6 +1,5 @@ git.apache.org/thrift.git v0.0.0-20141105021220-591e20f9636c h1:8Z1BqdpEgzGJNfAhMtW8SP/zdw6uoLLJZSSALQcCuak= git.apache.org/thrift.git v0.0.0-20141105021220-591e20f9636c/go.mod h1:fPE2ZNJGynbRyZ4dJvy6G277gSllfV2HJqblrnkyeyg= -github.com/XiaoMi/talos-sdk-golang v0.0.0-20190619110940-faf91b4509e9 h1:tgE180gSnp7IL3qdFAq5JZmhNY3IPFOlVS3inGgs4zA= github.com/alecthomas/log4go v0.0.0-20180109082532-d146e6b86faa h1:0zdYOLyuQ3TWIgWNgEH+LnmZNMmkO1ze3wriQt093Mk= github.com/alecthomas/log4go v0.0.0-20180109082532-d146e6b86faa/go.mod h1:iCVmQ9g4TfaRX5m5jq5sXY7RXYWPv9/PynM/GocbG3w= github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= diff --git a/producer/PartitionMessageQueue.go b/producer/PartitionMessageQueue.go index e28c3eb..e7c5895 100644 --- a/producer/PartitionMessageQueue.go +++ b/producer/PartitionMessageQueue.go @@ -11,8 +11,8 @@ import ( "sync" "time" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/utils" log "github.com/sirupsen/logrus" ) diff --git a/producer/PartitionSender.go b/producer/PartitionSender.go index 2e2b80a..c0759c8 100644 --- a/producer/PartitionSender.go +++ b/producer/PartitionSender.go @@ -11,9 +11,10 @@ import ( "time" "sync/atomic" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/thrift/topic" - "talos-sdk-golang/utils" + + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/utils" log "github.com/sirupsen/logrus" ) diff --git a/producer/SimplePartitioner.go b/producer/SimplePartitioner.go index 38ea659..33f6e0a 100644 --- a/producer/SimplePartitioner.go +++ b/producer/SimplePartitioner.go @@ -9,7 +9,7 @@ package producer import ( "math" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/utils" ) type SimplePartitioner struct { diff --git a/producer/SimpleProducer.go b/producer/SimpleProducer.go index c0bf4a2..b0220e0 100644 --- a/producer/SimpleProducer.go +++ b/producer/SimpleProducer.go @@ -11,12 +11,13 @@ import ( "sync/atomic" "strconv" - "talos-sdk-golang/client" - "talos-sdk-golang/client/compression" - "talos-sdk-golang/thrift/auth" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/thrift/topic" - "talos-sdk-golang/utils" + + "github.com/XiaoMi/talos-sdk-golang/client" + "github.com/XiaoMi/talos-sdk-golang/client/compression" + "github.com/XiaoMi/talos-sdk-golang/thrift/auth" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/utils" log "github.com/sirupsen/logrus" ) diff --git a/producer/TalosProducer.go b/producer/TalosProducer.go index cd13908..ce02055 100644 --- a/producer/TalosProducer.go +++ b/producer/TalosProducer.go @@ -13,12 +13,13 @@ import ( "time" "sync/atomic" - "talos-sdk-golang/admin" - "talos-sdk-golang/client" - "talos-sdk-golang/thrift/auth" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/thrift/topic" - "talos-sdk-golang/utils" + + "github.com/XiaoMi/talos-sdk-golang/admin" + "github.com/XiaoMi/talos-sdk-golang/client" + "github.com/XiaoMi/talos-sdk-golang/thrift/auth" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/utils" log "github.com/sirupsen/logrus" ) diff --git a/producer/TalosProducerConfig.go b/producer/TalosProducerConfig.go index 3fc65bd..99a8a87 100644 --- a/producer/TalosProducerConfig.go +++ b/producer/TalosProducerConfig.go @@ -10,9 +10,9 @@ import ( "fmt" "strconv" - "talos-sdk-golang/client" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/client" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/utils" log "github.com/sirupsen/logrus" ) diff --git a/producer/UserMessage.go b/producer/UserMessage.go index a04310e..f52a720 100644 --- a/producer/UserMessage.go +++ b/producer/UserMessage.go @@ -7,8 +7,8 @@ package producer import ( - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/utils" ) type UserMessage struct { diff --git a/producer/UserMessageResult.go b/producer/UserMessageResult.go index 2dcec75..9d45dfb 100644 --- a/producer/UserMessageResult.go +++ b/producer/UserMessageResult.go @@ -7,7 +7,7 @@ package producer import ( - "talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" ) type UserMessageResult struct { diff --git a/test/client/compression_test.go b/test/client/compression_test.go index a602e5f..105d9ae 100644 --- a/test/client/compression_test.go +++ b/test/client/compression_test.go @@ -12,11 +12,11 @@ import ( "testing" "time" - "talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" - "talos-sdk-golang/utils" + "github.com/XiaoMi/talos-sdk-golang/utils" - "talos-sdk-golang/client/compression" + "github.com/XiaoMi/talos-sdk-golang/client/compression" ) func setUp() []*message.Message { diff --git a/thrift/auth/constants.go b/thrift/auth/constants.go index d418dfb..a020722 100644 --- a/thrift/auth/constants.go +++ b/thrift/auth/constants.go @@ -6,8 +6,9 @@ package auth import ( "bytes" "fmt" + "git.apache.org/thrift.git/lib/go/thrift" - "talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" ) // (needed to ensure safety because of naive import list construction.) diff --git a/thrift/auth/ttypes.go b/thrift/auth/ttypes.go index e72c8f2..30421bf 100644 --- a/thrift/auth/ttypes.go +++ b/thrift/auth/ttypes.go @@ -6,8 +6,9 @@ package auth import ( "bytes" "fmt" + "git.apache.org/thrift.git/lib/go/thrift" - "talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" ) // (needed to ensure safety because of naive import list construction.) diff --git a/thrift/common/talos_base_service-remote/talos_base_service-remote.go b/thrift/common/talos_base_service-remote/talos_base_service-remote.go index d95126f..2dccf38 100755 --- a/thrift/common/talos_base_service-remote/talos_base_service-remote.go +++ b/thrift/common/talos_base_service-remote/talos_base_service-remote.go @@ -12,7 +12,8 @@ import ( "os" "strconv" "strings" - "talos-sdk-golang/thrift/common" + + "github.com/XiaoMi/talos-sdk-golang/thrift/common" "git.apache.org/thrift.git/lib/go/thrift" ) diff --git a/thrift/consumer/constants.go b/thrift/consumer/constants.go index 2c2ed04..7ef065c 100644 --- a/thrift/consumer/constants.go +++ b/thrift/consumer/constants.go @@ -6,9 +6,10 @@ package consumer import ( "bytes" "fmt" + "git.apache.org/thrift.git/lib/go/thrift" - "talos-sdk-golang/thrift/common" - "talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" ) // (needed to ensure safety because of naive import list construction.) diff --git a/thrift/consumer/consumer_service-remote/consumer_service-remote.go b/thrift/consumer/consumer_service-remote/consumer_service-remote.go index e5cfdb5..dda5c5e 100755 --- a/thrift/consumer/consumer_service-remote/consumer_service-remote.go +++ b/thrift/consumer/consumer_service-remote/consumer_service-remote.go @@ -12,7 +12,8 @@ import ( "os" "strconv" "strings" - "talos-sdk-golang/thrift/consumer" + + "github.com/XiaoMi/talos-sdk-golang/thrift/consumer" "git.apache.org/thrift.git/lib/go/thrift" ) diff --git a/thrift/consumer/consumerservice.go b/thrift/consumer/consumerservice.go index 5c0afe9..c811045 100644 --- a/thrift/consumer/consumerservice.go +++ b/thrift/consumer/consumerservice.go @@ -6,9 +6,10 @@ package consumer import ( "bytes" "fmt" + "git.apache.org/thrift.git/lib/go/thrift" - "talos-sdk-golang/thrift/common" - "talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" ) // (needed to ensure safety because of naive import list construction.) diff --git a/thrift/consumer/ttypes.go b/thrift/consumer/ttypes.go index ad05134..1b9bb69 100644 --- a/thrift/consumer/ttypes.go +++ b/thrift/consumer/ttypes.go @@ -6,9 +6,10 @@ package consumer import ( "bytes" "fmt" + "git.apache.org/thrift.git/lib/go/thrift" - "talos-sdk-golang/thrift/common" - "talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" ) // (needed to ensure safety because of naive import list construction.) diff --git a/thrift/message/constants.go b/thrift/message/constants.go index f7eab01..47842e2 100644 --- a/thrift/message/constants.go +++ b/thrift/message/constants.go @@ -6,9 +6,10 @@ package message import ( "bytes" "fmt" + "git.apache.org/thrift.git/lib/go/thrift" - "talos-sdk-golang/thrift/common" - "talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" ) // (needed to ensure safety because of naive import list construction.) diff --git a/thrift/message/message_service-remote/message_service-remote.go b/thrift/message/message_service-remote/message_service-remote.go index a5c4458..c78867d 100755 --- a/thrift/message/message_service-remote/message_service-remote.go +++ b/thrift/message/message_service-remote/message_service-remote.go @@ -12,7 +12,8 @@ import ( "os" "strconv" "strings" - "talos-sdk-golang/thrift/message" + + "github.com/XiaoMi/talos-sdk-golang/thrift/message" "git.apache.org/thrift.git/lib/go/thrift" ) diff --git a/thrift/message/messageservice.go b/thrift/message/messageservice.go index 1ea0d5e..4212bb0 100644 --- a/thrift/message/messageservice.go +++ b/thrift/message/messageservice.go @@ -6,9 +6,10 @@ package message import ( "bytes" "fmt" + "git.apache.org/thrift.git/lib/go/thrift" - "talos-sdk-golang/thrift/common" - "talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" ) // (needed to ensure safety because of naive import list construction.) diff --git a/thrift/message/ttypes.go b/thrift/message/ttypes.go index dba7bcf..db6cbd6 100644 --- a/thrift/message/ttypes.go +++ b/thrift/message/ttypes.go @@ -6,9 +6,10 @@ package message import ( "bytes" "fmt" + "git.apache.org/thrift.git/lib/go/thrift" - "talos-sdk-golang/thrift/common" - "talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" ) // (needed to ensure safety because of naive import list construction.) diff --git a/thrift/quota/constants.go b/thrift/quota/constants.go index d26b655..41c35af 100644 --- a/thrift/quota/constants.go +++ b/thrift/quota/constants.go @@ -6,8 +6,9 @@ package quota import ( "bytes" "fmt" + "git.apache.org/thrift.git/lib/go/thrift" - "talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" ) // (needed to ensure safety because of naive import list construction.) diff --git a/thrift/quota/quota_service-remote/quota_service-remote.go b/thrift/quota/quota_service-remote/quota_service-remote.go index b719c7c..83f264d 100755 --- a/thrift/quota/quota_service-remote/quota_service-remote.go +++ b/thrift/quota/quota_service-remote/quota_service-remote.go @@ -12,7 +12,8 @@ import ( "os" "strconv" "strings" - "talos-sdk-golang/thrift/quota" + + "github.com/XiaoMi/talos-sdk-golang/thrift/quota" "git.apache.org/thrift.git/lib/go/thrift" ) diff --git a/thrift/quota/quotaservice.go b/thrift/quota/quotaservice.go index 2c4f7e4..cad8fc1 100644 --- a/thrift/quota/quotaservice.go +++ b/thrift/quota/quotaservice.go @@ -6,8 +6,9 @@ package quota import ( "bytes" "fmt" + "git.apache.org/thrift.git/lib/go/thrift" - "talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" ) // (needed to ensure safety because of naive import list construction.) diff --git a/thrift/quota/ttypes.go b/thrift/quota/ttypes.go index 9778809..06babf9 100644 --- a/thrift/quota/ttypes.go +++ b/thrift/quota/ttypes.go @@ -6,8 +6,9 @@ package quota import ( "bytes" "fmt" + "git.apache.org/thrift.git/lib/go/thrift" - "talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" ) // (needed to ensure safety because of naive import list construction.) diff --git a/thrift/topic/constants.go b/thrift/topic/constants.go index 48697d7..4ede8a0 100644 --- a/thrift/topic/constants.go +++ b/thrift/topic/constants.go @@ -6,10 +6,11 @@ package topic import ( "bytes" "fmt" + "git.apache.org/thrift.git/lib/go/thrift" - "talos-sdk-golang/thrift/authorization" - "talos-sdk-golang/thrift/common" - "talos-sdk-golang/thrift/quota" + "github.com/XiaoMi/talos-sdk-golang/thrift/authorization" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/quota" ) // (needed to ensure safety because of naive import list construction.) diff --git a/thrift/topic/topic_service-remote/topic_service-remote.go b/thrift/topic/topic_service-remote/topic_service-remote.go index 537f52a..9dd2dd6 100755 --- a/thrift/topic/topic_service-remote/topic_service-remote.go +++ b/thrift/topic/topic_service-remote/topic_service-remote.go @@ -12,7 +12,8 @@ import ( "os" "strconv" "strings" - "talos-sdk-golang/thrift/topic" + + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" "git.apache.org/thrift.git/lib/go/thrift" ) diff --git a/thrift/topic/topicservice.go b/thrift/topic/topicservice.go index 16d3d58..e64fef9 100644 --- a/thrift/topic/topicservice.go +++ b/thrift/topic/topicservice.go @@ -6,10 +6,11 @@ package topic import ( "bytes" "fmt" + "git.apache.org/thrift.git/lib/go/thrift" - "talos-sdk-golang/thrift/authorization" - "talos-sdk-golang/thrift/common" - "talos-sdk-golang/thrift/quota" + "github.com/XiaoMi/talos-sdk-golang/thrift/authorization" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/quota" ) // (needed to ensure safety because of naive import list construction.) diff --git a/thrift/topic/ttypes.go b/thrift/topic/ttypes.go index 2d93e12..2f3c97a 100644 --- a/thrift/topic/ttypes.go +++ b/thrift/topic/ttypes.go @@ -6,10 +6,11 @@ package topic import ( "bytes" "fmt" + "git.apache.org/thrift.git/lib/go/thrift" - "talos-sdk-golang/thrift/authorization" - "talos-sdk-golang/thrift/common" - "talos-sdk-golang/thrift/quota" + "github.com/XiaoMi/talos-sdk-golang/thrift/authorization" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/quota" ) // (needed to ensure safety because of naive import list construction.) diff --git a/utils/Utils.go b/utils/Utils.go index dc2285f..08c2ca4 100644 --- a/utils/Utils.go +++ b/utils/Utils.go @@ -16,11 +16,11 @@ import ( "sync/atomic" "time" - "talos-sdk-golang/thrift/common" - "talos-sdk-golang/thrift/message" - "talos-sdk-golang/thrift/topic" + "github.com/XiaoMi/talos-sdk-golang/thrift/common" + "github.com/XiaoMi/talos-sdk-golang/thrift/message" + "github.com/XiaoMi/talos-sdk-golang/thrift/topic" - "talos-sdk-golang/thrift/auth" + "github.com/XiaoMi/talos-sdk-golang/thrift/auth" "git.apache.org/thrift.git/lib/go/thrift" "github.com/gofrs/uuid"