Versions in this module Expand all Collapse all v0 v0.0.1 Dec 19, 2023 Changes in this version + func Connectionlog(ctx context.Context, wg *sync.WaitGroup, mongourl string, permurl string, ...) (hostport string, containerip string, err error) + func Forward(ctx context.Context, fromPort int, toAddr string) error + func Influxdb(ctx context.Context, wg *sync.WaitGroup) (hostport string, containerip string, err error) + func Kafka(ctx context.Context, wg *sync.WaitGroup, zookeeperUrl string) (kafkaUrl string, err error) + func MongoDB(ctx context.Context, wg *sync.WaitGroup) (hostport string, containerip string, err error) + func New(ctx context.Context, wg *sync.WaitGroup, defaults config.Config) (config config.Config, connectionlogip string, err error) + func OpenSearch(ctx context.Context, wg *sync.WaitGroup) (hostPort string, ipAddress string, err error) + func PermissionSearch(ctx context.Context, wg *sync.WaitGroup, kafkaUrl string, dbIp string) (hostPort string, ipAddress string, err error) + func Zookeeper(ctx context.Context, wg *sync.WaitGroup) (hostPort string, ipAddress string, err error)