From c94c37d093418aa286d7962551f51584b74f9551 Mon Sep 17 00:00:00 2001 From: crusader Date: Thu, 26 Apr 2018 16:58:25 +0900 Subject: [PATCH] ing --- external/external.go | 10 +++++----- external/grpc/grpc.go | 10 +++++----- external/kafka/kafka.go | 10 +++++----- external/redis/redis.go | 10 +++++----- 4 files changed, 20 insertions(+), 20 deletions(-) diff --git a/external/external.go b/external/external.go index 1642199..04a6d24 100644 --- a/external/external.go +++ b/external/external.go @@ -1,13 +1,13 @@ package external import ( - ocec "git.loafle.net/overflow/commons-go/external/config" + occe "git.loafle.net/overflow/commons-go/config/external" "git.loafle.net/overflow/gateway/external/grpc" "git.loafle.net/overflow/gateway/external/kafka" "git.loafle.net/overflow/gateway/external/redis" ) -func InitPackage(config *ocec.External) { +func InitPackage(config *occe.External) { if nil == config { return } @@ -16,7 +16,7 @@ func InitPackage(config *ocec.External) { kafka.InitPackage(config.Kafka) } -func StartPackage(config *ocec.External) { +func StartPackage(config *occe.External) { if nil == config { return } @@ -25,7 +25,7 @@ func StartPackage(config *ocec.External) { kafka.StartPackage(config.Kafka) } -func StopPackage(config *ocec.External) { +func StopPackage(config *occe.External) { if nil == config { return } @@ -34,7 +34,7 @@ func StopPackage(config *ocec.External) { kafka.StopPackage(config.Kafka) } -func DestroyPackage(config *ocec.External) { +func DestroyPackage(config *occe.External) { if nil == config { return } diff --git a/external/grpc/grpc.go b/external/grpc/grpc.go index 5b664b8..7144eae 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" - ocec "git.loafle.net/overflow/commons-go/external/config" + occe "git.loafle.net/overflow/commons-go/config/external" "google.golang.org/grpc" ) var grpcClient oci.CentralAPIClient -func InitPackage(config *ocec.GRPC) { +func InitPackage(config *occe.GRPC) { if nil == config { return } @@ -27,20 +27,20 @@ func InitPackage(config *ocec.GRPC) { logging.Logger().Infof("GRPC: connected to %s", config.Address) } -func StartPackage(config *ocec.GRPC) { +func StartPackage(config *occe.GRPC) { if nil == config { return } } -func StopPackage(config *ocec.GRPC) { +func StopPackage(config *occe.GRPC) { if nil == config { return } } -func DestroyPackage(config *ocec.GRPC) { +func DestroyPackage(config *occe.GRPC) { if nil == config { return } diff --git a/external/kafka/kafka.go b/external/kafka/kafka.go index 40c0a80..aa7939c 100644 --- a/external/kafka/kafka.go +++ b/external/kafka/kafka.go @@ -5,7 +5,7 @@ import ( "fmt" "git.loafle.net/commons/logging-go" - ocec "git.loafle.net/overflow/commons-go/external/config" + occe "git.loafle.net/overflow/commons-go/config/external" "github.com/segmentio/kafka-go" ) @@ -13,7 +13,7 @@ var ( kafkaWriter *kafka.Writer ) -func InitPackage(config *ocec.Kafka) { +func InitPackage(config *occe.Kafka) { kafkaWriter = kafka.NewWriter(kafka.WriterConfig{ Brokers: []string{"192.168.1.50:9092"}, @@ -23,21 +23,21 @@ func InitPackage(config *ocec.Kafka) { } -func StartPackage(config *ocec.Kafka) { +func StartPackage(config *occe.Kafka) { if nil == config { return } } -func StopPackage(config *ocec.Kafka) { +func StopPackage(config *occe.Kafka) { if nil == config { return } } -func DestroyPackage(config *ocec.Kafka) { +func DestroyPackage(config *occe.Kafka) { if nil == config { return } diff --git a/external/redis/redis.go b/external/redis/redis.go index 010dd55..90c9f11 100644 --- a/external/redis/redis.go +++ b/external/redis/redis.go @@ -2,13 +2,13 @@ package redis import ( "git.loafle.net/commons/logging-go" - ocec "git.loafle.net/overflow/commons-go/external/config" + occe "git.loafle.net/overflow/commons-go/config/external" "github.com/gomodule/redigo/redis" ) var Pool *redis.Pool -func InitPackage(config *ocec.Redis) { +func InitPackage(config *occe.Redis) { if nil == config { return } @@ -26,20 +26,20 @@ func InitPackage(config *ocec.Redis) { logging.Logger().Infof("Redis: initialized [%s:%s]", config.Network, config.Address) } -func StartPackage(config *ocec.Redis) { +func StartPackage(config *occe.Redis) { if nil == config { return } } -func StopPackage(config *ocec.Redis) { +func StopPackage(config *occe.Redis) { if nil == config { return } } -func DestroyPackage(config *ocec.Redis) { +func DestroyPackage(config *occe.Redis) { if nil == config { return }