Documentation
¶
Index ¶
- func ClusterHealthCheck(experimentsDetails *experimentTypes.ExperimentDetails, ...) error
- func CreateLivenessPod(experimentsDetails *experimentTypes.ExperimentDetails, KafkaTopicName string, ...) error
- func DisplayKafkaBroker(experimentsDetails *experimentTypes.ExperimentDetails)
- func LivenessCleanup(experimentsDetails *experimentTypes.ExperimentDetails, ...) error
- func LivenessStream(experimentsDetails *experimentTypes.ExperimentDetails, ...) (string, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ClusterHealthCheck ¶
func ClusterHealthCheck(experimentsDetails *experimentTypes.ExperimentDetails, clients clients.ClientSets) error
ClusterHealthCheck checks health of the kafka cluster
func CreateLivenessPod ¶
func CreateLivenessPod(experimentsDetails *experimentTypes.ExperimentDetails, KafkaTopicName string, clients clients.ClientSets) error
CreateLivenessPod creates the kafka liveness pod
func DisplayKafkaBroker ¶
func DisplayKafkaBroker(experimentsDetails *experimentTypes.ExperimentDetails)
DisplayKafkaBroker displays the kafka broker info
func LivenessCleanup ¶
func LivenessCleanup(experimentsDetails *experimentTypes.ExperimentDetails, clients clients.ClientSets) error
LivenessCleanup deletes the kafka liveness pod
func LivenessStream ¶
func LivenessStream(experimentsDetails *experimentTypes.ExperimentDetails, clients clients.ClientSets) (string, error)
LivenessStream generates kafka liveness pod, which continuously validate the liveness of kafka brokers and derive the kafka topic leader(candidate for the deletion)
Types ¶
This section is empty.
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.