workflow

package

Go to main page

Versions in this module

v0

v0.8.0

Apr 26, 2018

Changes in this version

type LoadRequest

+ func (r *LoadRequest) Validate() error

type RunRequest

+ AssetURL string

+ SharedStateMode bool

v0.7.8

Apr 19, 2018

v0.7.7

Apr 18, 2018

Changes in this version

+ const ServiceID

+ func FirstWorkflow(context *endly.Context) *model.Process

+ func GetResource(dao *Dao, state data.Map, URL string) *url.Resource

+ func Last(context *endly.Context) *model.Process

+ func LastWorkflow(context *endly.Context) *model.Process

+ func New() endly.Service

+ func Pop(context *endly.Context) *model.Process

+ func Push(context *endly.Context, process *model.Process)

+ type AsyncEvent struct

+ ServiceAction *model.Action

+ func NewAsyncEvent(action *model.Action) *AsyncEvent

+ type Dao struct

+ Dao *neatly.Dao

+ func NewDao() *Dao

+ func (d *Dao) Load(context *endly.Context, source *url.Resource) (*model.Workflow, error)

+ func (d *Dao) NewRepoResource(context data.Map, URI string) (*url.Resource, error)

+ type EndEvent struct

+ SessionID string

+ func NewEndEvent(sessionID string) *EndEvent

+ type ExitRequest struct

+ Source *url.Resource

+ type ExitResponse struct

+ type FailRequest struct

+ Message string

+ type FailResponse struct

+ type GotoRequest struct

+ Task string

+ type GotoResponse interface

+ type InitEvent struct

+ State map[string]interface{}

+ Tasks string

+ func NewInitEvent(tasks string, state data.Map) *InitEvent

+ type LoadRequest struct

+ Source *url.Resource

+ type LoadResponse struct

+ type LoadedEvent struct

+ Workflow *model.Workflow

+ func NewLoadedEvent(workflow *model.Workflow) *LoadedEvent

+ type Logger struct

+ Listener msg.Listener

+ func NewLogger(directory string, listener msg.Listener) *Logger

+ func (l *Logger) AsEventListener() msg.Listener

+ func (l *Logger) OnEvent(event msg.Event)

+ type ModifiedStateEvent struct

+ In map[string]interface{}

+ Modified map[string]interface{}

+ Variables model.Variables

+ func NewModifiedStateEvent(variables model.Variables, in, out data.Map) *ModifiedStateEvent

+ type NopParrotRequest struct

+ In interface{}

+ type NopRequest struct

+ type PipelineEvent struct

+ Name string

+ func NewPipelineEvent(pipeline *model.Pipeline) *PipelineEvent

+ type PrintRequest struct

+ Error string

+ Message string

+ Style int

+ func (r *PrintRequest) Messages() []*msg.Message

+ type RegisterRequest struct

+ type RegisterResponse struct

+ Source *url.Resource

+ type RunRequest struct

+ Async bool

+ EnableLogging bool

+ EventFilter map[string]bool

+ LogDirectory string

+ Name string

+ Params map[string]interface{}

+ PublishParameters bool

+ Source *url.Resource

+ TagIDs string

+ Tasks string

+ URL string

+ func NewRunRequest(workflow string, params map[string]interface{}, publishParams bool) *RunRequest

+ func NewRunRequestFromURL(URL string) (*RunRequest, error)

+ func (r *RunRequest) HasPipeline() bool

+ func (r *RunRequest) Init() (err error)

+ func (r *RunRequest) Validate() error

+ type RunResponse struct

+ Data map[string]interface{}

+ SessionID string

+ type Service struct

+ Dao *Dao

+ func (s *Service) HasWorkflow(name string) bool

+ func (s *Service) Register(workflow *model.Workflow) error

+ func (s *Service) Workflow(name string) (*model.Workflow, error)

+ type SwitchCase struct

+ Task string

+ Value interface{}

+ type SwitchRequest struct

+ Cases []*SwitchCase

+ Default *SwitchCase

+ SourceKey string

+ func (r *SwitchRequest) Match(source interface{}) *SwitchCase

+ func (r *SwitchRequest) Validate() error

+ type SwitchResponse interface

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