README
¶
Documentation
¶
Overview ¶
Package jobrunner provides higher-level abstraction of automation cloud API which allows to use protocol in order to automate in-flow input requests
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type JibConfig ¶
type JibConfig = map[string]interface{}
JibConfig is a configuration for job input bundler (JIB).
type JobRun ¶
type JobRun struct {
ServiceId string `json:"serviceId"`
DomainId string `json:"domainId"`
JibConfig JibConfig `json:"jibConfig"`
CallbackUrl string `json:"callbackUrl,omitempty"`
OversupplyInputs bool `json:"oversupplyInputs"`
HowMany int `json:"howMany"`
}
JobRun is an instruction required to run a job using JobRunner, options are: - ServiceId: id of automation service, required - DomainId: id of domain, required - JibConfig: job input bundler (jib) configuration, required - CallbackUrl: callback url for webhook - HowMany: how many jobs with the same input data to run (used to test concurrency), defaults to 1
type JobRunner ¶
type JobRunner struct {
DomainId string
Job *cl.Job
JibUrl string `json:"jibUrl"`
InputData map[string]interface{}
// contains filtered or unexported fields
}
JobRunner manages job.
func (*JobRunner) CreateInput ¶
CreateInput makes an attempt to create input automatically. It uses job output and domain type definitions in order to do so. For example, it can send "finalPriceConsent" based on "finalPrice" output, if domain defines "finalPriceConsent" input with "finalPrice" as `sourceOutputKey` and "Consent" and `inputMethod`
Source Files