diff --git a/external/external.go b/external/external.go index 04a6d24..1642199 100644 --- a/external/external.go +++ b/external/external.go @@ -1,13 +1,13 @@ package external import ( - occe "git.loafle.net/overflow/commons-go/config/external" + ocec "git.loafle.net/overflow/commons-go/external/config" "git.loafle.net/overflow/gateway/external/grpc" "git.loafle.net/overflow/gateway/external/kafka" "git.loafle.net/overflow/gateway/external/redis" ) -func InitPackage(config *occe.External) { +func InitPackage(config *ocec.External) { if nil == config { return } @@ -16,7 +16,7 @@ func InitPackage(config *occe.External) { kafka.InitPackage(config.Kafka) } -func StartPackage(config *occe.External) { +func StartPackage(config *ocec.External) { if nil == config { return } @@ -25,7 +25,7 @@ func StartPackage(config *occe.External) { kafka.StartPackage(config.Kafka) } -func StopPackage(config *occe.External) { +func StopPackage(config *ocec.External) { if nil == config { return } @@ -34,7 +34,7 @@ func StopPackage(config *occe.External) { kafka.StopPackage(config.Kafka) } -func DestroyPackage(config *occe.External) { +func DestroyPackage(config *ocec.External) { if nil == config { return } diff --git a/external/grpc/grpc.go b/external/grpc/grpc.go index 0dda84d..e4aa10e 100644 --- a/external/grpc/grpc.go +++ b/external/grpc/grpc.go @@ -8,13 +8,13 @@ import ( "git.loafle.net/commons/logging-go" oci "git.loafle.net/overflow/central_api/golang" - occeg "git.loafle.net/overflow/commons-go/config/external/grpc" + ocec "git.loafle.net/overflow/commons-go/external/config" "google.golang.org/grpc" ) var grpcClient oci.OverflowApiServerClient -func InitPackage(config *occeg.GRPC) { +func InitPackage(config *ocec.GRPC) { if nil == config { return } @@ -27,21 +27,21 @@ func InitPackage(config *occeg.GRPC) { logging.Logger().Infof("GRPC: connected to %s", config.Address) } -func StartPackage(config *occeg.GRPC) { +func StartPackage(config *ocec.GRPC) { if nil == config { return } } -func StopPackage(config *occeg.GRPC) { +func StopPackage(config *ocec.GRPC) { if nil == config { return } } -func DestroyPackage(config *occeg.GRPC) { +func DestroyPackage(config *ocec.GRPC) { if nil == config { return } diff --git a/external/kafka/kafka.go b/external/kafka/kafka.go index da469ea..40c0a80 100644 --- a/external/kafka/kafka.go +++ b/external/kafka/kafka.go @@ -5,7 +5,7 @@ import ( "fmt" "git.loafle.net/commons/logging-go" - occek "git.loafle.net/overflow/commons-go/config/external/kafka" + ocec "git.loafle.net/overflow/commons-go/external/config" "github.com/segmentio/kafka-go" ) @@ -13,7 +13,7 @@ var ( kafkaWriter *kafka.Writer ) -func InitPackage(config *occek.Kafka) { +func InitPackage(config *ocec.Kafka) { kafkaWriter = kafka.NewWriter(kafka.WriterConfig{ Brokers: []string{"192.168.1.50:9092"}, @@ -23,21 +23,21 @@ func InitPackage(config *occek.Kafka) { } -func StartPackage(config *occek.Kafka) { +func StartPackage(config *ocec.Kafka) { if nil == config { return } } -func StopPackage(config *occek.Kafka) { +func StopPackage(config *ocec.Kafka) { if nil == config { return } } -func DestroyPackage(config *occek.Kafka) { +func DestroyPackage(config *ocec.Kafka) { if nil == config { return } diff --git a/external/redis/redis.go b/external/redis/redis.go index e6c8552..010dd55 100644 --- a/external/redis/redis.go +++ b/external/redis/redis.go @@ -2,13 +2,13 @@ package redis import ( "git.loafle.net/commons/logging-go" - occer "git.loafle.net/overflow/commons-go/config/external/redis" + ocec "git.loafle.net/overflow/commons-go/external/config" "github.com/gomodule/redigo/redis" ) var Pool *redis.Pool -func InitPackage(config *occer.Redis) { +func InitPackage(config *ocec.Redis) { if nil == config { return } @@ -26,20 +26,20 @@ func InitPackage(config *occer.Redis) { logging.Logger().Infof("Redis: initialized [%s:%s]", config.Network, config.Address) } -func StartPackage(config *occer.Redis) { +func StartPackage(config *ocec.Redis) { if nil == config { return } } -func StopPackage(config *occer.Redis) { +func StopPackage(config *ocec.Redis) { if nil == config { return } } -func DestroyPackage(config *occer.Redis) { +func DestroyPackage(config *ocec.Redis) { if nil == config { return }