operator

Documentation

Index

• func HandleError(ctx context.Context, result *ctrl.Result, err error) (ctrl.Result, error)
• func RequeueAfter(d time.Duration) error
• func RequeueAfterWithError(d time.Duration, err error) error
• func ResultFromError(err error) (*ctrl.Result, error)
• type ReconcileHandler
• type RequeueError
  • func (r *RequeueError) Error() string
  • func (r *RequeueError) Result() reconcile.Result
• type SubReconciler
  • func NewDeploymentReconciler[T runtime.Object](fn ReconcileHandler[T]) SubReconciler[T]
  • func NewPVCReconciler[T runtime.Object](fn ReconcileHandler[T]) SubReconciler[T]
  • func NewServiceReconciler[T runtime.Object](fn ReconcileHandler[T]) SubReconciler[T]
  • func NewStatefulSetReconciler[T runtime.Object](fn ReconcileHandler[T]) SubReconciler[T]
• type SubReconcilers
  • func NewSubReconcilers[T runtime.Object](reconcilers ...SubReconciler[T]) SubReconcilers[T]
  • func (s SubReconcilers[T]) Reconcile(ctx context.Context, req ctrl.Request, m T) error

Functions

func HandleError

func HandleError(ctx context.Context, result *ctrl.Result, err error) (ctrl.Result, error)

func RequeueAfter

func RequeueAfter(d time.Duration) error

func RequeueAfterWithError

func RequeueAfterWithError(d time.Duration, err error) error

func ResultFromError

func ResultFromError(err error) (*ctrl.Result, error)

Types

type ReconcileHandler

type ReconcileHandler[T runtime.Object] func(ctx context.Context, ns string, name string, m T) error

type RequeueError

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

func (*RequeueError) Error

func (r *RequeueError) Error() string

func (*RequeueError) Result

func (r *RequeueError) Result() reconcile.Result

type SubReconciler

type SubReconciler[T runtime.Object] struct {
	// contains filtered or unexported fields
}

func NewDeploymentReconciler

func NewDeploymentReconciler[T runtime.Object](fn ReconcileHandler[T]) SubReconciler[T]

func NewPVCReconciler

func NewPVCReconciler[T runtime.Object](fn ReconcileHandler[T]) SubReconciler[T]

func NewServiceReconciler

func NewServiceReconciler[T runtime.Object](fn ReconcileHandler[T]) SubReconciler[T]

func NewStatefulSetReconciler

func NewStatefulSetReconciler[T runtime.Object](fn ReconcileHandler[T]) SubReconciler[T]

type SubReconcilers

type SubReconcilers[T runtime.Object] []SubReconciler[T]

func NewSubReconcilers

func NewSubReconcilers[T runtime.Object](reconcilers ...SubReconciler[T]) SubReconcilers[T]

func (SubReconcilers[T]) Reconcile

func (s SubReconcilers[T]) Reconcile(ctx context.Context, req ctrl.Request, m T) error