Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CombinedPodListProcessor ¶
type CombinedPodListProcessor struct {
// contains filtered or unexported fields
}
CombinedPodListProcessor is a list of PodListProcessors
func NewCombinedPodListProcessor ¶
func NewCombinedPodListProcessor(processors []PodListProcessor) *CombinedPodListProcessor
NewCombinedPodListProcessor construct CombinedPodListProcessor.
func (*CombinedPodListProcessor) AddProcessor ¶
func (p *CombinedPodListProcessor) AddProcessor(processor PodListProcessor)
AddProcessor append processor to the list.
func (*CombinedPodListProcessor) CleanUp ¶
func (p *CombinedPodListProcessor) CleanUp()
CleanUp cleans up the processor's internal structures.
func (*CombinedPodListProcessor) Process ¶
func (p *CombinedPodListProcessor) Process(ctx *context.AutoscalingContext, unschedulablePods []*apiv1.Pod) ([]*apiv1.Pod, error)
Process runs sub-processors sequentially
type NoOpPodListProcessor ¶
type NoOpPodListProcessor struct {
}
NoOpPodListProcessor is returning pod lists without processing them.
func (*NoOpPodListProcessor) CleanUp ¶
func (p *NoOpPodListProcessor) CleanUp()
CleanUp cleans up the processor's internal structures.
func (*NoOpPodListProcessor) Process ¶
func (p *NoOpPodListProcessor) Process( context *context.AutoscalingContext, unschedulablePods []*apiv1.Pod) ([]*apiv1.Pod, error)
Process processes lists of unschedulable and scheduled pods before scaling of the cluster.
type PodListProcessor ¶
type PodListProcessor interface {
Process(
context *context.AutoscalingContext,
unschedulablePods []*apiv1.Pod) ([]*apiv1.Pod, error)
CleanUp()
}
PodListProcessor processes lists of unschedulable pods.
func NewDefaultPodListProcessor ¶
func NewDefaultPodListProcessor() PodListProcessor
NewDefaultPodListProcessor creates an instance of PodListProcessor.
Source Files
Click to show internal directories.
Click to hide internal directories.