docker

Documentation

Index

• Variables
• func DeviceManager(ctx context.Context, wg *sync.WaitGroup, kafkaUrl string, deviceRepoUrl string, ...) (hostPort string, ipAddress string, err error)
• func DeviceManagerWithDependencies(basectx context.Context, wg *sync.WaitGroup) (managerUrl string, repoUrl string, searchUrl string, err error)
• func DeviceManagerWithDependenciesAndKafka(basectx context.Context, wg *sync.WaitGroup) (kafkaUrl string, managerUrl string, repoUrl string, searchUrl string, ...)
• func DeviceRepo(ctx context.Context, wg *sync.WaitGroup, kafkaUrl string, mongoUrl string, ...) (hostPort string, ipAddress string, err error)
• func ImportRepo(ctx context.Context, wg *sync.WaitGroup, kafkaUrl string, mongoUrl string, ...) (hostPort string, ipAddress string, err error)
• func MongoDB(ctx context.Context, wg *sync.WaitGroup) (hostport string, containerip string, err error)

Variables

var Kafka = docker.Kafka

var OpenSearch = docker.OpenSearch

var PermSearch = docker.PermissionSearch

var Zookeeper = docker.Zookeeper

Functions

func DeviceManager

func DeviceManager(ctx context.Context, wg *sync.WaitGroup, kafkaUrl string, deviceRepoUrl string, permsearch string) (hostPort string, ipAddress string, err error)

func DeviceManagerWithDependencies

func DeviceManagerWithDependencies(basectx context.Context, wg *sync.WaitGroup) (managerUrl string, repoUrl string, searchUrl string, err error)

func DeviceManagerWithDependenciesAndKafka

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

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

func MongoDB

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