docker

Documentation

Index

• func Kafka(ctx context.Context, wg *sync.WaitGroup, zookeeperUrl string) (kafkaUrl string, err error)
• func Memcached(ctx context.Context, wg *sync.WaitGroup) (hostPort string, ipAddress string, err error)
• func Tableworker(ctx context.Context, wg *sync.WaitGroup, postgresHost string, postgresPort int, ...) (err error)
• func Timescale(ctx context.Context, wg *sync.WaitGroup) (host string, port int, user string, pw string, db string, err error)
• func Vernemqtt(ctx context.Context, wg *sync.WaitGroup, connecorUrl string, ...) (brokerUrlForConnector string, brokerUrlForClients string, err error)
• func Zookeeper(ctx context.Context, wg *sync.WaitGroup) (hostPort string, ipAddress string, err error)

Functions

func Kafka

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

func Memcached

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

func Tableworker

func Tableworker(ctx context.Context, wg *sync.WaitGroup, postgresHost string, postgresPort int, postgresUser string, postgresPw string, postgresDb string, kafkaBootstrap string, deviceManagerUrl string) (err error)

func Timescale

func Timescale(ctx context.Context, wg *sync.WaitGroup) (host string, port int, user string, pw string, db string, err error)

func Vernemqtt

func Vernemqtt(ctx context.Context, wg *sync.WaitGroup, connecorUrl string, config configuration.Config) (brokerUrlForConnector string, brokerUrlForClients string, err error)

func Zookeeper

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