schemaswap

Documentation

Index

• func RegisterWorkflowFactory()
• type Swap
  • func (schemaSwap *Swap) Action(ctx context.Context, path, name string) error
  • func (schemaSwap *Swap) Run(ctx context.Context, manager *workflow.Manager, ...) error
• type SwapWorkflowFactory
  • func (*SwapWorkflowFactory) Init(_ *workflow.Manager, workflowProto *workflowpb.Workflow, args []string) error
  • func (*SwapWorkflowFactory) Instantiate(_ *workflow.Manager, workflowProto *workflowpb.Workflow, ...) (workflow.Workflow, error)

Functions

func RegisterWorkflowFactory

func RegisterWorkflowFactory()

RegisterWorkflowFactory registers schema swap as a valid factory in the workflow framework.

Types

type Swap

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

Swap contains meta-information and methods controlling schema swap process as a whole.

func (*Swap) Action

func (schemaSwap *Swap) Action(ctx context.Context, path, name string) error

Action is a part of workflow.ActionListener interface. It registers "Retry" actions from UI.

func (*Swap) Run

func (schemaSwap *Swap) Run(ctx context.Context, manager *workflow.Manager, workflowInfo *topo.WorkflowInfo) error

Run is a part of workflow.Workflow interface. This is the main entrance point of the schema swap workflow.

type SwapWorkflowFactory

type SwapWorkflowFactory struct{}

SwapWorkflowFactory is a factory to create Swap objects as workflows.

func (*SwapWorkflowFactory) Init

func (*SwapWorkflowFactory) Init(_ *workflow.Manager, workflowProto *workflowpb.Workflow, args []string) error

Init is a part of workflow.Factory interface. It initializes a Workflow protobuf object.

func (*SwapWorkflowFactory) Instantiate

func (*SwapWorkflowFactory) Instantiate(_ *workflow.Manager, workflowProto *workflowpb.Workflow, rootNode *workflow.Node) (workflow.Workflow, error)

Instantiate is a part of workflow.Factory interface. It instantiates workflow.Workflow object from workflowpb.Workflow protobuf object.