reconciler

Documentation

Index

• type ClusterStageRecResult
  • func (r *ClusterStageRecResult) AsXlineClusterRecStatus() xapi.XlineClusterRecStatus
• type ReconcileContext
  • func NewReconcileContext(client client.Client, schema *runtime.Scheme, ctx context.Context) ReconcileContext
  • func (r *ReconcileContext) CreateOrUpdate(obj client.Object, objType client.Object) error
  • func (r *ReconcileContext) DeleteWhenExist(key types.NamespacedName, objType client.Object, ...) error
  • func (r *ReconcileContext) Exist(key types.NamespacedName, objType client.Object) (bool, error)
• type XlineClusterReconciler
  • func (r *XlineClusterReconciler) Reconcile() ClusterStageRecResult
  • func (r *XlineClusterReconciler) Sync() (xapi.XlineClusterSyncStatus, error)

Types

type ClusterStageRecResult

type ClusterStageRecResult struct {
	Stage  xapi.XlineClusterOprStage
	Status xapi.OprStageStatus
	Err    error
}

ClusterStageRecResult represents the result of a stage reconciliation for XlineCluster

func (*ClusterStageRecResult) AsXlineClusterRecStatus

func (r *ClusterStageRecResult) AsXlineClusterRecStatus() xapi.XlineClusterRecStatus

type ReconcileContext

type ReconcileContext struct {
	client.Client
	Schema *runtime.Scheme
	Ctx    context.Context
	Log    logr.Logger
}

ReconcileContext is the context for reconciling CRD.

func NewReconcileContext

func NewReconcileContext(client client.Client, schema *runtime.Scheme, ctx context.Context) ReconcileContext

func (*ReconcileContext) CreateOrUpdate

func (r *ReconcileContext) CreateOrUpdate(obj client.Object, objType client.Object) error

CreateOrUpdate creates or updates the kubernetes object.

func (*ReconcileContext) DeleteWhenExist

func (r *ReconcileContext) DeleteWhenExist(key types.NamespacedName, objType client.Object, deleteOpts ...client.DeleteOption) error

DeleteWhenExist deletes the kubernetes object if it exists.

func (*ReconcileContext) Exist

func (r *ReconcileContext) Exist(key types.NamespacedName, objType client.Object) (bool, error)

Exist checks if the kubernetes object exists.

type XlineClusterReconciler

type XlineClusterReconciler struct {
	ReconcileContext
	CR *xapi.XlineCluster
}

XlineClusterReconciler reconciles a XlineCluster object

func (*XlineClusterReconciler) Reconcile

func (r *XlineClusterReconciler) Reconcile() ClusterStageRecResult

Reconcile all sub components

func (*XlineClusterReconciler) Sync

func (r *XlineClusterReconciler) Sync() (xapi.XlineClusterSyncStatus, error)

Sync all subcomponents status.