controller

Documentation

Index

• func CommonOptions(maxConcurrentReconciles int) controller.Options
• func GetShardRequirement(shard string, isDefaultController bool) (*labels.Requirement, error)
• type ResponsibleFor
  • func (i ResponsibleFor[T]) Create(e event.TypedCreateEvent[T]) bool
  • func (i ResponsibleFor[T]) Delete(e event.TypedDeleteEvent[T]) bool
  • func (i ResponsibleFor[T]) Generic(e event.TypedGenericEvent[T]) bool
  • func (i ResponsibleFor[T]) IsResponsible(obj client.Object) bool
  • func (i ResponsibleFor[T]) Update(e event.TypedUpdateEvent[T]) bool

Functions

func CommonOptions

func CommonOptions(maxConcurrentReconciles int) controller.Options

func GetShardRequirement

func GetShardRequirement(
	shard string,
	isDefaultController bool,
) (*labels.Requirement, error)

GetShardRequirement considers the provided shard name and boolean indicating whether this controller is the default controller and attempts to distill this information down to a labels.Requirement. In cases where it is unable to do so, it will return a nil labels.Requirement.

Types

type ResponsibleFor

type ResponsibleFor[T any] struct {
	IsDefaultController bool
	ShardName           string
}

ResponsibleFor is an implementation of predicate.Predicate used by reconcilers to narrow the set of client.Objects they watch according to how they are labeled.

func (ResponsibleFor[T]) Create

func (i ResponsibleFor[T]) Create(e event.TypedCreateEvent[T]) bool

Create implements predicate.Predicate.

func (ResponsibleFor[T]) Delete

func (i ResponsibleFor[T]) Delete(e event.TypedDeleteEvent[T]) bool

Delete implements predicate.Predicate.

func (ResponsibleFor[T]) Generic

func (i ResponsibleFor[T]) Generic(e event.TypedGenericEvent[T]) bool

Generic implements predicate.Predicate.

func (ResponsibleFor[T]) IsResponsible

func (i ResponsibleFor[T]) IsResponsible(obj client.Object) bool

func (ResponsibleFor[T]) Update

func (i ResponsibleFor[T]) Update(e event.TypedUpdateEvent[T]) bool

Update implements predicate.Predicate.