scale

Documentation

Index

• func MockNewCruiseControlScaler()
• type CruiseControlScaler
  • func NewCruiseControlScaler(namespace, kubernetesClusterDomain, endpoint, clusterName string) CruiseControlScaler

Functions

func MockNewCruiseControlScaler

func MockNewCruiseControlScaler()

Types

type CruiseControlScaler

type CruiseControlScaler interface {
	GetLiveKafkaBrokersFromCruiseControl(brokerIDs []string) ([]string, error)
	GetBrokerIDWithLeastPartition() (string, error)
	UpScaleCluster(brokerIDs []string) (string, string, error)
	DownsizeCluster(brokerIDs []string) (string, string, error)
	RebalanceDisks(brokerIDsWithMountPath map[string][]string) (string, string, error)
	RebalanceCluster() (string, error)
	RunPreferedLeaderElectionInCluster() (string, error)
	KillCCTask() error
	GetCCTaskState(uTaskID string) (banzaicloudv1beta1.CruiseControlUserTaskState, error)
}

func NewCruiseControlScaler

func NewCruiseControlScaler(namespace, kubernetesClusterDomain, endpoint, clusterName string) CruiseControlScaler