actions

Sep 3, 2021

Changes in this version

+ const RequeueDelay

+ const RequeueDelayError

+ func IsResourceFound(client client.Client, ctx context.Context, req ctrl.Request, ...) (bool, error)

+ func ManageError(client client.Client, ctx context.Context, instance client.Object, ...) (reconcile.Result, error)

+ func ManageSuccess(client client.Client, ctx context.Context, instance client.Object, ...) (reconcile.Result, error)

+ func ReadCurrentState(client client.Client, ctx context.Context, instance client.Object, ...) (reconcile.Result, error)

+ func RunDesiredStateActions(client client.Client, scheme *runtime.Scheme, ctx context.Context, ...) (reconcile.Result, error)

+ type ResourceState interface

+ IsResourcesReady func(client.Object) (bool, error)

+ Read func(context.Context, client.Object) error

Jul 8, 2021

Changes in this version

+ const ConditionStatusSuccess

+ func IsDeploymentReady(resource *appsv1.Deployment) (bool, error)

+ func IsEndpointsReady(resource *corev1.Endpoints) (bool, error)

+ func IsJobReady(resource *batchv1.Job) (bool, error)

+ func IsResourceNotReadyError(err error) bool

+ func IsServiceMeshControlPlaneReady(resource *unstructured.Unstructured) (bool, error)

+ func IsServiceMeshMemberReady(resource *unstructured.Unstructured) (bool, error)

+ func IsServiceMeshMemberRollReady(resource *unstructured.Unstructured) (bool, error)

+ type ActionRunner interface

+ Create func(obj client.Object, skipOwnerRef bool) error

+ Delete func(obj client.Object) error

+ Error func(err error) error

+ RunAll func(desiredState DesiredResourceState) error

+ Update func(obj client.Object, skipOwnerRef bool) error

+ func NewControllerActionRunner(context context.Context, client client.Client, scheme *runtime.Scheme, ...) ActionRunner

+ type ControllerAction interface

+ Run func(runner ActionRunner) (string, error)

+ type ControllerActionRunner struct

+ func (i *ControllerActionRunner) Create(obj client.Object, skipOwnerRef bool) error

+ func (i *ControllerActionRunner) Delete(obj client.Object) error

+ func (i *ControllerActionRunner) Error(err error) error

+ func (i *ControllerActionRunner) RunAll(desiredState DesiredResourceState) error

+ func (i *ControllerActionRunner) Update(obj client.Object, skipOwnerRef bool) error

+ type DesiredResourceState []ControllerAction

+ func (d *DesiredResourceState) AddAction(action ControllerAction) DesiredResourceState

+ func (d *DesiredResourceState) AddActions(actions []ControllerAction) DesiredResourceState

+ type GenericCreateAction struct

+ Msg string

+ Ref client.Object

+ SkipOwnerRef bool

+ func (i GenericCreateAction) Run(runner ActionRunner) (string, error)

+ type GenericDeleteAction struct

+ Msg string

+ Ref client.Object

+ func (i GenericDeleteAction) Run(runner ActionRunner) (string, error)

+ type GenericErrorAction struct

+ Msg string

+ Ref error

+ func (i GenericErrorAction) Run(runner ActionRunner) (string, error)

+ type GenericUpdateAction struct

+ Msg string

+ Ref client.Object

+ SkipOwnerRef bool

+ func (i GenericUpdateAction) Run(runner ActionRunner) (string, error)

+ type ResourceNotReadyError struct

+ PartialObject client.Object

+ func (e *ResourceNotReadyError) Error() string

+ type StateManager struct

+ func GetStateManager() *StateManager

+ func (sm *StateManager) Clear()

+ func (sm *StateManager) GetState(key string) interface{}

+ func (sm *StateManager) SetState(key string, value interface{})