Documentation
¶
Index ¶
Constants ¶
const DagFileExtension = ".so"
DagFileExtension is the extension of Dag files. Basically, they are go file compiled as plugins.
Variables ¶
This section is empty.
Functions ¶
func GetDagRunCheckInterval ¶
GetDagRunCheckInterval returns DAG_RUN_CHECK_INTERVAL used by scheduler. It is the time which scheduler must wait before checking which tasks need to be scheduled.
func GetDagsParseInterval ¶
GetDagsParseInterval returns DAGS_PARSE_INTERVAL used by scheduler.
func GetDataStore ¶
func GetDataStore() string
GetDataStore returns the persistence backend type we are using.
func GetNumWorkers ¶
func GetNumWorkers() int
GetNumWorkers tell us number of worker goroutines to spawn per worker
func GetPubSubClient ¶
func GetPubSubClient() string
GetPubSubClient returns the pub sub backend type we are using.
func GetRuntimeEnv ¶
func GetRuntimeEnv() string
GetRuntimeEnv returns RUNTIME_ENV. Used to configuration purposes. Same method is present in logger package to avoid circular import.
func NumCocurrencyGoRoutine ¶
func NumCocurrencyGoRoutine() int
NumCocurrencyGoRoutine returns NUM_CONCURRENCY_GO_ROUTINE, which tells us how many goroutines to use when we want to do parallel processing.
Types ¶
This section is empty.
Source Files