scale

Documentation

Index

• type CruiseControlScaler
  • func NewCruiseControlScaler(namespace, kubernetesClusterDomain, endpoint, clusterName string) CruiseControlScaler
  • func (cc *CruiseControlScaler) DownsizeCluster(brokerIds []string) (string, string, error)
  • func (cc *CruiseControlScaler) GetBrokerIDWithLeastPartition() (string, error)
  • func (cc *CruiseControlScaler) GetCCTaskState(uTaskId string) (banzaicloudv1beta1.CruiseControlUserTaskState, error)
  • func (cc *CruiseControlScaler) GetLiveKafkaBrokersFromCruiseControl(brokerIds []string) ([]string, error)
  • func (cc *CruiseControlScaler) KillCCTask() error
  • func (cc *CruiseControlScaler) RebalanceCluster() (string, error)
  • func (cc *CruiseControlScaler) RebalanceDisks(brokerIdsWithMountPath map[string][]string) (string, string, error)
  • func (cc *CruiseControlScaler) RunPreferedLeaderElectionInCluster() (string, error)
  • func (cc *CruiseControlScaler) UpScaleCluster(brokerIds []string) (string, string, error)

Types

type CruiseControlScaler

type CruiseControlScaler struct {
	// contains filtered or unexported fields
}

func NewCruiseControlScaler

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

func (*CruiseControlScaler) DownsizeCluster

func (cc *CruiseControlScaler) DownsizeCluster(brokerIds []string) (string, string, error)

DownsizeCluster downscales Kafka cluster

func (*CruiseControlScaler) GetBrokerIDWithLeastPartition

func (cc *CruiseControlScaler) GetBrokerIDWithLeastPartition() (string, error)

GetBrokerIDWithLeastPartition returns

func (*CruiseControlScaler) GetCCTaskState

func (cc *CruiseControlScaler) GetCCTaskState(uTaskId string) (banzaicloudv1beta1.CruiseControlUserTaskState, error)

GetCCTaskState checks whether the given CC Task ID finished or not

func (*CruiseControlScaler) GetLiveKafkaBrokersFromCruiseControl

func (cc *CruiseControlScaler) GetLiveKafkaBrokersFromCruiseControl(brokerIds []string) ([]string, error)

Get brokers status from CC from a provided list of broker ids

func (*CruiseControlScaler) KillCCTask

func (cc *CruiseControlScaler) KillCCTask() error

KillCCTask kills the specified CC task

func (*CruiseControlScaler) RebalanceCluster

func (cc *CruiseControlScaler) RebalanceCluster() (string, error)

RebalanceCluster rebalances Kafka cluster using CC

func (*CruiseControlScaler) RebalanceDisks

func (cc *CruiseControlScaler) RebalanceDisks(brokerIdsWithMountPath map[string][]string) (string, string, error)

RebalanceDisks rebalances Kafka broker replicas between disks using CC

func (*CruiseControlScaler) RunPreferedLeaderElectionInCluster

func (cc *CruiseControlScaler) RunPreferedLeaderElectionInCluster() (string, error)

RunPreferedLeaderElectionInCluster runs leader election in Kafka cluster using CC

func (*CruiseControlScaler) UpScaleCluster

func (cc *CruiseControlScaler) UpScaleCluster(brokerIds []string) (string, string, error)

UpScaleCluster upscales Kafka cluster