docker

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

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

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

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

func EventWorker(ctx context.Context, wg *sync.WaitGroup, deviceRepoUrl string, eventTriggerUrl string, kafkaUrl string, mongoUrl string) (err error)

func GetFreePort() (int, error)

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

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 Mongo(ctx context.Context, wg *sync.WaitGroup) (hostport string, containerip 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, err error)

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

func Retry(timeout time.Duration, f func() error) (err error)

func TaskWorker(ctx context.Context, wg *sync.WaitGroup, deviceRepoUrl string, kafkaUrl string, incidentApiUrl string, shardsDbUrl string, memcachedUrl string) (err error)

func Waitretry(timeout time.Duration, f func(ctx context.Context, target wait.StrategyTarget) error) func(ctx context.Context, target wait.StrategyTarget) error

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