docker

func AnalyticsFlowEngine(ctx context.Context, wg *sync.WaitGroup, pipelineApiUrl string, parserUrl string, rancherUrl string, mqttUrl string, permUrl string) (hostPort string, ipAddress string, err error)

func AnalyticsFlowRepo(ctx context.Context, wg *sync.WaitGroup, mongoIp string, operatorRepoUrl string, permUrl string, piplelineRegUrl string) (hostPort string, ipAddress string, err error)

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

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

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

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

func DatabaseExports(ctx context.Context, wg *sync.WaitGroup, mysqlHost string, rancherUrl string, permSearchUrl string, influxDbHost string, kafkaUrl string, importDeployUrl string, pipelineApiUrl string) (hostPort string, ipAddress string, err error)

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

func GetFreePort() (string, error)

func GetHostIp() (string, error)

func Imports(ctx context.Context, wg *sync.WaitGroup, mongoUrl string, importRepoUrl string, permissionsUrl string, kafkaUrl string, rancherUrl string, permV2Url string) (hostPort string, ipAddress string, err error)

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

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

func LocalUrlToDockerUrl(localUrl string) (dockerUrl string, err error)

func MongoContainer(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 MysqlContainer(ctx context.Context, wg *sync.WaitGroup) (hostPort string, ipAddress string, err error)

func NotificationContainer(ctx context.Context, wg *sync.WaitGroup, mongoIp string, vaultUrl string, keycloakUrl string) (hostPort string, ipAddress string, err error)

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

func PrintDockerLogs(c testcontainers.Container, name string)

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

func Start(basectx context.Context, wg *sync.WaitGroup, origConfig configuration.Config) (config configuration.Config, getDeviceRepoCalls func() []string, err error)

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