workflow

func (*Service) DecodeYAML ¶

func (s *Service) DecodeYAML(encoded []byte) (*model.Workflow, error)

DecodeYAML decodes a workflow from YAML

func (*Service) Load ¶

func (s *Service) Load(ctx context.Context, URL string) (*model.Workflow, error)

Load loads a workflow from YAML at the specified Location

func (*Service) ParseWorkflow ¶

func (s *Service) ParseWorkflow(URL string, node *yaml.Node) (*model.Workflow, error)

func (*Service) Refresh ¶ added in v0.1.19

func (s *Service) Refresh(location string)

Refresh discards any cached copy of the workflow definition identified by the provided location. The next Load call will reload the file via the meta-service.

func (*Service) RootTaskNodeName ¶

func (s *Service) RootTaskNodeName() string

RootTaskNodeName returns the root task node name

func (*Service) Upsert ¶ added in v0.1.19

func (s *Service) Upsert(location string, wf *model.Workflow)

Upsert stores the supplied workflow definition in the cache under the given location, replacing any existing entry.