server

func Connectionlog(ctx context.Context, wg *sync.WaitGroup, mongourl string, permurl string, influxurl 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)