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 Forward(ctx context.Context, fromPort int, toAddr 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 Forward

func Forward(ctx context.Context, fromPort int, toAddr 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)