scale

Documentation

Index

• Constants
• func CruiseControlURL(namespace, domain, endpoint, name string) string
• func CruiseControlURLFromKafkaCluster(instance *v1beta1.KafkaCluster) string
• func MockNewCruiseControlScaler()
• type CruiseControlScaler
  • func NewCruiseControlScaler(ctx context.Context, serverURL string) (CruiseControlScaler, error)
• type CruiseControlStatus
  • func (s CruiseControlStatus) InExecution() bool
  • func (s CruiseControlStatus) IsReady() bool
• type KafkaBrokerState
• type LogDirState
• type Result

Constants

const (
	KafkaBrokerAlive    = types.BrokerStateAlive
	KafkaBrokerDead     = types.BrokerStateDead
	KafkaBrokerNew      = types.BrokerStateNew
	KafkaBrokerDemoted  = types.BrokerStateDemoted
	KafkaBrokerBadDisks = types.BrokerStateBadDisks
)

Functions

func CruiseControlURL

func CruiseControlURL(namespace, domain, endpoint, name string) string

func CruiseControlURLFromKafkaCluster

func CruiseControlURLFromKafkaCluster(instance *v1beta1.KafkaCluster) string

func MockNewCruiseControlScaler

func MockNewCruiseControlScaler()

Types

type CruiseControlScaler

type CruiseControlScaler interface {
	IsReady() bool
	Status() CruiseControlStatus
	GetUserTasks(taskIDs ...string) ([]*Result, error)
	IsUp() bool
	AddBrokers(brokerIDs ...string) (*Result, error)
	RemoveBrokers(brokerIDs ...string) (*Result, error)
	RebalanceDisks(brokerIDs ...string) (*Result, error)
	BrokersWithState(states ...KafkaBrokerState) ([]string, error)
	PartitionReplicasByBroker() (map[string]int32, error)
	BrokerWithLeastPartitionReplicas() (string, error)
	LogDirsByBroker() (map[string]map[LogDirState][]string, error)
}

func NewCruiseControlScaler

func NewCruiseControlScaler(ctx context.Context, serverURL string) (CruiseControlScaler, error)

type CruiseControlStatus

type CruiseControlStatus struct {
	MonitorReady  bool
	ExecutorReady bool
	AnalyzerReady bool
	ProposalReady bool
	GoalsReady    bool

	MonitoredWindows   float32
	MonitoringCoverage float64
}

CruiseControlStatus struct is used to describe internal state of Cruise Control.

func (CruiseControlStatus) InExecution

func (s CruiseControlStatus) InExecution() bool

InExecution returns true if the Executor component of Cruise Control is performing an operation which means that new operations cannot be started until the current has finished or the forced to be terminated.

func (CruiseControlStatus) IsReady

func (s CruiseControlStatus) IsReady() bool

IsReady returns true if the Analyzer and Monitor components of Cruise Control are in ready state.

type KafkaBrokerState

type KafkaBrokerState = types.BrokerState

type LogDirState

type LogDirState int8

const (
	LogDirStateOnline LogDirState = iota
	LogDirStateOffline
)

type Result

type Result struct {
	TaskID    string
	StartedAt string
	State     v1beta1.CruiseControlUserTaskState
	Err       string
}