schemaswap

Documentation

Index

• func RegisterWorkflowFactory()
• type Swap
  • func (*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(workflowProto *workflowpb.Workflow, args []string) error
  • func (*SwapWorkflowFactory) Instantiate(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 (*Swap) Action(ctx context.Context, path, name string) error

Action is a part of workflow.Workflow interface. It implements UI actions with the workflow.

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(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(workflowProto *workflowpb.Workflow) (workflow.Workflow, error)

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