Documentation ¶
Index ¶
- func Camunda(ctx context.Context, wg *sync.WaitGroup, pgIp string, pgPort string) (camundaUrl string, err error)
- func GetFreePort() (int, error)
- func GetFreePortStr() (string, error)
- func Mongo(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 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, mqttUrl string, camundaUrl string) (err error)
- func Waitretry(timeout time.Duration, ...) func(ctx context.Context, target wait.StrategyTarget) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetFreePort ¶ added in v1.0.19
func GetFreePortStr ¶ added in v1.0.19
func PostgresWithNetwork ¶
func TaskWorker ¶ added in v1.0.18
Types ¶
This section is empty.
Source Files ¶
Click to show internal directories.
Click to hide internal directories.