workflowsdk

Documentation

Index

• type AlreadyExistsError
  • func (e *AlreadyExistsError) Error() string
• type Workflow
  • func New(instance *instancesdk.Instance, workflowDB database.WorkflowDB) *Workflow
  • func (w *Workflow) Create(wf *workflow.Workflow) (*workflow.Workflow, error)
  • func (w *Workflow) Delete(hash hash.Hash) error
  • func (w *Workflow) Get(hash hash.Hash) (*workflow.Workflow, error)
  • func (w *Workflow) List() ([]*workflow.Workflow, error)

Types

type AlreadyExistsError

type AlreadyExistsError struct {
	Hash hash.Hash
}

AlreadyExistsError is an not found error.

func (*AlreadyExistsError) Error

func (e *AlreadyExistsError) Error() string

type Workflow

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

Workflow exposes workflow APIs of MESG.

func New

func New(instance *instancesdk.Instance, workflowDB database.WorkflowDB) *Workflow

New creates a new Workflow SDK with given options.

func (*Workflow) Create

func (w *Workflow) Create(wf *workflow.Workflow) (*workflow.Workflow, error)

Create creates a new service from definition.

func (*Workflow) Delete

func (w *Workflow) Delete(hash hash.Hash) error

Delete deletes the workflow by hash.

func (*Workflow) Get

func (w *Workflow) Get(hash hash.Hash) (*workflow.Workflow, error)

Get returns the workflow that matches given hash.

func (*Workflow) List

func (w *Workflow) List() ([]*workflow.Workflow, error)

List returns all workflows.