model

type AbstractNode struct {
	Name        string
	Description string    `yaml:",omitempty"`
	Init        Variables `description:"state init instruction " yaml:",omitempty"`
	Post        Variables `description:"post execution state update instruction" yaml:",omitempty"`
	When        string    `description:"run criteria" yaml:",omitempty"`
	SleepTimeMs int       `yaml:",omitempty"`
	Logging     *bool     `description:"optional flag to disable logging, enabled by default" yaml:",omitempty"`
	// contains filtered or unexported fields
}

type Action struct {
	*AbstractNode   `yaml:",inline"`
	*ServiceRequest `yaml:",inline"`
	*MetaTag        `yaml:",inline"`
	*Repeater       `yaml:",inline"`
	Async           bool   `description:"flag to run action async" yaml:",omitempty"`
	Skip            string `description:"criteria to skip current TagID"  yaml:",omitempty"`
	// contains filtered or unexported fields
}

type ActionSelector string

type Activities struct {
	Activity *Activity
	// contains filtered or unexported fields
}

type Activity struct {
	*MetaTag
	Caller          string
	Task            string
	Service         string
	Action          string
	Description     string
	Error           string
	StartTime       time.Time
	Ineligible      bool
	Request         interface{}
	Response        map[string]interface{}
	ServiceResponse *endly.ServiceResponse
	Logging         *bool
}

type ActivityEndEvent struct {
	Response interface{}
}

type ExecutionError struct {
	Error    string
	Caller   string
	TaskName string
	Request  interface{}
	Response interface{}
}

type Extract struct {
	RegExpr  string `description:"regular expression with oval bracket to extract match pattern"`            //regular expression
	Key      string `description:"state key to store a match"`                                               //state key to store a match
	Reset    bool   `description:"reset the key in the context before evaluating this data extraction rule"` //reset the key in the context before evaluating this data extraction rule
	Required bool   `description:"require that at least one pattern match is returned"`                      //require that at least one pattern match is returned
}

type ExtractEvent struct {
	Output           string
	StructuredOutput interface{}
	Data             interface{}
}

type Extracts []*Extract

type Inlined struct {
	Init     interface{}
	Post     interface{}
	Logging  *bool
	Defaults map[string]interface{}
	Data     map[string]interface{}
	Pipeline []*MapEntry
	State    data.Map
	// contains filtered or unexported fields
}

type MapEntry struct {
	Key   string      `description:"preserved order map entry key"`
	Value interface{} `description:"preserved order map entry value"`
}

type MetaTag struct {
	Tag            string `yaml:",omitempty"` //tag
	TagIndex       string `yaml:",omitempty"` //tag index
	TagID          string `yaml:",omitempty"` //tag id
	TagDescription string `yaml:",omitempty"` //tag description
	Comments       string `yaml:",omitempty"`
}

type ModifiedStateEvent struct {
	Variables Variables
	In        map[string]interface{}
	Modified  map[string]interface{}
}

type OperatingSystem struct {
	*gosh.OSInfo
	*gosh.HardwareInfo
}

type OsTarget struct {
	System             string
	Architecture       string
	Name               string
	MinRequiredVersion string
	MaxAllowedVersion  string
}

type Path struct {
	Items []string
	// contains filtered or unexported fields
}

type Process struct {
	Source   *location.Resource
	Owner    string
	TagIDs   map[string]bool
	HasTagID bool
	Workflow *Workflow
	Task     *Task
	TaskNode *TasksNode
	*Activities
	State      data.Map
	Terminated int32
	Scheduled  *Task
	*ExecutionError
}

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

type Repeater struct {
	Extract     Extracts  `yaml:",omitempty"` //textual regexp based data extraction
	Variables   Variables `yaml:",omitempty"` //structure data based data extraction
	Repeat      int       `yaml:",omitempty"` //how many time send this request
	ThinkTimeMs int       `yaml:",omitempty"` //Sleep time after request send, this only makes sense with repeat option
	Exit        string    `yaml:",omitempty"` //Exit criteria, it uses expected variable to determine repeat termination
	// contains filtered or unexported fields
}

type ServiceRequest struct {
	Service string      `description:"service SessionID"`
	Action  string      `description:"service's'action "`
	Request interface{} `description:"service request" `
}

type Session struct {
	ID string
	*gosh.Service
	DaemonType    int
	Username      string
	SuperUSerAuth bool
	//Path             *Path
	EnvVariables     map[string]string
	CurrentDirectory string
	Deployed         map[string]string
	Cacheable        map[string]interface{}
	Mutex            *sync.RWMutex
}

type Sessions map[string]*Session

type Tag struct {
	OwnerSource *location.Resource
	OwnerName   string
	Name        string
	Group       string
	IsArray     bool
	Iterator    *TagIterator
	LineNumber  int
	Subpath     string
	PathMatch   string
	// contains filtered or unexported fields
}

type TagIterator struct {
	Template string
	Min      int
	Max      int
	// contains filtered or unexported fields
}

type Task struct {
	*AbstractNode `yaml:",inline"` //abstract node
	*MetaTag      `yaml:",inline"` //optional template tag propagated to task
	Actions       []*Action        ` yaml:",omitempty"` //actions
	*TasksNode    ` yaml:",inline"`
	Fail          bool      ` yaml:",omitempty"` //controls if return fail status workflow on catch task
	Template      *Template ` yaml:",omitempty"`
	// contains filtered or unexported fields
}

type TaskAsyncDoneEvent struct {
	TaskPath  []string `json:",omitempty"`
	Completed int      `json:",omitempty"`
	SessionID string   `json:",omitempty"`
}

type TaskAsyncStartEvent struct {
	TaskPath  []string `json:",omitempty"`
	Expected  int      `json:",omitempty"`
	SessionID string   `json:",omitempty"`
}

type TaskEndEvent struct {
	WorkflowName string   `json:",omitempty"`
	OwnerURL     string   `json:",omitempty"`
	TaskName     string   `json:",omitempty"`
	TaskPath     []string `json:",omitempty"`
	SessionID    string   `json:",omitempty"`
	Index        int      `json:",omitempty"`
	Status       string   `json:",omitempty"`
	Error        string   `json:",omitempty"`
}

type TaskStartEvent struct {
	WorkflowName string   `json:",omitempty"`
	OwnerURL     string   `json:",omitempty"`
	TaskName     string   `json:",omitempty"`
	TaskPath     []string `json:",omitempty"`
	SessionID    string   `json:",omitempty"`
	Index        int      `json:",omitempty"`
	TemplateTag  *MetaTag `json:",omitempty"`
}

type Tasks []*Task

type TasksNode struct {
	Tasks        Tasks  ` yaml:",omitempty"` //sub tasks
	OnErrorTask  string ` yaml:",omitempty"` //task that will run if error occur, the final workflow will return this task response
	DeferredTask string ` yaml:",omitempty"` //task that will always run if there has been previous  error or not
}

type TasksSelector string

type Template struct {
	SubPath     string            `description:"sub path for dynamic resource template expansion: i.e. use_cases/${index}*"`
	Tag         string            `description:"grouping tag i.e Test"`
	Range       string            `description:"range expression i.e 2..003  where upper bound number drives padding $index variable"`
	Description string            `description:"reference to file containing tagDescription i.e. @use_case,  file reference has to start with @"`
	Data        map[string]string `` /* 181-byte string literal not displayed */
	Tasks       []*Task           `description:"tasks to expand"`
}

type TransientTemplate struct {
	SubPath     string            `description:"sub path for dynamic resource template expansion: i.e. use_cases/${index}*"`
	Tag         string            `description:"grouping tag i.e Test"`
	Range       string            `description:"range expression i.e 2..003  where upper bound number drives padding $index variable"`
	Description string            `description:"reference to file containing tagDescription i.e. @use_case,  file reference has to start with @"`
	Data        map[string]string `` /* 181-byte string literal not displayed */
	Template    []interface{}     `description:"template to expand"`
	// contains filtered or unexported fields
}

type Variable struct {
	Name              string            `description:"name"`
	Value             interface{}       `description:"default value"`
	From              string            `description:"context state map key to pull data"`
	When              string            `` /* 139-byte string literal not displayed */
	Else              interface{}       `description:"if when criteria is not met then else can provide variable value alternative"`
	Required          bool              `description:"flag that validates that from returns non empty value or error is generated"`
	EmptyIfUnexpanded bool              `description:"threat variable value empty if it was not expanded"`
	Replace           map[string]string `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

type VariableExpression string

type Variables []*Variable

type Workflow struct {
	Source        *location.Resource ` yaml:",omitempty"` //source definition of the workflow
	Data          data.Map           `yaml:"-"`           //workflow data
	*AbstractNode `yaml:",inline"`   //workflow node`
	*TasksNode    `yaml:"pipeline"`  ///workflow tasks
}

type WorkflowSelector string