config

Jun 8, 2021

Changes in this version

+ const StopReadJobsOutputAfter5Min

+ const TimeoutJobsAfter5MinInTerminalState

May 20, 2021

Changes in this version

+ const DefaultNumWorkers

+ var CFG_PREFIX_JOBS = "jobs"

+ var CFG_PREFIX_JOBS_FETCHER = "fetch"

+ var CFG_PREFIX_JOBS_TIMEOUT = "timeout"

+ var CFG_PREFIX_JOB_TIMEOUT_DURATION = "job_max_duration"

+ var NumWorkers int

+ func NewFlakyTestServer(t *testing.T, out <-chan string, isFlakyNow <-chan bool, ...) *httptest.Server

+ func StringToCfgForTests(t *testing.T, yaml []byte) (Config, Config)

type Config

+ PrometheusNamespace string

+ PrometheusService string

Oct 10, 2020

Changes in this version

+ var CFG_COMMUNICATOR_PARAMS_KEY = "params"

+ var CFG_INTERVAL_PARAMETER = "interval"

+ var CFG_PREFIX_ALLOWED_RESPONSE_CODES = "codes"

+ var CFG_PREFIX_BACKOFF = "backoff"

+ var CFG_PREFIX_BACKOFF_INITIALINTERVAL = "initialinterval"

+ var CFG_PREFIX_BACKOFF_MAXELAPSEDTIME = "maxelapsedtime"

+ var CFG_PREFIX_BACKOFF_MAXINTERVAL = "maxinterval"

+ var CFG_PREFIX_COMMUNICATOR = "communicator"

+ var CFG_PREFIX_COMMUNICATORS = "communicators"

+ func ConvertMapStringToInterface(in map[string]string) map[string]interface

+ func GetBool(section string) bool

+ func GetIntSlice(section string, param string, def []int) []int

+ func GetMapStringMapStringTemplatedDefault(section string, param string, def map[string]string) map[string]map[string]string

+ func GetStringDefault(section string, def string) string

+ func GetStringMapStringTemplated(section string, param string) map[string]string

+ func GetStringMapStringTemplatedDefault(section string, param string, def map[string]string) map[string]string

+ func GetStringMapStringTemplatedFromMap(section string, param string, from map[string]string) map[string]string

+ func GetStringMapStringTemplatedFromMapDefault(section string, param string, from map[string]string, def map[string]string) map[string]string

+ func GetTimeDurationDefault(section string, param string, def time.Duration) (interval time.Duration)

+ func LoadCfgForTests(t *testing.T, CfgFile string) (Config, Config)

+ func NewTestServer(t *testing.T, in func() interface{}, out func(string)) *httptest.Server

+ func TestMain(m *testing.M)

type Config

+ ClusterId string

+ ClusterPool string

+ NumActiveJobs int

+ NumFreeSlots int

+ NumWorkers int

+ URL string

Sep 23, 2020

Changes in this version

+ func GetStringTemplatedDefault(section string, def string) string

Apr 5, 2020

Changes in this version

+ const ProjectName

+ var C Config = Config

+ var CfgFile string

+ var ClientId string

+ func ReinitializeConfig()

+ type ApiOperations struct

+ Cancel UrlConf

+ Cancelation UrlConf

+ Failed UrlConf

+ Finish UrlConf

+ Get UrlConf

+ Lock UrlConf

+ LogStreams UrlConf

+ Run UrlConf

+ Unlock UrlConf

+ Update UrlConf

+ type Config struct

+ CallAPIDelaySec int

+ ClientId string

+ ConfigVersion string

+ HeartBeat ApiOperations

+ JobsAPI ApiOperations

+ type UrlConf struct

+ Headers map[string]string

+ Method string

+ Params map[string]string

+ PreservedFields map[string]string

+ Url string