objectsets

Documentation

Index

• type ArchivedObjectSetReconciler
  • func (r *ArchivedObjectSetReconciler) Reconcile(ctx context.Context, objectSet genericObjectSet) (ctrl.Result, error)
• type GenericClusterObjectSet
  • func (a *GenericClusterObjectSet) ClientObject() client.Object
  • func (a *GenericClusterObjectSet) GetConditions() *[]metav1.Condition
  • func (a *GenericClusterObjectSet) GetPausedFor() []packagesv1alpha1.ObjectSetPausedObject
  • func (a *GenericClusterObjectSet) GetPhases() []packagesv1alpha1.ObjectPhase
  • func (a *GenericClusterObjectSet) GetReadinessProbes() []packagesv1alpha1.ObjectSetProbe
  • func (a *GenericClusterObjectSet) IsArchived() bool
  • func (a *GenericClusterObjectSet) IsObjectPaused(obj client.Object) bool
  • func (a *GenericClusterObjectSet) IsPaused() bool
  • func (a *GenericClusterObjectSet) SetStatusPausedFor(pausedFor []packagesv1alpha1.ObjectSetPausedObject)
  • func (a *GenericClusterObjectSet) UpdatePhase()
• type GenericClusterObjectSetPhase
  • func (a *GenericClusterObjectSetPhase) ClientObject() client.Object
  • func (a *GenericClusterObjectSetPhase) GetConditions() []metav1.Condition
  • func (a *GenericClusterObjectSetPhase) GetStatusPausedFor() []packagesv1alpha1.ObjectSetPausedObject
  • func (a *GenericClusterObjectSetPhase) SetPhase(phase packagesv1alpha1.ObjectPhase)
  • func (a *GenericClusterObjectSetPhase) SetReadinessProbes(probes []packagesv1alpha1.ObjectSetProbe)
  • func (a *GenericClusterObjectSetPhase) SetSpecPausedFor(paused []packagesv1alpha1.ObjectSetPausedObject)
• type GenericObjectSet
  • func (a *GenericObjectSet) ClientObject() client.Object
  • func (a *GenericObjectSet) GetConditions() *[]metav1.Condition
  • func (a *GenericObjectSet) GetPausedFor() []packagesv1alpha1.ObjectSetPausedObject
  • func (a *GenericObjectSet) GetPhases() []packagesv1alpha1.ObjectPhase
  • func (a *GenericObjectSet) GetReadinessProbes() []packagesv1alpha1.ObjectSetProbe
  • func (a *GenericObjectSet) IsArchived() bool
  • func (a *GenericObjectSet) IsObjectPaused(obj client.Object) bool
  • func (a *GenericObjectSet) IsPaused() bool
  • func (a *GenericObjectSet) SetStatusPausedFor(pausedFor []packagesv1alpha1.ObjectSetPausedObject)
  • func (a *GenericObjectSet) UpdatePhase()
• type GenericObjectSetController
  • func NewClusterObjectSetController(c client.Client, log logr.Logger, scheme *runtime.Scheme, dw dynamicWatcher) *GenericObjectSetController
  • func NewGenericObjectSetController(gvk schema.GroupVersionKind, phaseGVK schema.GroupVersionKind, c client.Client, ...) *GenericObjectSetController
  • func NewObjectSetController(c client.Client, log logr.Logger, scheme *runtime.Scheme, dw dynamicWatcher) *GenericObjectSetController
  • func (c *GenericObjectSetController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (c *GenericObjectSetController) SetupWithManager(mgr ctrl.Manager) error
• type GenericObjectSetPhase
  • func (a *GenericObjectSetPhase) ClientObject() client.Object
  • func (a *GenericObjectSetPhase) GetConditions() []metav1.Condition
  • func (a *GenericObjectSetPhase) GetStatusPausedFor() []packagesv1alpha1.ObjectSetPausedObject
  • func (a *GenericObjectSetPhase) SetPhase(phase packagesv1alpha1.ObjectPhase)
  • func (a *GenericObjectSetPhase) SetReadinessProbes(probes []packagesv1alpha1.ObjectSetProbe)
  • func (a *GenericObjectSetPhase) SetSpecPausedFor(paused []packagesv1alpha1.ObjectSetPausedObject)
• type ObjectSetPhaseReconciler
  • func (r *ObjectSetPhaseReconciler) Reconcile(ctx context.Context, objectSet genericObjectSet) (ctrl.Result, error)
• type TeardownHandler
  • func NewTeardownHandler(c client.Client, dw dynamicWatchFreer, ...) *TeardownHandler
  • func (h *TeardownHandler) Teardown(ctx context.Context, objectSet genericObjectSet) (done bool, err error)

Types

type ArchivedObjectSetReconciler

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

func (*ArchivedObjectSetReconciler) Reconcile

func (r *ArchivedObjectSetReconciler) Reconcile(ctx context.Context, objectSet genericObjectSet) (ctrl.Result, error)

type GenericClusterObjectSet

type GenericClusterObjectSet struct {
	packagesv1alpha1.ClusterObjectSet
}

func (*GenericClusterObjectSet) ClientObject

func (a *GenericClusterObjectSet) ClientObject() client.Object

func (*GenericClusterObjectSet) GetConditions

func (a *GenericClusterObjectSet) GetConditions() *[]metav1.Condition

func (*GenericClusterObjectSet) GetPausedFor

func (a *GenericClusterObjectSet) GetPausedFor() []packagesv1alpha1.ObjectSetPausedObject

func (*GenericClusterObjectSet) GetPhases

func (a *GenericClusterObjectSet) GetPhases() []packagesv1alpha1.ObjectPhase

func (*GenericClusterObjectSet) GetReadinessProbes

func (a *GenericClusterObjectSet) GetReadinessProbes() []packagesv1alpha1.ObjectSetProbe

func (*GenericClusterObjectSet) IsArchived

func (a *GenericClusterObjectSet) IsArchived() bool

func (*GenericClusterObjectSet) IsObjectPaused

func (a *GenericClusterObjectSet) IsObjectPaused(obj client.Object) bool

func (*GenericClusterObjectSet) IsPaused

func (a *GenericClusterObjectSet) IsPaused() bool

func (*GenericClusterObjectSet) SetStatusPausedFor

func (a *GenericClusterObjectSet) SetStatusPausedFor(
	pausedFor []packagesv1alpha1.ObjectSetPausedObject)

func (*GenericClusterObjectSet) UpdatePhase

func (a *GenericClusterObjectSet) UpdatePhase()

type GenericClusterObjectSetPhase

type GenericClusterObjectSetPhase struct {
	packagesv1alpha1.ClusterObjectSetPhase
}

func (*GenericClusterObjectSetPhase) ClientObject

func (a *GenericClusterObjectSetPhase) ClientObject() client.Object

func (*GenericClusterObjectSetPhase) GetConditions

func (a *GenericClusterObjectSetPhase) GetConditions() []metav1.Condition

func (*GenericClusterObjectSetPhase) GetStatusPausedFor

func (a *GenericClusterObjectSetPhase) GetStatusPausedFor() []packagesv1alpha1.ObjectSetPausedObject

func (*GenericClusterObjectSetPhase) SetPhase

func (a *GenericClusterObjectSetPhase) SetPhase(phase packagesv1alpha1.ObjectPhase)

func (*GenericClusterObjectSetPhase) SetReadinessProbes

func (a *GenericClusterObjectSetPhase) SetReadinessProbes(probes []packagesv1alpha1.ObjectSetProbe)

func (*GenericClusterObjectSetPhase) SetSpecPausedFor

func (a *GenericClusterObjectSetPhase) SetSpecPausedFor(paused []packagesv1alpha1.ObjectSetPausedObject)

type GenericObjectSet

type GenericObjectSet struct {
	packagesv1alpha1.ObjectSet
}

func (*GenericObjectSet) ClientObject

func (a *GenericObjectSet) ClientObject() client.Object

func (*GenericObjectSet) GetConditions

func (a *GenericObjectSet) GetConditions() *[]metav1.Condition

func (*GenericObjectSet) GetPausedFor

func (a *GenericObjectSet) GetPausedFor() []packagesv1alpha1.ObjectSetPausedObject

func (*GenericObjectSet) GetPhases

func (a *GenericObjectSet) GetPhases() []packagesv1alpha1.ObjectPhase

func (*GenericObjectSet) GetReadinessProbes

func (a *GenericObjectSet) GetReadinessProbes() []packagesv1alpha1.ObjectSetProbe

func (*GenericObjectSet) IsArchived

func (a *GenericObjectSet) IsArchived() bool

func (*GenericObjectSet) IsObjectPaused

func (a *GenericObjectSet) IsObjectPaused(obj client.Object) bool

func (*GenericObjectSet) IsPaused

func (a *GenericObjectSet) IsPaused() bool

func (*GenericObjectSet) SetStatusPausedFor

func (a *GenericObjectSet) SetStatusPausedFor(
	pausedFor []packagesv1alpha1.ObjectSetPausedObject)

func (*GenericObjectSet) UpdatePhase

func (a *GenericObjectSet) UpdatePhase()

type GenericObjectSetController

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

Generic reconciler for both ObjectSet and ClusterObjectSet objects.

func NewClusterObjectSetController

func NewClusterObjectSetController(
	c client.Client, log logr.Logger,
	scheme *runtime.Scheme, dw dynamicWatcher,
) *GenericObjectSetController

func NewGenericObjectSetController

func NewGenericObjectSetController(
	gvk schema.GroupVersionKind,
	phaseGVK schema.GroupVersionKind,
	c client.Client, log logr.Logger,
	scheme *runtime.Scheme, dw dynamicWatcher,
) *GenericObjectSetController

func NewObjectSetController

func NewObjectSetController(
	c client.Client, log logr.Logger,
	scheme *runtime.Scheme, dw dynamicWatcher,
) *GenericObjectSetController

func (*GenericObjectSetController) Reconcile

func (c *GenericObjectSetController) Reconcile(
	ctx context.Context, req ctrl.Request,
) (ctrl.Result, error)

func (*GenericObjectSetController) SetupWithManager

func (c *GenericObjectSetController) SetupWithManager(
	mgr ctrl.Manager) error

type GenericObjectSetPhase

type GenericObjectSetPhase struct {
	packagesv1alpha1.ObjectSetPhase
}

func (*GenericObjectSetPhase) ClientObject

func (a *GenericObjectSetPhase) ClientObject() client.Object

func (*GenericObjectSetPhase) GetConditions

func (a *GenericObjectSetPhase) GetConditions() []metav1.Condition

func (*GenericObjectSetPhase) GetStatusPausedFor

func (a *GenericObjectSetPhase) GetStatusPausedFor() []packagesv1alpha1.ObjectSetPausedObject

func (*GenericObjectSetPhase) SetPhase

func (a *GenericObjectSetPhase) SetPhase(phase packagesv1alpha1.ObjectPhase)

func (*GenericObjectSetPhase) SetReadinessProbes

func (a *GenericObjectSetPhase) SetReadinessProbes(probes []packagesv1alpha1.ObjectSetProbe)

func (*GenericObjectSetPhase) SetSpecPausedFor

func (a *GenericObjectSetPhase) SetSpecPausedFor(paused []packagesv1alpha1.ObjectSetPausedObject)

type ObjectSetPhaseReconciler

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

func (*ObjectSetPhaseReconciler) Reconcile

func (r *ObjectSetPhaseReconciler) Reconcile(
	ctx context.Context, objectSet genericObjectSet,
) (ctrl.Result, error)

type TeardownHandler

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

func NewTeardownHandler

func NewTeardownHandler(
	c client.Client,
	dw dynamicWatchFreer,
	newObjectSetPhase func() genericObjectSetPhase,
) *TeardownHandler

func (*TeardownHandler) Teardown

func (h *TeardownHandler) Teardown(
	ctx context.Context, objectSet genericObjectSet,
) (done bool, err error)