MongoDbSchedulerDefs Struct Reference

#include <Distributed/Schedulers/MongoDB/mongodbschedulerdefs.h>

Static Public Attributes
static const char *	bsonEnumStateAborted = "aborted"
static const char *	bsonEnumStateExecuting = "executing"
static const char *	bsonEnumStateFinished = "finished"
static const char *	bsonEnumStateInvalid = "invalid"
static const char *	bsonEnumStatePending = "pending"
static const char *	bsonEnumStateScheduled = "scheduled"
static const char *	bsonTagArguments = "args"
static const char *	bsonTagCapabilities = "capabilities"
static const char *	bsonTagData = "data"
static const char *	bsonTagErrorFileContents = "error"
static const char *	bsonTagExecutionBegin = "executionBegin"
static const char *	bsonTagExecutionEnd = "executionEnd"
static const char *	bsonTagHost = "host"
static const char *	bsonTagHostName = "host"
static const char *	bsonTagImageName = "imageName"
static const char *	bsonTagIp = "ip"
static const char *	bsonTagJobPollingPaused = "jobPollingPaused"
static const char *	bsonTagLastModified = "lastModified"
static const char *	bsonTagLastModifiedOnServer = "lastModifiedOnServer"
static const char *	bsonTagLogType = "logType"
static const char *	bsonTagMaxConcurrentJob = "maxConcurrentJob"
static const char *	bsonTagMediaType = "mediaType"
static const char *	bsonTagNetwork = "network"
static const char *	bsonTagObjectId = "_id"
static const char *	bsonTagOriginalWorkflowUuid = "originalWorkflowUuid"
static const char *	bsonTagOsPlatform = "osPlatform"
static const char *	bsonTagOsVersion = "osVersion"
static const char *	bsonTagOutput = "output"
static const char *	bsonTagParentProcessUuid = "parentProcessUuid"
static const char *	bsonTagPollingInterval = "pollingInterval"
static const char *	bsonTagProcessId = "processId"
static const char *	bsonTagProcessUuid = "processUuid"
static const char *	bsonTagProgress = "progress"
static const char *	bsonTagQuietPeriod = "quietPeriod"
static const char *	bsonTagRequestTime = "requestTime"
static const char *	bsonTagRequiredFeatures = "requiredFeatures"
static const char *	bsonTagResultWorkflow = "resultWorkflow"
static const char *	bsonTagResultWorkflowGridFS = "resultWorkflowGridFS"
static const char *	bsonTagRetryCount = "retryCount"
static const char *	bsonTagRetryWorkflowUuids = "retryWorkflowUuids"
static const char *	bsonTagScheduledBy = "scheduledBy"
static const char *	bsonTagScheduledFrom = "scheduledFrom"
static const char *	bsonTagScheduledTime = "scheduledTime"
static const char *	bsonTagScheduledTo = "scheduledTo"
static const char *	bsonTagSchedulerOption = "schedulerOption"
static const char *	bsonTagServerUuid = "serverUuid"
static const char *	bsonTagStartupTimeOnDb = "startupTimeOnDb"
static const char *	bsonTagStartupTimeOnHost = "startupTimeOnHost"
static const char *	bsonTagState = "state"
static const char *	bsonTagStop = "stop"
static const char *	bsonTagSupportedFeatures = "features"
static const char *	bsonTagSupportedPlugins = "plugins"
static const char *	bsonTagText = "text"
static const char *	bsonTagTimestamp = "timestamp"
static const char *	bsonTagUser = "user"
static const char *	bsonTagVersion = "version"
static const char *	bsonTagWorkflow = "workflow"
static const char *	bsonTagWorkflowName = "workflowName"
static const char *	bsonTagWorkflowUuid = "workflowUuid"
static const char *	bsonTagWorkingPath = "workingPath"

Member Data Documentation

bsonEnumStateAborted

const char * bsonEnumStateAborted = "aborted"

static

bsonEnumStateExecuting

const char * bsonEnumStateExecuting = "executing"

static

bsonEnumStateFinished

const char * bsonEnumStateFinished = "finished"

static

bsonEnumStateInvalid

const char * bsonEnumStateInvalid = "invalid"

static

bsonEnumStatePending

const char * bsonEnumStatePending = "pending"

static

bsonEnumStateScheduled

const char * bsonEnumStateScheduled = "scheduled"

static

bsonTagArguments

const char * bsonTagArguments = "args"

static

bsonTagCapabilities

const char * bsonTagCapabilities = "capabilities"

static

bsonTagData

const char * bsonTagData = "data"

static

bsonTagErrorFileContents

const char * bsonTagErrorFileContents = "error"

static

bsonTagExecutionBegin

const char * bsonTagExecutionBegin = "executionBegin"

static

bsonTagExecutionEnd

const char * bsonTagExecutionEnd = "executionEnd"

static

bsonTagHost

const char * bsonTagHost = "host"

static

bsonTagHostName

const char * bsonTagHostName = "host"

static

bsonTagImageName

const char * bsonTagImageName = "imageName"

static

bsonTagIp

const char * bsonTagIp = "ip"

static

bsonTagJobPollingPaused

const char * bsonTagJobPollingPaused = "jobPollingPaused"

static

bsonTagLastModified

const char * bsonTagLastModified = "lastModified"

static

bsonTagLastModifiedOnServer

const char * bsonTagLastModifiedOnServer = "lastModifiedOnServer"

static

bsonTagLogType

const char * bsonTagLogType = "logType"

static

bsonTagMaxConcurrentJob

const char * bsonTagMaxConcurrentJob = "maxConcurrentJob"

static

bsonTagMediaType

const char * bsonTagMediaType = "mediaType"

static

bsonTagNetwork

const char * bsonTagNetwork = "network"

static

bsonTagObjectId

const char * bsonTagObjectId = "_id"

static

bsonTagOriginalWorkflowUuid

const char * bsonTagOriginalWorkflowUuid = "originalWorkflowUuid"

static

bsonTagOsPlatform

const char * bsonTagOsPlatform = "osPlatform"

static

bsonTagOsVersion

const char * bsonTagOsVersion = "osVersion"

static

bsonTagOutput

const char * bsonTagOutput = "output"

static

bsonTagParentProcessUuid

const char * bsonTagParentProcessUuid = "parentProcessUuid"

static

bsonTagPollingInterval

const char * bsonTagPollingInterval = "pollingInterval"

static

bsonTagProcessId

const char * bsonTagProcessId = "processId"

static

bsonTagProcessUuid

const char * bsonTagProcessUuid = "processUuid"

static

bsonTagProgress

const char * bsonTagProgress = "progress"

static

bsonTagQuietPeriod

const char * bsonTagQuietPeriod = "quietPeriod"

static

bsonTagRequestTime

const char * bsonTagRequestTime = "requestTime"

static

bsonTagRequiredFeatures

const char * bsonTagRequiredFeatures = "requiredFeatures"

static

bsonTagResultWorkflow

const char * bsonTagResultWorkflow = "resultWorkflow"

static

bsonTagResultWorkflowGridFS

const char * bsonTagResultWorkflowGridFS = "resultWorkflowGridFS"

static

bsonTagRetryCount

const char * bsonTagRetryCount = "retryCount"

static

bsonTagRetryWorkflowUuids

const char * bsonTagRetryWorkflowUuids = "retryWorkflowUuids"

static

bsonTagScheduledBy

const char * bsonTagScheduledBy = "scheduledBy"

static

bsonTagScheduledFrom

const char * bsonTagScheduledFrom = "scheduledFrom"

static

bsonTagScheduledTime

const char * bsonTagScheduledTime = "scheduledTime"

static

bsonTagScheduledTo

const char * bsonTagScheduledTo = "scheduledTo"

static

bsonTagSchedulerOption

const char * bsonTagSchedulerOption = "schedulerOption"

static

bsonTagServerUuid

const char * bsonTagServerUuid = "serverUuid"

static

Job states may have the following transitions: Created -> Pending; Note, a new created job would write itself as Pending in database so you'll never see it as Created in database Pending -> Scheduled; When a server polled the job from database, it's marked as scheduled with the serverUuid set. Pending -> Invalid; When a server find a job in a bad format, it's marked as invalid by the server. Scheduled -> Pending[label = "Condition not fulfilled"]; The server marking the job as scheduled would proceed to check the pre-conditions like dependency jobs' status. If the condition hasn't fulfilled yet, the server would set the job back to Pending. A quietPeriod would be added to the job so other servers won't poll this job too soon. Scheduled -> Executing; If all the conditions fulfilled. The server would try scheduling it to the Scheduler which would then change to executing. Executing -> Finished; If the workflow of the job run to the end without error, it'll change to finished. Executing -> Aborted; Otherwise, it'll be aborted.

bsonTagStartupTimeOnDb

const char * bsonTagStartupTimeOnDb = "startupTimeOnDb"

static

bsonTagStartupTimeOnHost

const char * bsonTagStartupTimeOnHost = "startupTimeOnHost"

static

bsonTagState

const char * bsonTagState = "state"

static

bsonTagStop

const char * bsonTagStop = "stop"

static

bsonTagSupportedFeatures

const char * bsonTagSupportedFeatures = "features"

static

bsonTagSupportedPlugins

const char * bsonTagSupportedPlugins = "plugins"

static

bsonTagText

const char * bsonTagText = "text"

static

bsonTagTimestamp

const char * bsonTagTimestamp = "timestamp"

static

bsonTagUser

const char * bsonTagUser = "user"

static

bsonTagVersion

const char * bsonTagVersion = "version"

static

bsonTagWorkflow

const char * bsonTagWorkflow = "workflow"

static

bsonTagWorkflowName

const char * bsonTagWorkflowName = "workflowName"

static

bsonTagWorkflowUuid

const char * bsonTagWorkflowUuid = "workflowUuid"

static

bsonTagWorkingPath

const char * bsonTagWorkingPath = "workingPath"

static