Versions in this module Expand all Collapse all v1 v1.5.0 Feb 2, 2018 Changes in this version + type Container struct + Args []string + Config struct{ ... } + ID string + Image string + NetworkSettings struct{ ... } + func (c *Container) Kill() error + func (c *Container) RunningKafka() bool + func (c *Container) Start() error + func (c *Container) Stop() error + type KafkaCluster struct + func NewKafkaCluster(kafkaDockerDir string, size int) *KafkaCluster + func (cluster *KafkaCluster) ContainerKill(containerID string) error + func (cluster *KafkaCluster) ContainerStart(containerID string) error + func (cluster *KafkaCluster) ContainerStop(containerID string) error + func (cluster *KafkaCluster) Containers() ([]*Container, error) + func (cluster *KafkaCluster) KafkaAddrs() ([]string, error) + func (cluster *KafkaCluster) Start() error + func (cluster *KafkaCluster) Stop() error + type PortMapping struct + HostIP string + HostPort string Other modules containing this package github.com/Domoryonok/kafka/v2