docker

Documentation

Index

• func Camunda(ctx context.Context, wg *sync.WaitGroup, pgIp string, pgPort string) (camundaUrl string, err error)
• func DeviceManager(ctx context.Context, wg *sync.WaitGroup, kafkaUrl string, deviceRepoUrl string, ...) (hostPort string, ipAddress string, err error)
• func DeviceManagerWithDependencies(basectx context.Context, wg *sync.WaitGroup) (managerUrl string, repoUrl string, permUrl string, err error)
• func DeviceManagerWithDependenciesAndKafka(basectx context.Context, wg *sync.WaitGroup) (kafkaUrl string, managerUrl string, repoUrl string, permUrl string, err error)
• func DeviceRepo(ctx context.Context, wg *sync.WaitGroup, kafkaUrl string, mongoUrl string, ...) (hostPort string, ipAddress string, err error)
• func DeviceRepoWithEnv(ctx context.Context, wg *sync.WaitGroup, kafkaUrl string, mongoUrl string, ...) (hostPort string, ipAddress string, err error)
• func DeviceSelection(ctx context.Context, wg *sync.WaitGroup, kafkaUrl string, deviceRepoUrl string) (hostPort string, ipAddress string, err error)
• func Kafka(ctx context.Context, wg *sync.WaitGroup, zookeeperUrl string) (kafkaUrl string, err error)
• func MgwProcessSyncClient(ctx context.Context, wg *sync.WaitGroup, ...) (err error)
• func MongoDB(ctx context.Context, wg *sync.WaitGroup) (hostport string, containerip string, err error)
• func Mqtt(ctx context.Context, wg *sync.WaitGroup) (hostPort string, ipAddress string, err error)
• func PermissionsV2(ctx context.Context, wg *sync.WaitGroup, mongoUrl string, kafkaUrl string) (hostPort string, ipAddress string, err error)
• func Postgres(ctx context.Context, wg *sync.WaitGroup, dbname string) (conStr string, ip string, port string, err error)
• func ProcessSync(ctx context.Context, wg *sync.WaitGroup, permUrl string, mqttBroker string, ...) (hostPort string, ipAddress string, err error)
• func Zookeeper(ctx context.Context, wg *sync.WaitGroup) (hostPort string, ipAddress string, err error)

Functions

func Camunda

func Camunda(ctx context.Context, wg *sync.WaitGroup, pgIp string, pgPort string) (camundaUrl string, err error)

func DeviceManager

func DeviceManager(ctx context.Context, wg *sync.WaitGroup, kafkaUrl string, deviceRepoUrl string, permUrl string) (hostPort string, ipAddress string, err error)

func DeviceManagerWithDependencies

func DeviceManagerWithDependencies(basectx context.Context, wg *sync.WaitGroup) (managerUrl string, repoUrl string, permUrl string, err error)

func DeviceManagerWithDependenciesAndKafka

func DeviceManagerWithDependenciesAndKafka(basectx context.Context, wg *sync.WaitGroup) (kafkaUrl string, managerUrl string, repoUrl string, permUrl string, err error)

func DeviceRepo

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

func DeviceRepoWithEnv

func DeviceRepoWithEnv(ctx context.Context, wg *sync.WaitGroup, kafkaUrl string, mongoUrl string, permv2Url string, env map[string]string) (hostPort string, ipAddress string, err error)

func DeviceSelection

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

func Kafka

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

func MgwProcessSyncClient

func MgwProcessSyncClient(ctx context.Context, wg *sync.WaitGroup, camundaDb, camundaUrl, mqttUrl, mqttClientId, networkId, deploymentMetadataStorage string) (err error)

func MongoDB

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

func Mqtt

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

func PermissionsV2

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

func Postgres

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

func ProcessSync

func ProcessSync(ctx context.Context, wg *sync.WaitGroup, permUrl string, mqttBroker string, mongoUrl string) (hostPort string, ipAddress string, err error)

func Zookeeper

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