twophase

Documentation

Index

• type Reconciler
  • func NewReconciler(req ctrl.Request, e endpoint.Endpoint, ctx ctx.Context) *Reconciler
  • func (r *Reconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
• type SchedulerUpdater
  • func (r *SchedulerUpdater) Reconcile(req ctrl.Request) (ctrl.Result, error)

Types

type Reconciler

type Reconciler struct {
	endpoint.Endpoint
	ctx.Context
}

Reconciler for the twophase reconciler

func NewReconciler

func NewReconciler(req ctrl.Request, e endpoint.Endpoint, ctx ctx.Context) *Reconciler

NewReconciler would create reconciler for twophase controller

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

Reconcile is twophase reconcile implement

type SchedulerUpdater

type SchedulerUpdater struct {
	Object runtime.Object
	ctx.Context
}

SchedulerUpdater updates nextStart and nextRecover for resources

func (*SchedulerUpdater) Reconcile

func (r *SchedulerUpdater) Reconcile(req ctrl.Request) (ctrl.Result, error)

Reconcile is twophase reconcile implement