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 Postgres(ctx context.Context, wg *sync.WaitGroup, dbname string) (conStr string, err error)
• func PostgresWithNetwork(ctx context.Context, wg *sync.WaitGroup, dbname string) (conStr string, containerIp string, hostPort 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, certAuth bool, ...) (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 Postgres

func Postgres(ctx context.Context, wg *sync.WaitGroup, dbname string) (conStr string, err error)

func PostgresWithNetwork

func PostgresWithNetwork(ctx context.Context, wg *sync.WaitGroup, dbname string) (conStr string, containerIp string, hostPort 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, certAuth bool, mqttVersion string) (brokerUrlForConnector string, brokerUrlForClients string, err error)

func Zookeeper

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