controllertools

Documentation

Index

• func IsNonRetriable(err error) bool
• func NewNonRetriable(message string) error
• func NonRetriable(err error) error
• type ControllerRefManager
  • func NewControllerRefManager[T kubeinterfaces.ObjectInterface](ctx context.Context, controller metav1.Object, ...) *ControllerRefManager[T]
  • func (m *ControllerRefManager[T]) AdoptObject(obj T) error
  • func (m *ControllerRefManager[T]) ClaimObjects(objects []T) (map[string]T, error)
  • func (m *ControllerRefManager[T]) ReleaseObject(obj T) error
• type ControllerRefManagerControlFuncs
  • func (cf ControllerRefManagerControlFuncs) GetControllerUncached(ctx context.Context, namespace, name string) (metav1.Object, error)
  • func (cf ControllerRefManagerControlFuncs) PatchObject(ctx context.Context, namespace, name string, pt types.PatchType, data []byte, ...) error
• type ControllerRefManagerControlFuncsConverter
  • func (c ControllerRefManagerControlFuncsConverter[CT, T]) Convert() ControllerRefManagerControlFuncs
• type ControllerRefManagerControlInterface
• type NonRetriableError
• type Observer
  • func NewObserver(name string, eventsClient corev1client.EventInterface, ...) *Observer
  • func (o *Observer) AddCachesToSync(caches ...cache.InformerSynced)
  • func (o *Observer) AddHandler(obj interface{})
  • func (o *Observer) DeleteHandler(obj interface{})
  • func (o *Observer) Enqueue()
  • func (o *Observer) GetGenericHandlers() cache.ResourceEventHandlerFuncs
  • func (o *Observer) Name() string
  • func (o *Observer) Run(ctx context.Context)
  • func (o *Observer) UpdateHandler(old, new interface{})
• type ObserverSyncFunc

Functions

func IsNonRetriable

func IsNonRetriable(err error) bool

func NewNonRetriable

func NewNonRetriable(message string) error

func NonRetriable

func NonRetriable(err error) error

Types

type ControllerRefManager

type ControllerRefManager[T kubeinterfaces.ObjectInterface] struct {
	kubecontroller.BaseControllerRefManager

	Control ControllerRefManagerControlInterface
	// contains filtered or unexported fields
}

func NewControllerRefManager

func NewControllerRefManager[T kubeinterfaces.ObjectInterface](
	ctx context.Context,
	controller metav1.Object,
	controllerGVK schema.GroupVersionKind,
	selector labels.Selector,
	control ControllerRefManagerControlInterface,
) *ControllerRefManager[T]

func (*ControllerRefManager[T]) AdoptObject

func (m *ControllerRefManager[T]) AdoptObject(obj T) error

func (*ControllerRefManager[T]) ClaimObjects

func (m *ControllerRefManager[T]) ClaimObjects(objects []T) (map[string]T, error)

func (*ControllerRefManager[T]) ReleaseObject

func (m *ControllerRefManager[T]) ReleaseObject(obj T) error

type ControllerRefManagerControlFuncs

type ControllerRefManagerControlFuncs struct {
	PatchObjectFunc           func(ctx context.Context, namespace string, name string, pt types.PatchType, data []byte, options metav1.PatchOptions) error
	GetControllerUncachedFunc func(ctx context.Context, namespace, name string) (metav1.Object, error)
}

func (ControllerRefManagerControlFuncs) GetControllerUncached

func (cf ControllerRefManagerControlFuncs) GetControllerUncached(ctx context.Context, namespace, name string) (metav1.Object, error)

func (ControllerRefManagerControlFuncs) PatchObject

func (cf ControllerRefManagerControlFuncs) PatchObject(ctx context.Context, namespace, name string, pt types.PatchType, data []byte, options metav1.PatchOptions) error

type ControllerRefManagerControlFuncsConverter

type ControllerRefManagerControlFuncsConverter[CT, T kubeinterfaces.ObjectInterface] struct {
	GetControllerUncachedFunc func(ctx context.Context, name string, opts metav1.GetOptions) (CT, error)
	PatchObjectFunc           func(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (T, error)
}

func (ControllerRefManagerControlFuncsConverter[CT, T]) Convert

func (c ControllerRefManagerControlFuncsConverter[CT, T]) Convert() ControllerRefManagerControlFuncs

type ControllerRefManagerControlInterface

type ControllerRefManagerControlInterface interface {
	PatchObject(ctx context.Context, namespace, name string, pt types.PatchType, data []byte, options metav1.PatchOptions) error
	GetControllerUncached(ctx context.Context, namespace, name string) (metav1.Object, error)
}

type NonRetriableError

type NonRetriableError struct {
	// contains filtered or unexported fields
}

type Observer

type Observer struct {
	// contains filtered or unexported fields
}

func NewObserver

func NewObserver(name string, eventsClient corev1client.EventInterface, syncFunc ObserverSyncFunc) *Observer

func (*Observer) AddCachesToSync

func (o *Observer) AddCachesToSync(caches ...cache.InformerSynced)

func (*Observer) AddHandler

func (o *Observer) AddHandler(obj interface{})

func (*Observer) DeleteHandler

func (o *Observer) DeleteHandler(obj interface{})

func (*Observer) Enqueue

func (o *Observer) Enqueue()

func (*Observer) GetGenericHandlers

func (o *Observer) GetGenericHandlers() cache.ResourceEventHandlerFuncs

func (*Observer) Name

func (o *Observer) Name() string

func (*Observer) Run

func (o *Observer) Run(ctx context.Context)

func (*Observer) UpdateHandler

func (o *Observer) UpdateHandler(old, new interface{})

type ObserverSyncFunc

type ObserverSyncFunc = func(ctx context.Context) error