server

Documentation

Index

• func Connectionlog(ctx context.Context, wg *sync.WaitGroup, mongourl 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 NewPartial(ctx context.Context, wg *sync.WaitGroup, defaults config.Config) (config config.Config, err error)
• func PermissionsV2(ctx context.Context, wg *sync.WaitGroup, mongoUrl string, kafkaUrl string) (hostPort string, ipAddress string, err error)
• func Zookeeper(ctx context.Context, wg *sync.WaitGroup) (hostPort string, ipAddress string, err error)

Functions

func Connectionlog

func Connectionlog(ctx context.Context, wg *sync.WaitGroup, mongourl string, influxurl string, permV2Url string) (hostport string, containerip string, err error)

func Forward

func Forward(ctx context.Context, fromPort int, toAddr string) error

func Influxdb

func Influxdb(ctx context.Context, wg *sync.WaitGroup) (hostport string, containerip string, err error)

func Kafka

func Kafka(ctx context.Context, wg *sync.WaitGroup, zookeeperUrl string) (kafkaUrl string, err error)

func MongoDB

func MongoDB(ctx context.Context, wg *sync.WaitGroup) (hostport string, containerip string, err error)

func New

func New(ctx context.Context, wg *sync.WaitGroup, defaults config.Config) (config config.Config, connectionlogip string, err error)

func NewPartial

func NewPartial(ctx context.Context, wg *sync.WaitGroup, defaults config.Config) (config config.Config, err error)

func PermissionsV2

func PermissionsV2(ctx context.Context, wg *sync.WaitGroup, mongoUrl string, kafkaUrl string) (hostPort string, ipAddress string, err error)

func Zookeeper

func Zookeeper(ctx context.Context, wg *sync.WaitGroup) (hostPort string, ipAddress string, err error)