docker

Documentation

Index

• func CreateTestEnv(baseCtx context.Context, wg *sync.WaitGroup, startConfig config.Config) (config config.Config, err error)
• func DeviceRepo(ctx context.Context, wg *sync.WaitGroup, kafkaUrl string, mongoUrl string, ...) (hostPort string, ipAddress string, err error)
• func DeviceRepoWithDependencies(basectx context.Context, wg *sync.WaitGroup) (repoUrl string, permv2Url, kafkaUrl string, err error)
• func DeviceRepoWithEnv(ctx context.Context, wg *sync.WaitGroup, kafkaUrl string, mongoUrl string, ...) (hostPort string, ipAddress string, err error)
• func Dockerlog(container testcontainers.Container, name string) error
• func Forward(ctx context.Context, fromPort int, toAddr string) error
• func Kafka(ctx context.Context, wg *sync.WaitGroup, zookeeperUrl string) (kafkaUrl string, err error)
• func MongoDB(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 Zookeeper(ctx context.Context, wg *sync.WaitGroup) (hostPort string, ipAddress string, err error)
• type LogWriter
  • func (this *LogWriter) Accept(l testcontainers.Log)
  • func (this *LogWriter) Write(p []byte) (n int, err error)

Functions

func CreateTestEnv

func CreateTestEnv(baseCtx context.Context, wg *sync.WaitGroup, startConfig config.Config) (config config.Config, 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 DeviceRepoWithDependencies

func DeviceRepoWithDependencies(basectx context.Context, wg *sync.WaitGroup) (repoUrl string, permv2Url, kafkaUrl 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 Dockerlog

func Dockerlog(container testcontainers.Container, name string) error

func Forward

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

func Kafka

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

func MongoDB

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

func PermissionsV2

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

func Zookeeper

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

Types

type LogWriter

type LogWriter struct {
	// contains filtered or unexported fields
}

func (*LogWriter) Accept

func (this *LogWriter) Accept(l testcontainers.Log)

func (*LogWriter) Write

func (this *LogWriter) Write(p []byte) (n int, err error)