Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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()
Source Files
Click to show internal directories.
Click to hide internal directories.