RTJobRunner

type BasicResponseResult struct {
	Err    error
	Result Result
}

type CreateWorkerFunction func() Worker

type JSONCommands struct {
	CommandToExecute string                     `json:"commandToExecute"`
	Substitutes      map[string]*SubstituteData `json:"substitutes,omitempty"`
}

type JSONFields struct {
	AdditionalStatements []string               `json:"additionalStatements,omitempty"`
	ExtraFields          map[string]interface{} `json:"extraFields,omitempty"`
}

type JSONJob struct {
	JSONCommands
	JSONFields
}

type JSONJobContainer struct {
	PostJobs      []*JSONJobContainer `json: "postJobs"`
	PreJobs       []*JSONJobContainer `json: "preJobs"`
	Job           *JSONJob            `json: "job"`
	Name          string              `json: "name"`
	NumIterations int                 `json: "numIterations"`
	Attributes    map[string]string   `json: "attributes"`
}

type JSONJobProcessor struct {
	Name             string
	CommandToExecute string
	OriginalJSONJob  *JSONJob
}

type JobHandler struct {
	PrintIndividualResults bool
	PrintPeriodicResults   bool
	PrintStatistics        bool

	Jobs []*JobInfo
	// contains filtered or unexported fields
}

type JobHandlerLineOutputFilter func(string) Request //line - outputline - if outputline is empty - dont add anything

type JobInfo struct {
	Resp Response
	Req  Request
	// contains filtered or unexported fields
}

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

type Request interface {
	GetName() string
}

type Response interface {
	GetError() error
	GetResult() Result
}

type Result interface{}

type StringRequest struct {
	Str string
}

type SubstituteData struct {
	NumToGenerate int    `json: "numToGenerate,omitempty"`
	Type          string `json: "type,omitempty"` //can be "int|string|random|gaussian"
	Upper         int    `json: "upper,omitempty"`
	Lower         int    `json: "lower,omitempty"`
}

type Worker interface {
	PreRun()
	PostRun()
	Run(id int, jh *JobHandler)
}