tasks

type Header struct {
	Meta struct {
		Protocol string `json:"protocol"`
		Caller   string `json:"caller"`
		TaskName string `json:"taskName"`
	} `json:"meta"`
	Data interface{} `json:"data"`
}

type JsonSchema struct {
	Schema     string                 `json:"$schema,omitempty" yaml:"$schema,omitempty"`       // optional
	ID         string                 `json:"$id,omitempty" yaml:"$id,omitempty"`               // optional
	Properties map[string]*JsonSchema `json:"properties,omitempty" yaml:"properties,omitempty"` // optional
	Type       string                 `json:"type,omitempty" yaml:"type,omitempty"`             // optional
	Required   []string               `json:"required,omitempty" yaml:"required,omitempty"`     // optional
}

type Runner interface {
	Execute(task *Task, execArgs interface{}) *TaskResult
	ExecuteAsync(task *Task, execArgs interface{})
	WaitUntilComplete()
	GetAsyncResults() <-chan *TaskResult
	SetLogger(logger *logrus.Logger)
	// contains filtered or unexported methods
}

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

type ScriptRunnerPool struct {
	*ScriptRunner
	// contains filtered or unexported fields
}

type ScriptSchema struct {
	Name        string      `json:"name,omitempty" yaml:"name,omitempty"`               // optional
	Description string      `json:"description,omitempty" yaml:"description,omitempty"` // optional
	Inputs      *JsonSchema `json:"inputs" yaml:"inputs"`
	Outputs     *JsonSchema `json:"outputs,omitempty" yaml:"outputs,omitempty"` // optional
}

type Task struct {
	Name     string      `json:"name" yaml:"name"`
	Location string      `json:"location" yaml:"location"`
	Accept   *JsonSchema `json:"schema" yaml:"schema"`
}

type TaskResult struct {
	Caller  *Task       `json:"-"` // not serialized
	Status  int         `json:"status"`
	Reason  string      `json:"reason"`
	Payload interface{} `json:"payload"`
}

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