controller

Documentation

Index

• func EnsureFinalizers(ctx context.Context, obj client.Object, finalizerName string, fn CheckFunc, ...) (*ctrl.Result, error)
• type CheckFunc
• type FuncSignal
• type KubeSyncReconciler
  • func (r *KubeSyncReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrlResult ctrl.Result, err error)
  • func (r *KubeSyncReconciler) SetupWithManager(mgr ctrl.Manager) error
• type KubeSyncRequest
• type KubeSyncSpecPredicate
  • func (p KubeSyncSpecPredicate) Create(e event.CreateEvent) bool
  • func (p KubeSyncSpecPredicate) Delete(e event.DeleteEvent) bool
  • func (p KubeSyncSpecPredicate) Update(e event.UpdateEvent) bool

Functions

func EnsureFinalizers

func EnsureFinalizers(ctx context.Context, obj client.Object, finalizerName string, fn CheckFunc, cl client.Client, logger logr.Logger, reconcileForUpdate ...bool) (*ctrl.Result, error)

Types

type CheckFunc

type CheckFunc func() (time.Duration, error)

type FuncSignal

type FuncSignal struct {
	CancelCh chan struct{}
	DoneCh   chan struct{}
}

type KubeSyncReconciler

type KubeSyncReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	Log    logr.Logger
	Mgr    manager.Manager

	// Map of kubesync name to cancel chans
	CancelMap map[string]*FuncSignal
	// contains filtered or unexported fields
}

KubeSyncReconciler reconciles a KubeSync object

func (*KubeSyncReconciler) Reconcile

func (r *KubeSyncReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrlResult ctrl.Result, err error)

func (*KubeSyncReconciler) SetupWithManager

func (r *KubeSyncReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type KubeSyncRequest

type KubeSyncRequest struct {
	Ks *jibutechcomv1.KubeSync
}

type KubeSyncSpecPredicate

type KubeSyncSpecPredicate struct {
	predicatebase.IgnoreAllPredicate
}

func (KubeSyncSpecPredicate) Create

func (p KubeSyncSpecPredicate) Create(e event.CreateEvent) bool

Create responds the Create events on server startup, a real Create event will be ignored.

func (KubeSyncSpecPredicate) Delete

func (p KubeSyncSpecPredicate) Delete(e event.DeleteEvent) bool

func (KubeSyncSpecPredicate) Update

func (p KubeSyncSpecPredicate) Update(e event.UpdateEvent) bool

Update returns true when status is changed.