docker

Documentation

Index

• Variables
• func Analytics(ctx context.Context, wg *sync.WaitGroup, conf config.Config) (err error)
• func DeviceRepo(ctx context.Context, wg *sync.WaitGroup, kafkaUrl string, mongoUrl string, ...) (hostPort string, ipAddress string, err error)
• func FlowParser(ctx context.Context, wg *sync.WaitGroup, flowRepoIp string) (hostPort string, ipAddress string, err error)
• func FlowRepo(ctx context.Context, wg *sync.WaitGroup, mongoIp string) (hostPort string, ipAddress string, err error)
• func Mongo(ctx context.Context, wg *sync.WaitGroup) (hostport string, containerip string, err error)
• func MongoDB(ctx context.Context, wg *sync.WaitGroup) (hostport string, containerip string, err error)
• func Mysql(ctx context.Context, wg *sync.WaitGroup) (hostPort string, ipAddress string, err error)
• func PermissionsV2(ctx context.Context, wg *sync.WaitGroup, mongoUrl string, kafkaUrl string) (hostPort string, ipAddress string, err error)

Variables

var Kafka = docker.Kafka

var Zookeeper = docker.Zookeeper

Functions

func Analytics

func Analytics(ctx context.Context, wg *sync.WaitGroup, conf 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 FlowParser

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

func FlowRepo

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

func Mongo

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

func MongoDB

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

func Mysql

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

func PermissionsV2

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