workflow

type AsyncEvent struct {
	ServiceAction *model.Action
}

type Dao struct {
	Dao *neatly.Dao
}

type EndEvent struct {
	SessionID string
}

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 {
	Tasks string
	State map[string]interface{}
}

type LoadRequest struct {
	Source *url.Resource
}

type LoadResponse struct {
	*model.Workflow
}

type LoadedEvent struct {
	Workflow *model.Workflow
}

type Logger struct {
	*model.Activities
	Listener msg.Listener
	// contains filtered or unexported fields
}

type NopParrotRequest struct {
	In interface{}
}

type NopRequest struct{}

type PrintRequest struct {
	Message string
	Style   int
	Error   string
}

type RegisterRequest struct {
	*model.Workflow
}

type RegisterResponse struct {
	Source *url.Resource
}

type RunRequest struct {
	EnableLogging     bool                   `description:"flag to enable logging"`
	LogDirectory      string                 `description:"log directory"`
	FailureCount      int                    `description:"max number of failures CLI reported per validation"`
	SummaryFormat     string                 `description:"summary format: xml|json|yaml, summary file is not produced if this is empty"`
	EventFilter       map[string]bool        `description:"optional CLI filter option,key is either package name or package name.request/event prefix "`
	Async             bool                   `description:"flag to runWorkflow it asynchronously. Do not set it your self runner sets the flag for the first workflow"`
	Params            map[string]interface{} `` /* 132-byte string literal not displayed */
	PublishParameters bool                   `default:"true" description:"flag to publish parameters directly into context state"`
	SharedState       bool                   `` /* 138-byte string literal not displayed */
	URL               string                 `description:"workflow URL if workflow is not found in the registry, it is loaded"`
	Name              string                 `required:"true" description:"name defined in workflow document"`
	StateKey          string                 `` /* 131-byte string literal not displayed */
	Source            *url.Resource          `description:"run request location "`
	AssetURL          string
	TagIDs            string `description:"coma separated TagID list, if present in a task, only matched runs, other task runWorkflow as normal"`
	Tasks             string `required:"true" description:"coma separated task list, if empty or '*' runs all tasks sequentially"` //tasks to runWorkflow with coma separated list or '*', or empty string for all tasks
	Interactive       bool
	*model.InlineWorkflow
	// contains filtered or unexported fields
}

type RunResponse struct {
	Data      map[string]interface{} //  data populated by  .Post variable section.
	SessionID string                 //session id
}

type Service struct {
	*endly.AbstractService
	Dao *Dao
	// contains filtered or unexported fields
}

type SetEnvRequest struct {
	Env map[string]string `description:"dynamically change current run endly os environment variables"`
}

type SetEnvResponse struct {
	Env map[string]string
}

type SwitchCase struct {
	*model.ServiceRequest `description:"action to runWorkflow if matched"`
	Task                  string      `description:"task to runWorkflow if matched"`
	Value                 interface{} `required:"true" description:"matching sourceKey value"`
}

type SwitchRequest struct {
	SourceKey string        `required:"true" description:"sourceKey for matching value"`
	Cases     []*SwitchCase `required:"true" description:"matching value cases"`
	Default   *SwitchCase   `description:"in case no value was match case"`
}

type SwitchResponse interface{}