Documentation
¶
Index ¶
Constants ¶
View Source
const ( NO_TASK = iota + 1 EXECUTION_STARTED REPLICA_MOVEMENT_IN_PROGRESS LEADER_MOVEMENT_IN_PROGRESS )
Variables ¶
This section is empty.
Functions ¶
func DownsizeCluster ¶
func DownsizeCluster(cluster spec.Kafkacluster, brokerToDelete string) error
func GetCruiseControlStatus ¶
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
}
Source Files
Click to show internal directories.
Click to hide internal directories.