workflowexecutions

Documentation

Index

• func Execution_Error_FromProto(mapCtx *direct.MapContext, in *pb.Execution_Error) *krm.Execution_Error
• func Execution_Error_ToProto(mapCtx *direct.MapContext, in *krm.Execution_Error) *pb.Execution_Error
• func Execution_StackTraceElement_FromProto(mapCtx *direct.MapContext, in *pb.Execution_StackTraceElement) *krm.Execution_StackTraceElement
• func Execution_StackTraceElement_Position_FromProto(mapCtx *direct.MapContext, in *pb.Execution_StackTraceElement_Position) *krm.Execution_StackTraceElement_Position
• func Execution_StackTraceElement_Position_ToProto(mapCtx *direct.MapContext, in *krm.Execution_StackTraceElement_Position) *pb.Execution_StackTraceElement_Position
• func Execution_StackTraceElement_ToProto(mapCtx *direct.MapContext, in *krm.Execution_StackTraceElement) *pb.Execution_StackTraceElement
• func Execution_StackTrace_FromProto(mapCtx *direct.MapContext, in *pb.Execution_StackTrace) *krm.Execution_StackTrace
• func Execution_StackTrace_ToProto(mapCtx *direct.MapContext, in *krm.Execution_StackTrace) *pb.Execution_StackTrace
• func Execution_StateError_FromProto(mapCtx *direct.MapContext, in *pb.Execution_StateError) *krm.Execution_StateError
• func Execution_StateError_ToProto(mapCtx *direct.MapContext, in *krm.Execution_StateError) *pb.Execution_StateError
• func Execution_Status_FromProto(mapCtx *direct.MapContext, in *pb.Execution_Status) *krm.Execution_Status
• func Execution_Status_Step_FromProto(mapCtx *direct.MapContext, in *pb.Execution_Status_Step) *krm.Execution_Status_Step
• func Execution_Status_Step_ToProto(mapCtx *direct.MapContext, in *krm.Execution_Status_Step) *pb.Execution_Status_Step
• func Execution_Status_ToProto(mapCtx *direct.MapContext, in *krm.Execution_Status) *pb.Execution_Status
• func NewExecutionModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)
• func WorkflowsExecutionObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Execution) *krm.WorkflowsExecutionObservedState
• func WorkflowsExecutionObservedState_ToProto(mapCtx *direct.MapContext, in *krm.WorkflowsExecutionObservedState) *pb.Execution
• func WorkflowsExecutionSpec_FromProto(mapCtx *direct.MapContext, in *pb.Execution) *krm.WorkflowsExecutionSpec
• func WorkflowsExecutionSpec_ToProto(mapCtx *direct.MapContext, in *krm.WorkflowsExecutionSpec) *pb.Execution
• type ExecutionAdapter
  • func (a *ExecutionAdapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error
  • func (a *ExecutionAdapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)
  • func (a *ExecutionAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)
  • func (a *ExecutionAdapter) Find(ctx context.Context) (bool, error)
  • func (a *ExecutionAdapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error

Functions

func Execution_Error_FromProto

func Execution_Error_FromProto(mapCtx *direct.MapContext, in *pb.Execution_Error) *krm.Execution_Error

func Execution_Error_ToProto

func Execution_Error_ToProto(mapCtx *direct.MapContext, in *krm.Execution_Error) *pb.Execution_Error

func Execution_StackTraceElement_FromProto

func Execution_StackTraceElement_FromProto(mapCtx *direct.MapContext, in *pb.Execution_StackTraceElement) *krm.Execution_StackTraceElement

func Execution_StackTraceElement_Position_FromProto

func Execution_StackTraceElement_Position_FromProto(mapCtx *direct.MapContext, in *pb.Execution_StackTraceElement_Position) *krm.Execution_StackTraceElement_Position

func Execution_StackTraceElement_Position_ToProto

func Execution_StackTraceElement_Position_ToProto(mapCtx *direct.MapContext, in *krm.Execution_StackTraceElement_Position) *pb.Execution_StackTraceElement_Position

func Execution_StackTraceElement_ToProto

func Execution_StackTraceElement_ToProto(mapCtx *direct.MapContext, in *krm.Execution_StackTraceElement) *pb.Execution_StackTraceElement

func Execution_StackTrace_FromProto

func Execution_StackTrace_FromProto(mapCtx *direct.MapContext, in *pb.Execution_StackTrace) *krm.Execution_StackTrace

func Execution_StackTrace_ToProto

func Execution_StackTrace_ToProto(mapCtx *direct.MapContext, in *krm.Execution_StackTrace) *pb.Execution_StackTrace

func Execution_StateError_FromProto

func Execution_StateError_FromProto(mapCtx *direct.MapContext, in *pb.Execution_StateError) *krm.Execution_StateError

func Execution_StateError_ToProto

func Execution_StateError_ToProto(mapCtx *direct.MapContext, in *krm.Execution_StateError) *pb.Execution_StateError

func Execution_Status_FromProto

func Execution_Status_FromProto(mapCtx *direct.MapContext, in *pb.Execution_Status) *krm.Execution_Status

func Execution_Status_Step_FromProto

func Execution_Status_Step_FromProto(mapCtx *direct.MapContext, in *pb.Execution_Status_Step) *krm.Execution_Status_Step

func Execution_Status_Step_ToProto

func Execution_Status_Step_ToProto(mapCtx *direct.MapContext, in *krm.Execution_Status_Step) *pb.Execution_Status_Step

func Execution_Status_ToProto

func Execution_Status_ToProto(mapCtx *direct.MapContext, in *krm.Execution_Status) *pb.Execution_Status

func NewExecutionModel

func NewExecutionModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func WorkflowsExecutionObservedState_FromProto

func WorkflowsExecutionObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Execution) *krm.WorkflowsExecutionObservedState

func WorkflowsExecutionObservedState_ToProto

func WorkflowsExecutionObservedState_ToProto(mapCtx *direct.MapContext, in *krm.WorkflowsExecutionObservedState) *pb.Execution

func WorkflowsExecutionSpec_FromProto

func WorkflowsExecutionSpec_FromProto(mapCtx *direct.MapContext, in *pb.Execution) *krm.WorkflowsExecutionSpec

func WorkflowsExecutionSpec_ToProto

func WorkflowsExecutionSpec_ToProto(mapCtx *direct.MapContext, in *krm.WorkflowsExecutionSpec) *pb.Execution

Types

type ExecutionAdapter

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

func (*ExecutionAdapter) Create

func (a *ExecutionAdapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error

Create creates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

func (*ExecutionAdapter) Delete

func (a *ExecutionAdapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)

Cancel the execution resource from GCP service when the corresponding Config Connector resource is deleted.

func (*ExecutionAdapter) Export

func (a *ExecutionAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)

Export maps the GCP object to a Config Connector resource `spec`.

func (*ExecutionAdapter) Find

func (a *ExecutionAdapter) Find(ctx context.Context) (bool, error)

Find retrieves the GCP resource. Return true means the object is found. This triggers Adapter `Update` call. Return false means the object is not found. This triggers Adapter `Create` call. Return a non-nil error requeues the requests.

func (*ExecutionAdapter) Update

func (a *ExecutionAdapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error

WorkflowsExecution does not support Update.