Versions in this module Expand all Collapse all v0 v0.19.1 Dec 15, 2015 v0.19.0 Dec 10, 2015 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