executor

Documentation

Overview

Package executor contains types and functions to help with the execution of the operands.

Index

• type ExecutionStrategy
• type Executor
  • func NewExecutor(e ExecutionStrategy, r record.EventRecorder) *Executor
  • func (exe *Executor) ExecuteOperands(order operand.OperandOrder, call operand.OperandRunCall, ctx context.Context, ...) (result ctrl.Result, rerr error)

Types

type ExecutionStrategy

type ExecutionStrategy int

ExecutionStrategy is the operands execution strategy of an operator.

const (
	Parallel ExecutionStrategy = iota
	Serial
)

type Executor

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

Executor is an operand executor. It is used to configure how the operands are executed. The event recorder is used to broadcast an event right after executing an operand.

func NewExecutor

func NewExecutor(e ExecutionStrategy, r record.EventRecorder) *Executor

NewExecutor initializes and returns an Executor.

func (*Executor) ExecuteOperands

func (exe *Executor) ExecuteOperands(
	order operand.OperandOrder,
	call operand.OperandRunCall,
	ctx context.Context,
	obj client.Object,
	ownerRef metav1.OwnerReference,
) (result ctrl.Result, rerr error)

ExecuteOperands executes operands in a given OperandOrder by calling a given OperandRunCall function on each of the operands. The OperandRunCall can be a call to Ensure or Delete.