pods

Documentation

Index

• type CombinedPodListProcessor
  • func NewCombinedPodListProcessor(processors []PodListProcessor) *CombinedPodListProcessor
  • func (p *CombinedPodListProcessor) AddProcessor(processor PodListProcessor)
  • func (p *CombinedPodListProcessor) CleanUp()
  • func (p *CombinedPodListProcessor) Process(ctx *context.AutoscalingContext, unschedulablePods []*apiv1.Pod) ([]*apiv1.Pod, error)
• type NoOpPodListProcessor
  • func (p *NoOpPodListProcessor) CleanUp()
  • func (p *NoOpPodListProcessor) Process(context *context.AutoscalingContext, unschedulablePods []*apiv1.Pod) ([]*apiv1.Pod, error)
• type PodListProcessor
  • func NewDefaultPodListProcessor() PodListProcessor

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.