Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventingScaleUpStatusProcessor ¶
type EventingScaleUpStatusProcessor struct{}
EventingScaleUpStatusProcessor processes the state of the cluster after a scale-up by emitting relevant events for pods depending on their post scale-up status.
func (*EventingScaleUpStatusProcessor) Process ¶
func (p *EventingScaleUpStatusProcessor) Process(context *context.AutoscalingContext, status *ScaleUpStatus)
Process processes the state of the cluster after a scale-up by emitting relevant events for pods depending on their post scale-up status.
type NoOpScaleUpStatusProcessor ¶
type NoOpScaleUpStatusProcessor struct{}
NoOpScaleUpStatusProcessor is a ScaleUpStatusProcessor implementations useful for testing.
func (*NoOpScaleUpStatusProcessor) Process ¶
func (p *NoOpScaleUpStatusProcessor) Process(context *context.AutoscalingContext, status *ScaleUpStatus)
Process processes the status of the cluster after a scale-up.
type ScaleUpStatus ¶
type ScaleUpStatus struct { ScaledUp bool ScaleUpInfos []nodegroupset.ScaleUpInfo PodsTriggeredScaleUp []*apiv1.Pod PodsRemainUnschedulable []*apiv1.Pod PodsAwaitEvaluation []*apiv1.Pod }
ScaleUpStatus is the status of a scale-up attempt. This includes information on if scale-up happened, description of scale-up operation performed and status of pods that took part in the scale-up evaluation.
type ScaleUpStatusProcessor ¶
type ScaleUpStatusProcessor interface {
Process(context *context.AutoscalingContext, status *ScaleUpStatus)
}
ScaleUpStatusProcessor processes the status of the cluster after a scale-up.
func NewDefaultScaleUpStatusProcessor ¶
func NewDefaultScaleUpStatusProcessor() ScaleUpStatusProcessor
NewDefaultScaleUpStatusProcessor creates a default instance of ScaleUpStatusProcessor.