model

type Action struct {
	*ServiceRequest
	*NeatlyTag
	*Repeater
	Name  string    `description:"action name"`
	Init  Variables `description:"action state init instruction "`
	Post  Variables `description:"action post processing instruction"`
	Async bool      `description:"flag to run action async"`
	When  string    `description:"run action criteria"`
	Skip  string    `description:"criteria to skip current TagID"`
}

type ActionSelector string

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

type Activity struct {
	*NeatlyTag
	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
}

type ActivityEndEvent struct {
	Response interface{}
}

type ExecutionError struct {
	Error    string
	Caller   string
	TaskName string
}

type Extract struct {
	RegExpr string `description:"regular expression with oval bracket to extract match pattern" example:"go(\d\.\d)"` //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
}

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

type Extracts []*Extract

type Inline struct {
	Pipeline  []*MapEntry            `required:"true" description:"key value representing Pipelines in simplified form"`
	Pipelines Pipelines              `description:"actual Pipelines (derived from Pipeline)"`
	Defaults  map[string]interface{} `description:"default value for pipline parameters"`
	Init      interface{}            `description:"init state expression"`
	Post      interface{}            `description:"post processing update state expression"`
}

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

type NeatlyTag struct {
	Tag            string //neatly tag
	TagIndex       string //neatly tag index
	TagID          string //neatly tag id
	TagDescription string //tag description
}

type OperatingSystem struct {
	System       string
	Name         string
	Hardware     string
	Architecture string
	Arch         string //architecture abbreviation
	Version      string
}

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

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

type Pipeline struct {
	Name        string                 `description:"pipeline task name"`
	Workflow    string                 `description:"workflow (URL[:tasks]) selector "`
	Action      string                 `description:"action (service.action) selector "`
	Params      map[string]interface{} `description:"workflow or action parameters"`
	Description string                 `description:"description"`
	Request     interface{}            `description:"external action request location, otherwise params are used to form request"`
	Pipelines   Pipelines              `description:"workflow or action subsequent pipelines"`
	When        string                 `description:"run criteria"`
	Init        interface{}            `description:"state initalization "`
	Post        interface{}            `description:"post execution state update "`
}

type Pipelines []*Pipeline

type Process struct {
	Source   *url.Resource
	Owner    string
	Workflow *Workflow
	Pipeline *Pipeline
	*Activities
	Terminated int32
	Scheduled  *Task
	*ExecutionError
}

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

type Repeater struct {
	Extraction  Extracts  //textual regexp based data extraction
	Variables   Variables //structure data based data extraction
	Repeat      int       //how many time send this request
	SleepTimeMs int       //Sleep time after request send, this only makes sense with repeat option
	Exit        string    //Exit criteria, it uses extracted variable to determine repeat termination
}

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

type Session struct {
	ID string
	ssh.MultiCommandSession
	DaemonType       int
	Service          ssh.Service
	Os               *OperatingSystem
	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 Task struct {
	When        string    //criteria to run this task
	Seq         int       //sequence of the task
	Name        string    //Id of the task
	Description string    //description
	Actions     []*Action //actions
	Init        Variables //variables to initialise state before this taks runs
	Post        Variables //variable to update state after this task completes
	TimeSpentMs int       //optional min required time spent in this task, remaining will force Sleep
}

type TasksSelector string

type Variable struct {
	Name     string            //name
	Value    interface{}       //default value
	From     string            //context state map key to pull data
	When     string            //criteria if specified this variable will be set only if evaluated criteria is true (it can use $in, and $out state variables)
	Else     interface{}       //if when criteria is not met then else can provide variable value alternative
	Persist  bool              //stores in tmp directory to be used as backup if data is not in the cotnext
	Required bool              //flag that validates that from returns non empty value or error is generated
	Replace  map[string]string `` //replacements map, if key if specified substitute variable value with corresponding value.
	/* 147-byte string literal not displayed */
}

type VariableExpression string

type Variables []*Variable

type Workflow struct {
	Source      *url.Resource //source definition of the workflow
	Data        data.Map      //workflow data
	Name        string        //worfklow Id
	Description string        //description
	Init        Variables     //variables to initialise state before this workflow runs
	Post        Variables     //variables to initialise state before this workflow runs
	Tasks       []*Task       //workflow task
	OnErrorTask string        //task that will run if error occur, the final workflow will return this task response
	DeferTask   string        //task that will alway run if there has been previous  error or not
	SleepTimeMs int           //optional Sleep time
}

type WorkflowSelector string