service_manager

Documentation

Index

• type CanaryConfig
• type Paths
• type ServiceManager
  • func CreateManager() *ServiceManager
  • func (c *ServiceManager) StartCanary()
  • func (c *ServiceManager) StartKafkaZookeeperContainers()
  • func (c *ServiceManager) StopKafkaZookeeperContainers()

Types

type CanaryConfig

type CanaryConfig struct {
	ReconcileIntervalTime string
	TopicTestName         string
	KafkaBrokerAddress    string
}

Configurations of canary that is manipulated in e2e tests

type Paths

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

paths to services ( kafka zookeeper docker compose, and Canary application main method)

type ServiceManager

type ServiceManager struct {
	CanaryConfig
	Paths
}

Implementation of Service Manager

func CreateManager

func CreateManager() *ServiceManager

func (*ServiceManager) StartCanary

func (c *ServiceManager) StartCanary()

func (*ServiceManager) StartKafkaZookeeperContainers

func (c *ServiceManager) StartKafkaZookeeperContainers()

func (*ServiceManager) StopKafkaZookeeperContainers

func (c *ServiceManager) StopKafkaZookeeperContainers()