schemaswap

package
v2.1.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Apr 25, 2017 License: BSD-3-Clause Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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.

Jump to

Keyboard shortcuts

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