scale

Documentation

Index

• Constants
• func CruiseControlURL(namespace, domain, endpoint, name string) string
• func CruiseControlURLFromKafkaCluster(instance *v1beta1.KafkaCluster) string
• func ScaleFactoryFn() ...
• 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
• type StatusTaskResult

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 ScaleFactoryFn

func ScaleFactoryFn() func(ctx context.Context, kafkaCluster *v1beta1.KafkaCluster) (CruiseControlScaler, error)

Types

type CruiseControlScaler

type CruiseControlScaler interface {
	IsReady(ctx context.Context) bool
	Status(ctx context.Context) (StatusTaskResult, error)
	StatusTask(ctx context.Context, taskId string) (StatusTaskResult, error)
	UserTasks(ctx context.Context, taskIDs ...string) ([]*Result, error)
	IsUp(ctx context.Context) bool
	AddBrokers(ctx context.Context, brokerIDs ...string) (*Result, error)
	AddBrokersWithParams(ctx context.Context, params map[string]string) (*Result, error)
	RemoveBrokersWithParams(ctx context.Context, params map[string]string) (*Result, error)
	RebalanceWithParams(ctx context.Context, params map[string]string) (*Result, error)
	StopExecution(ctx context.Context) (*Result, error)
	RemoveBrokers(ctx context.Context, brokerIDs ...string) (*Result, error)
	RebalanceDisks(ctx context.Context, brokerIDs ...string) (*Result, error)
	BrokersWithState(ctx context.Context, states ...KafkaBrokerState) ([]string, error)
	KafkaClusterState(ctx context.Context) (*types.KafkaClusterState, error)
	PartitionReplicasByBroker(ctx context.Context) (map[string]int32, error)
	BrokerWithLeastPartitionReplicas(ctx context.Context) (string, error)
	LogDirsByBroker(ctx context.Context) (map[string]map[LogDirState][]string, error)
	KafkaClusterLoad(ctx context.Context) (*api.KafkaClusterLoadResponse, 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
	ResponseStatusCode int
	RequestURL         string
	Result             *types.OptimizationResult
	State              v1beta1.CruiseControlUserTaskState
	Err                error
}

type StatusTaskResult

type StatusTaskResult struct {
	TaskResult *Result
	Status     *CruiseControlStatus
}