controllerbase

Documentation

Index

• func RemoveFinalizer(metaObj *metav1.ObjectMeta, finalizer string)
• func ShouldRetry(err error) bool
• func WithReconciliationId(ctx context.Context) zap.Field
• func WrapRetryError(err error) error
• type Controller
  • func NewController(base ControllerBase, coreClient kubernetes.Interface) *Controller
  • func (c *Controller) EventRecorder() record.EventRecorder
  • func (c *Controller) Log(ctx context.Context) *zap.Logger
  • func (c *Controller) OnAdd(obj interface{})
  • func (c *Controller) OnDelete(obj interface{})
  • func (c *Controller) OnUpdate(old, new interface{})
  • func (c *Controller) ProcessKey(key string) error
  • func (c *Controller) Run(ctx context.Context, workers int)
  • func (c *Controller) Shutdown()
• type ControllerBase
• type ObjectToKeyConverter
• type ReconciliationId
• type RetryError
  • func (e *RetryError) Error() string
  • func (e *RetryError) Is(err error) bool
  • func (e *RetryError) Unwrap() error
• type TimeKey

Functions

func RemoveFinalizer

func RemoveFinalizer(metaObj *metav1.ObjectMeta, finalizer string)

func ShouldRetry

func ShouldRetry(err error) bool

func WithReconciliationId

func WithReconciliationId(ctx context.Context) zap.Field

func WrapRetryError

func WrapRetryError(err error) error

Types

type Controller

type Controller struct {
	Base ControllerBase
	// contains filtered or unexported fields
}

func NewController

func NewController(base ControllerBase, coreClient kubernetes.Interface) *Controller

func (*Controller) EventRecorder

func (c *Controller) EventRecorder() record.EventRecorder

func (*Controller) Log

func (c *Controller) Log(ctx context.Context) *zap.Logger

func (*Controller) OnAdd

func (c *Controller) OnAdd(obj interface{})

func (*Controller) OnDelete

func (c *Controller) OnDelete(obj interface{})

func (*Controller) OnUpdate

func (c *Controller) OnUpdate(old, new interface{})

func (*Controller) ProcessKey

func (c *Controller) ProcessKey(key string) error

func (*Controller) Run

func (c *Controller) Run(ctx context.Context, workers int)

func (*Controller) Shutdown

func (c *Controller) Shutdown()

type ControllerBase

type ControllerBase interface {
	Name() string
	Finalizers() []string
	ListerSynced() []cache.InformerSynced
	EventSources() []cache.SharedIndexInformer
	ConvertToKeys() ObjectToKeyConverter
	GetObject(key string) (interface{}, error)
	UpdateObject(ctx context.Context, obj interface{}) error
	Reconcile(ctx context.Context, obj interface{}) error
	Finalize(ctx context.Context, obj interface{}) error
}

type ObjectToKeyConverter

type ObjectToKeyConverter func(obj interface{}) (keys []string, err error)

type ReconciliationId

type ReconciliationId struct{}

type RetryError

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

func (*RetryError) Error

func (e *RetryError) Error() string

func (*RetryError) Is

func (e *RetryError) Is(err error) bool

func (*RetryError) Unwrap

func (e *RetryError) Unwrap() error

type TimeKey

type TimeKey struct{}