overflow_cloud/gateway
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ing

Browse Source
This commit is contained in:
crusader 2018-04-10 14:29:17 +09:00
parent b55a07327e
commit e1cd1e7e19
4 changed files with 18 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
external/external.go vendored
View File

@ -7,7 +7,7 @@ import (
"git.loafle.net/overflow/gateway/external/redis" "git.loafle.net/overflow/gateway/external/redis"
) )
func InitPackage(config *occe.ExternalConfig) { func InitPackage(config *occe.External) {
if nil == config { if nil == config {
return return
} }
@ -16,7 +16,7 @@ func InitPackage(config *occe.ExternalConfig) {
kafka.InitPackage(config.Kafka) kafka.InitPackage(config.Kafka)
} }
func StartPackage(config *occe.ExternalConfig) { func StartPackage(config *occe.External) {
if nil == config { if nil == config {
return return
} }
@ -25,7 +25,7 @@ func StartPackage(config *occe.ExternalConfig) {
kafka.StartPackage(config.Kafka) kafka.StartPackage(config.Kafka)
} }
func StopPackage(config *occe.ExternalConfig) { func StopPackage(config *occe.External) {
if nil == config { if nil == config {
return return
} }
@ -34,7 +34,7 @@ func StopPackage(config *occe.ExternalConfig) {
kafka.StopPackage(config.Kafka) kafka.StopPackage(config.Kafka)
} }
func DestroyPackage(config *occe.ExternalConfig) { func DestroyPackage(config *occe.External) {
if nil == config { if nil == config {
return return
} }

10
external/grpc/grpc.go vendored
View File

@ -14,12 +14,12 @@ import (
var grpcClient oci.OverflowApiServerClient var grpcClient oci.OverflowApiServerClient
func InitPackage(config *occeg.GRPConfig) { func InitPackage(config *occeg.GRPC) {
if nil == config { if nil == config {
return return
} }
go func() { go func() {
conn, err := grpc.Dial("192.168.1.50:50006", grpc.WithInsecure()) conn, err := grpc.Dial(config.Address, grpc.WithInsecure())
if nil != err { if nil != err {
logging.Logger().Panic(err) logging.Logger().Panic(err)
} }
@ -27,21 +27,21 @@ func InitPackage(config *occeg.GRPConfig) {
}() }()
} }
func StartPackage(config *occeg.GRPConfig) { func StartPackage(config *occeg.GRPC) {
if nil == config { if nil == config {
return return
} }
} }
func StopPackage(config *occeg.GRPConfig) { func StopPackage(config *occeg.GRPC) {
if nil == config { if nil == config {
return return
} }
} }
func DestroyPackage(config *occeg.GRPConfig) { func DestroyPackage(config *occeg.GRPC) {
if nil == config { if nil == config {
return return
} }

8
external/kafka/kafka.go vendored
View File

@ -13,7 +13,7 @@ var (
kafkaWriter *kafka.Writer kafkaWriter *kafka.Writer
) )
func InitPackage(config *occek.KafkaConfig) { func InitPackage(config *occek.Kafka) {
kafkaWriter = kafka.NewWriter(kafka.WriterConfig{ kafkaWriter = kafka.NewWriter(kafka.WriterConfig{
Brokers: []string{"192.168.1.50:9092"}, Brokers: []string{"192.168.1.50:9092"},
@ -23,21 +23,21 @@ func InitPackage(config *occek.KafkaConfig) {
} }
func StartPackage(config *occek.KafkaConfig) { func StartPackage(config *occek.Kafka) {
if nil == config { if nil == config {
return return
} }
} }
func StopPackage(config *occek.KafkaConfig) { func StopPackage(config *occek.Kafka) {
if nil == config { if nil == config {
return return
} }
} }
func DestroyPackage(config *occek.KafkaConfig) { func DestroyPackage(config *occek.Kafka) {
if nil == config { if nil == config {
return return
} }

10
external/redis/redis.go vendored
View File

@ -7,7 +7,7 @@ import (
var Pool *redis.Pool var Pool *redis.Pool
func InitPackage(config *occer.RedisConfig) { func InitPackage(config *occer.Redis) {
if nil == config { if nil == config {
return return
} }
@ -19,26 +19,26 @@ func InitPackage(config *occer.RedisConfig) {
Wait: true, Wait: true,
MaxConnLifetime: 1, MaxConnLifetime: 1,
Dial: func() (redis.Conn, error) { Dial: func() (redis.Conn, error) {
return redis.Dial("tcp", "192.168.1.50:6379") return redis.Dial(config.Network, config.Address)
}, },
} }
} }
func StartPackage(config *occer.RedisConfig) { func StartPackage(config *occer.Redis) {
if nil == config { if nil == config {
return return
} }
} }
func StopPackage(config *occer.RedisConfig) { func StopPackage(config *occer.Redis) {
if nil == config { if nil == config {
return return
} }
} }
func DestroyPackage(config *occer.RedisConfig) { func DestroyPackage(config *occer.Redis) {
if nil == config { if nil == config {
return return
} }