docker

Documentation

Index

• Variables
• 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(ctx context.Context, container testcontainers.Container, name string) error
• func MongoDB(ctx context.Context, wg *sync.WaitGroup) (hostport string, containerip string, err error)
• func VernemqttErlio(ctx context.Context, wg *sync.WaitGroup) (brokerUrl string, apiUrl string, err error)
• type LogWriter
  • func (this *LogWriter) Write(p []byte) (n int, err error)

Variables

var Kafka = docker.Kafka

var OpenSearch = docker.OpenSearch

var PermSearch = docker.PermissionSearch

var Zookeeper = docker.Zookeeper

Functions

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(ctx context.Context, container testcontainers.Container, name string) error

func MongoDB

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

func VernemqttErlio

func VernemqttErlio(ctx context.Context, wg *sync.WaitGroup) (brokerUrl string, apiUrl string, err error)

Types

type LogWriter

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

func (*LogWriter) Write

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