exec

Documentation

Index

• type BumpGenExec
  • func (exec *BumpGenExec) Done() bool
  • func (exec *BumpGenExec) Execute(rc *xstorev1reconcile.Context, flow control.Flow) (reconcile.Result, error)
  • func (exec *BumpGenExec) MarkDone()
  • func (exec *BumpGenExec) Step() *plan.Step
• type CreateExec
  • func (exec *CreateExec) Done() bool
  • func (exec *CreateExec) Execute(rc *xstorev1reconcile.Context, flow control.Flow) (reconcile.Result, error)
  • func (exec *CreateExec) MarkDone()
  • func (exec *CreateExec) Step() *plan.Step
• type DeleteExec
  • func (exec *DeleteExec) Done() bool
  • func (exec *DeleteExec) Execute(rc *xstorev1reconcile.Context, flow control.Flow) (reconcile.Result, error)
  • func (exec *DeleteExec) MarkDone()
  • func (exec *DeleteExec) Step() *plan.Step
• type Executor
  • func NewExecutor(ec *context.ExecutionContext, index int, step plan.Step) Executor
  • func NewExecutorsForPlan(ec *context.ExecutionContext, plan plan.Plan) []Executor
• type ReplaceExec
  • func (exec *ReplaceExec) Done() bool
  • func (exec *ReplaceExec) Execute(rc *xstorev1reconcile.Context, flow control.Flow) (reconcile.Result, error)
  • func (exec *ReplaceExec) MarkDone()
  • func (exec *ReplaceExec) Step() *plan.Step
• type SnapshotExec
  • func (exec *SnapshotExec) Done() bool
  • func (exec *SnapshotExec) Execute(rc *xstorev1reconcile.Context, flow control.Flow) (reconcile.Result, error)
  • func (exec *SnapshotExec) MarkDone()
  • func (exec *SnapshotExec) Step() *plan.Step
• type UpdateExec
  • func (exec *UpdateExec) Done() bool
  • func (exec *UpdateExec) Execute(rc *xstorev1reconcile.Context, flow control.Flow) (reconcile.Result, error)
  • func (exec *UpdateExec) MarkDone()
  • func (exec *UpdateExec) Step() *plan.Step

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 (exec *SnapshotExec) Execute(rc *xstorev1reconcile.Context, flow control.Flow) (reconcile.Result, error)

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