update module name

XiaoMi · Jun 19, 2019 · 105ffdc · 105ffdc
1 parent 0165c5b
commit 105ffdc
Show file tree

Hide file tree

Showing 62 changed files with 188 additions and 170 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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=
+galaxy.talos.partition.id=1
diff --git 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
@@ -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=
+galaxy.talos.partition.id=2
diff --git 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"
 )