Documentation
¶
Index ¶
- func DownsizeCluster(brokerId, namespace, ccEndpoint, clusterName string) error
- func GetBrokerIDWithLeastPartition(namespace, ccEndpoint, clusterName string) (string, error)
- func RebalanceCluster(namespace, ccEndpoint, clusterName string) error
- func RunPreferedLeaderElectionInCluster(namespace, ccEndpoint, clusterName string) error
- func UpScaleCluster(brokerId, namespace, ccEndpoint, clusterName string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DownsizeCluster ¶
DownsizeCluster downscales Kafka cluster
func GetBrokerIDWithLeastPartition ¶
GetBrokerIDWithLeastPartition returns
func RebalanceCluster ¶
RebalanceCluster rebalances Kafka cluster using CC
func RunPreferedLeaderElectionInCluster ¶
RunPreferedLeaderElectionInCluster runs leader election in Kafka cluster using CC
func UpScaleCluster ¶
UpScaleCluster upscales Kafka cluster
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.