local_workflow

Documentation

Index

• func New(c chan workflow.ExecutionInput) gateway.Workflow
• type LocalWorkflow
  • func (g *LocalWorkflow) Channel() chan workflow.ExecutionInput
  • func (g *LocalWorkflow) DeprovisionNode(ctx context.Context, input *workflow.DeprovisionNodeInput) error
  • func (g *LocalWorkflow) ProvisionNode(ctx context.Context, input *workflow.ProvisionNodeInput) error

Functions

func New

func New(c chan workflow.ExecutionInput) gateway.Workflow

Types

type LocalWorkflow

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

func (*LocalWorkflow) Channel

func (g *LocalWorkflow) Channel() chan workflow.ExecutionInput

func (*LocalWorkflow) DeprovisionNode

func (g *LocalWorkflow) DeprovisionNode(ctx context.Context, input *workflow.DeprovisionNodeInput) error

func (*LocalWorkflow) ProvisionNode

func (g *LocalWorkflow) ProvisionNode(ctx context.Context, input *workflow.ProvisionNodeInput) error