v1

Feb 10, 2023

Changes in this version

type CompositeOperator

+ func (co *CompositeOperator) Blockers() operand.BlockingOperands

Sep 26, 2022

Changes in this version

+ type CompositeOperator struct

+ DAG *dag.OperandDAG

+ Operands []operand.Operand

+ func NewCompositeOperator(opts ...CompositeOperatorOption) (*CompositeOperator, error)

+ func (co *CompositeOperator) Cleanup(ctx context.Context, obj client.Object) (result ctrl.Result, rerr error)

+ func (co *CompositeOperator) Ensure(ctx context.Context, obj client.Object, ownerRef metav1.OwnerReference) (ctrl.Result, error)

+ func (co *CompositeOperator) IsSuspended(ctx context.Context, obj client.Object) bool

+ func (co *CompositeOperator) Order() operand.OperandOrder

+ type CompositeOperatorOption func(*CompositeOperator)

+ func WithEventRecorder(recorder record.EventRecorder) CompositeOperatorOption

+ func WithExecutionStrategy(strategy executor.ExecutionStrategy) CompositeOperatorOption

+ func WithInstrumentation(tp trace.TracerProvider, mp metric.MeterProvider, log logr.Logger) CompositeOperatorOption

+ func WithOperands(operands ...operand.Operand) CompositeOperatorOption

+ func WithRetryPeriod(duration time.Duration) CompositeOperatorOption

+ func WithSuspensionCheck(f func(context.Context, client.Object) bool) CompositeOperatorOption

+ type Operator interface

+ Cleanup func(context.Context, client.Object) (result ctrl.Result, err error)

+ Ensure func(context.Context, client.Object, metav1.OwnerReference) (result ctrl.Result, err error)

+ IsSuspended func(context.Context, client.Object) bool