docker

Documentation

Index

• Variables
• 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, searchUrl string, kafkaUrl 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 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)

Variables

var OpenSearch = docker.OpenSearch

var PermSearch = docker.PermissionSearch

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, permsearch string) (hostPort string, ipAddress string, err error)

func DeviceRepoWithDependencies

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