kafka

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)

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)