integration

README

integration

Integration with kafka & zoopeeker test helpers.

KafkaCluster depends on docker and docker-compose commands.

IMPORTANT: Make sure to update KAFKA_ADVERTISED_HOST_NAME in kafka-docker/docker-compose.yml before running tests.

kafka-docker

kafka-docker directory is copy of wurstmeister/kafka-docker repository.

Documentation

Index

• type Container
  • func (c *Container) Kill() error
  • func (c *Container) RunningKafka() bool
  • func (c *Container) Start() error
  • func (c *Container) Stop() error
• type KafkaCluster
  • func NewKafkaCluster(kafkaDockerDir string, size int) *KafkaCluster
  • func (cluster *KafkaCluster) ContainerKill(containerID string) error
  • func (cluster *KafkaCluster) ContainerNetworkIP(container Container, network string) (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
  • func (cluster *KafkaCluster) WaitUntilReady() error

Types

type Container

type Container struct {
	*docker.Container
	// contains filtered or unexported fields
}

func (*Container) Kill

func (c *Container) Kill() error

func (*Container) RunningKafka

func (c *Container) RunningKafka() bool

RunningKafka returns true if container is running kafka node

func (*Container) Start

func (c *Container) Start() error

Start starts current container

func (*Container) Stop

func (c *Container) Stop() error

Stop stops current container

type KafkaCluster

type KafkaCluster struct {
	// contains filtered or unexported fields
}

func NewKafkaCluster

func NewKafkaCluster(kafkaDockerDir string, size int) *KafkaCluster

func (*KafkaCluster) ContainerKill

func (cluster *KafkaCluster) ContainerKill(containerID string) error

func (*KafkaCluster) ContainerNetworkIP

func (cluster *KafkaCluster) ContainerNetworkIP(container Container, network string) (string, error)

func (*KafkaCluster) ContainerStart

func (cluster *KafkaCluster) ContainerStart(containerID string) error

func (*KafkaCluster) ContainerStop

func (cluster *KafkaCluster) ContainerStop(containerID string) error

func (*KafkaCluster) Containers

func (cluster *KafkaCluster) Containers() ([]*Container, error)

Containers inspect all containers running within cluster and return information about them.

func (*KafkaCluster) KafkaAddrs

func (cluster *KafkaCluster) KafkaAddrs() ([]string, error)

KafkaAddrs return list of kafka node addresses as strings, in form <host>:<port>

func (*KafkaCluster) Start

func (cluster *KafkaCluster) Start() error

Start start zookeeper and kafka nodes using docker-compose command. Upon successful process spawn, cluster is scaled to required amount of nodes.

func (*KafkaCluster) Stop

func (cluster *KafkaCluster) Stop() error

Stop stop all services running for the cluster by sending SIGINT to docker-compose process.

func (*KafkaCluster) WaitUntilReady

func (cluster *KafkaCluster) WaitUntilReady() error