ctrlkit

Oct 14, 2022

Changes in this version

type Action

+ func IfElse(predicate bool, left, right Action) Action

+ func RetryInterval(limit int, interval time.Duration, act Action) Action

Aug 31, 2022

Changes in this version

+ var Continue = NoRequeue

+ var ErrExit = errors.New("exit")

+ var Nop = &nopAction

+ var SequentialJoin = OrderedJoin

+ func Exit() (ctrl.Result, error)

+ func ExitIf(cond bool) (ctrl.Result, error)

+ func IgnoreExit(r ctrl.Result, err error) (ctrl.Result, error)

+ func NeedsRequeue(result ctrl.Result, err error) bool

+ func NoRequeue() (ctrl.Result, error)

+ func RequeueAfter(after time.Duration) (ctrl.Result, error)

+ func RequeueIfError(err error) (ctrl.Result, error)

+ func RequeueIfErrorAndWrap(explain string, err error) (ctrl.Result, error)

+ func RequeueImmediately() (ctrl.Result, error)

+ func ValidateOwnership(obj, owner client.Object) bool

+ type Action = internal.Action

+ func If(predicate bool, act Action) Action

+ func Join(actions ...Action) Action

+ func NewAction(description string, f ActionFunc) Action

+ func OptimizeWorkflow(workflow Action) Action

+ func OrderedJoin(actions ...Action) Action

+ func Parallel(act Action) Action

+ func ParallelJoin(actions ...Action) Action

+ func Retry(limit int, act Action) Action

+ func Sequential(actions ...Action) Action

+ func Shared(inner Action) Action

+ func Timeout(timeout time.Duration, act Action) Action

+ type ActionFunc func(context.Context) (ctrl.Result, error)

+ type ActionHook interface

+ PostRun func(ctx context.Context, logger logr.Logger, action string, result ctrl.Result, ...)

+ PreRun func(ctx context.Context, logger logr.Logger, action string, ...)

+ type ChainedActionHooks struct

+ func ChainActionHooks(hooks ...ActionHook) *ChainedActionHooks

+ func (c *ChainedActionHooks) Add(hook ActionHook)

+ func (c *ChainedActionHooks) PostRun(ctx context.Context, logger logr.Logger, action string, result ctrl.Result, ...)

+ func (c *ChainedActionHooks) PreRun(ctx context.Context, logger logr.Logger, action string, ...)