ensurer

Documentation

Index

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

Functions

func GetFlowSchemaRemoveCandidates

func GetFlowSchemaRemoveCandidates(lister flowcontrollisters.FlowSchemaLister, bootstrap []*flowcontrolv1beta3.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 []*flowcontrolv1beta3.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([]*flowcontrolv1beta3.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([]*flowcontrolv1beta3.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.