exec

package
v1.2.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 25, 2022 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BumpGenExec

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

func (*BumpGenExec) Done

func (exec *BumpGenExec) Done() bool

func (*BumpGenExec) Execute

func (exec *BumpGenExec) Execute(rc *xstorev1reconcile.Context, flow control.Flow) (reconcile.Result, error)

func (*BumpGenExec) MarkDone

func (exec *BumpGenExec) MarkDone()

func (*BumpGenExec) Step

func (exec *BumpGenExec) Step() *plan.Step

type CreateExec

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

func (*CreateExec) Done

func (exec *CreateExec) Done() bool

func (*CreateExec) Execute

func (exec *CreateExec) Execute(rc *xstorev1reconcile.Context, flow control.Flow) (reconcile.Result, error)

func (*CreateExec) MarkDone

func (exec *CreateExec) MarkDone()

func (*CreateExec) Step

func (exec *CreateExec) Step() *plan.Step

type DeleteExec

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

func (*DeleteExec) Done

func (exec *DeleteExec) Done() bool

func (*DeleteExec) Execute

func (exec *DeleteExec) Execute(
	rc *xstorev1reconcile.Context,
	flow control.Flow,
) (reconcile.Result, error)

func (*DeleteExec) MarkDone

func (exec *DeleteExec) MarkDone()

func (*DeleteExec) Step

func (exec *DeleteExec) Step() *plan.Step

type Executor

type Executor interface {
	Step() *plan.Step
	Done() bool
	Execute(rc *xstorev1reconcile.Context, flow control.Flow) (reconcile.Result, error)
}

func NewExecutor

func NewExecutor(ec *context.ExecutionContext, index int, step plan.Step) Executor

func NewExecutorsForPlan

func NewExecutorsForPlan(ec *context.ExecutionContext, plan plan.Plan) []Executor

type ReplaceExec

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

func (*ReplaceExec) Done

func (exec *ReplaceExec) Done() bool

func (*ReplaceExec) Execute

func (exec *ReplaceExec) Execute(rc *xstorev1reconcile.Context, flow control.Flow) (reconcile.Result, error)

func (*ReplaceExec) MarkDone

func (exec *ReplaceExec) MarkDone()

func (*ReplaceExec) Step

func (exec *ReplaceExec) Step() *plan.Step

type SnapshotExec

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

func (*SnapshotExec) Done

func (exec *SnapshotExec) Done() bool

func (*SnapshotExec) Execute

func (*SnapshotExec) MarkDone

func (exec *SnapshotExec) MarkDone()

func (*SnapshotExec) Step

func (exec *SnapshotExec) Step() *plan.Step

type UpdateExec

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

func (*UpdateExec) Done

func (exec *UpdateExec) Done() bool

func (*UpdateExec) Execute

func (exec *UpdateExec) Execute(rc *xstorev1reconcile.Context, flow control.Flow) (reconcile.Result, error)

func (*UpdateExec) MarkDone

func (exec *UpdateExec) MarkDone()

func (*UpdateExec) Step

func (exec *UpdateExec) Step() *plan.Step

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL