cruisecontrol

Documentation

Index

• Constants
• func DownsizeCluster(cluster spec.Kafkacluster, brokerToDelete string) error
• func GetCruiseControlStatus(url string) (string, error)
• type CruiseControlExecuterState
• type CruiseControlMonitorState
• type CruiseControlState

Constants

const (
	NO_TASK = iota + 1
	EXECUTION_STARTED
	REPLICA_MOVEMENT_IN_PROGRESS
	LEADER_MOVEMENT_IN_PROGRESS
)

Functions

func DownsizeCluster

func DownsizeCluster(cluster spec.Kafkacluster, brokerToDelete string) error

func GetCruiseControlStatus

func GetCruiseControlStatus(url string) (string, error)

Types

type CruiseControlExecuterState

type CruiseControlExecuterState int32

type CruiseControlMonitorState

type CruiseControlMonitorState int32

type CruiseControlState

type CruiseControlState struct {
	MonitorState      CruiseControlMonitorState
	ExecuterState     CruiseControlExecuterState
	ReplicasToMove    int
	FinshedReplicas   int
	BootstrapProgress int
	ValidPartitions   int
	TotalPartitions   int
	ProposalReady     bool
}