package ensurer

import "k8s.io/kubernetes/pkg/registry/flowcontrol/ensurer"

Index ¶

• func GetFlowSchemaRemoveCandidates(lister flowcontrollisters.FlowSchemaLister, bootstrap []*flowcontrolv1beta2.FlowSchema) ([]string, error)
• func GetPriorityLevelRemoveCandidates(lister flowcontrollisters.PriorityLevelConfigurationLister, bootstrap []*flowcontrolv1beta2.PriorityLevelConfiguration) ([]string, error)
• type FlowSchemaEnsurer
• func NewMandatoryFlowSchemaEnsurer(client flowcontrolclient.FlowSchemaInterface, lister flowcontrollisters.FlowSchemaLister) FlowSchemaEnsurer
• func NewSuggestedFlowSchemaEnsurer(client flowcontrolclient.FlowSchemaInterface, lister flowcontrollisters.FlowSchemaLister) FlowSchemaEnsurer
• type FlowSchemaRemover
• func NewFlowSchemaRemover(client flowcontrolclient.FlowSchemaInterface, lister flowcontrollisters.FlowSchemaLister) FlowSchemaRemover
• type PriorityLevelEnsurer
• func NewMandatoryPriorityLevelEnsurer(client flowcontrolclient.PriorityLevelConfigurationInterface, lister flowcontrollisters.PriorityLevelConfigurationLister) PriorityLevelEnsurer
• func NewSuggestedPriorityLevelEnsurerEnsurer(client flowcontrolclient.PriorityLevelConfigurationInterface, lister flowcontrollisters.PriorityLevelConfigurationLister) PriorityLevelEnsurer
• type PriorityLevelRemover
• func NewPriorityLevelRemover(client flowcontrolclient.PriorityLevelConfigurationInterface, lister flowcontrollisters.PriorityLevelConfigurationLister) PriorityLevelRemover

Functions ¶

func GetFlowSchemaRemoveCandidates ¶

func GetFlowSchemaRemoveCandidates(lister flowcontrollisters.FlowSchemaLister, bootstrap []*flowcontrolv1beta2.FlowSchema) ([]string, error)

GetFlowSchemaRemoveCandidates returns a list of FlowSchema object names that are candidates for deletion from the cluster. bootstrap: a set of hard coded FlowSchema configuration objects kube-apiserver maintains in-memory.

func GetPriorityLevelRemoveCandidates ¶

func GetPriorityLevelRemoveCandidates(lister flowcontrollisters.PriorityLevelConfigurationLister, bootstrap []*flowcontrolv1beta2.PriorityLevelConfiguration) ([]string, error)

GetPriorityLevelRemoveCandidates returns a list of PriorityLevelConfiguration names that are candidates for removal from the cluster. bootstrap: a set of hard coded PriorityLevelConfiguration configuration objects kube-apiserver maintains in-memory.

Types ¶

type FlowSchemaEnsurer ¶

type FlowSchemaEnsurer interface {
	Ensure([]*flowcontrolv1beta2.FlowSchema) error
}

FlowSchemaEnsurer ensures the specified bootstrap configuration objects

func NewMandatoryFlowSchemaEnsurer ¶

func NewMandatoryFlowSchemaEnsurer(client flowcontrolclient.FlowSchemaInterface, lister flowcontrollisters.FlowSchemaLister) FlowSchemaEnsurer

NewMandatoryFlowSchemaEnsurer returns a FlowSchemaEnsurer instance that can be used to ensure a set of mandatory FlowSchema configuration objects.

func NewSuggestedFlowSchemaEnsurer ¶

func NewSuggestedFlowSchemaEnsurer(client flowcontrolclient.FlowSchemaInterface, lister flowcontrollisters.FlowSchemaLister) FlowSchemaEnsurer

NewSuggestedFlowSchemaEnsurer returns a FlowSchemaEnsurer instance that can be used to ensure a set of suggested FlowSchema configuration objects.

type FlowSchemaRemover ¶

type FlowSchemaRemover interface {
	RemoveAutoUpdateEnabledObjects([]string) error
}

FlowSchemaRemover is the interface that wraps the RemoveAutoUpdateEnabledObjects method.

RemoveAutoUpdateEnabledObjects removes a set of bootstrap FlowSchema objects specified via their names. The function removes an object only if automatic update of the spec is enabled for it.

func NewFlowSchemaRemover ¶

func NewFlowSchemaRemover(client flowcontrolclient.FlowSchemaInterface, lister flowcontrollisters.FlowSchemaLister) FlowSchemaRemover

NewFlowSchemaRemover returns a FlowSchemaRemover instance that can be used to remove a set of FlowSchema configuration objects.

type PriorityLevelEnsurer ¶

type PriorityLevelEnsurer interface {
	Ensure([]*flowcontrolv1beta2.PriorityLevelConfiguration) error
}

PriorityLevelEnsurer ensures the specified bootstrap configuration objects

func NewMandatoryPriorityLevelEnsurer ¶

func NewMandatoryPriorityLevelEnsurer(client flowcontrolclient.PriorityLevelConfigurationInterface, lister flowcontrollisters.PriorityLevelConfigurationLister) PriorityLevelEnsurer

NewMandatoryPriorityLevelEnsurer returns a PriorityLevelEnsurer instance that can be used to ensure a set of mandatory PriorityLevelConfiguration configuration objects.

func NewSuggestedPriorityLevelEnsurerEnsurer ¶

func NewSuggestedPriorityLevelEnsurerEnsurer(client flowcontrolclient.PriorityLevelConfigurationInterface, lister flowcontrollisters.PriorityLevelConfigurationLister) PriorityLevelEnsurer

NewSuggestedPriorityLevelEnsurerEnsurer returns a PriorityLevelEnsurer instance that can be used to ensure a set of suggested PriorityLevelConfiguration configuration objects.

type PriorityLevelRemover ¶

type PriorityLevelRemover interface {
	RemoveAutoUpdateEnabledObjects([]string) error
}

PriorityLevelRemover is the interface that wraps the RemoveAutoUpdateEnabledObjects method.

RemoveAutoUpdateEnabledObjects removes a set of bootstrap PriorityLevelConfiguration objects specified via their names. The function removes an object only if automatic update of the spec is enabled for it.

func NewPriorityLevelRemover ¶

func NewPriorityLevelRemover(client flowcontrolclient.PriorityLevelConfigurationInterface, lister flowcontrollisters.PriorityLevelConfigurationLister) PriorityLevelRemover

NewPriorityLevelRemover returns a PriorityLevelRemover instance that can be used to remove a set of PriorityLevelConfiguration configuration objects.

Source Files ¶

flowschema.go prioritylevelconfiguration.go strategy.go