ing
This commit is contained in:
parent
d4664c368e
commit
eec92a5aba
|
@ -3,6 +3,7 @@ package external
|
||||||
import (
|
import (
|
||||||
occe "git.loafle.net/overflow/commons-go/config/external"
|
occe "git.loafle.net/overflow/commons-go/config/external"
|
||||||
"git.loafle.net/overflow/external-go/grpc"
|
"git.loafle.net/overflow/external-go/grpc"
|
||||||
|
"git.loafle.net/overflow/external-go/influxdb"
|
||||||
"git.loafle.net/overflow/external-go/kafka"
|
"git.loafle.net/overflow/external-go/kafka"
|
||||||
"git.loafle.net/overflow/external-go/redis"
|
"git.loafle.net/overflow/external-go/redis"
|
||||||
)
|
)
|
||||||
|
@ -14,6 +15,7 @@ func InitPackage(config *occe.External) {
|
||||||
grpc.InitPackage(config.GRPC)
|
grpc.InitPackage(config.GRPC)
|
||||||
redis.InitPackage(config.Redis)
|
redis.InitPackage(config.Redis)
|
||||||
kafka.InitPackage(config.Kafka)
|
kafka.InitPackage(config.Kafka)
|
||||||
|
influxdb.InitPackage(config.InfluxDB)
|
||||||
}
|
}
|
||||||
|
|
||||||
func StartPackage(config *occe.External) {
|
func StartPackage(config *occe.External) {
|
||||||
|
@ -23,6 +25,7 @@ func StartPackage(config *occe.External) {
|
||||||
grpc.StartPackage(config.GRPC)
|
grpc.StartPackage(config.GRPC)
|
||||||
redis.StartPackage(config.Redis)
|
redis.StartPackage(config.Redis)
|
||||||
kafka.StartPackage(config.Kafka)
|
kafka.StartPackage(config.Kafka)
|
||||||
|
influxdb.StartPackage(config.InfluxDB)
|
||||||
}
|
}
|
||||||
|
|
||||||
func StopPackage(config *occe.External) {
|
func StopPackage(config *occe.External) {
|
||||||
|
@ -32,6 +35,7 @@ func StopPackage(config *occe.External) {
|
||||||
grpc.StopPackage(config.GRPC)
|
grpc.StopPackage(config.GRPC)
|
||||||
redis.StopPackage(config.Redis)
|
redis.StopPackage(config.Redis)
|
||||||
kafka.StopPackage(config.Kafka)
|
kafka.StopPackage(config.Kafka)
|
||||||
|
influxdb.StopPackage(config.InfluxDB)
|
||||||
}
|
}
|
||||||
|
|
||||||
func DestroyPackage(config *occe.External) {
|
func DestroyPackage(config *occe.External) {
|
||||||
|
@ -41,4 +45,5 @@ func DestroyPackage(config *occe.External) {
|
||||||
grpc.DestroyPackage(config.GRPC)
|
grpc.DestroyPackage(config.GRPC)
|
||||||
redis.DestroyPackage(config.Redis)
|
redis.DestroyPackage(config.Redis)
|
||||||
kafka.DestroyPackage(config.Kafka)
|
kafka.DestroyPackage(config.Kafka)
|
||||||
|
influxdb.DestroyPackage(config.InfluxDB)
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue
Block a user