AttemptListQuery returns a new GraphQuery for the given AttemptList.

AttemptListQueryL returns a new GraphQuery for the given AttemptList literal.

AttemptRangeQuery returns a new GraphQuery for the given AttemptRange specification.

FileDescriptorSet returns a descriptor set for this proto package, which includes all defined services, and all transitive dependencies.

MakeWalkGraphIncludeAll makes a new WalkGraphReq_Include which has all the boxes ticked.

NewAttemptAbnormalFinish creates an Attempt in the ABNORMAL_FINISH state.

NewAttemptExecuting creates an Attempt in the EXECUTING state.

NewAttemptFinished creates an Attempt in the FINISHED state.

NewAttemptID is a shorthand to New a new *Attempt_ID.

NewAttemptList is a convenience method for making a normalized *AttemptList with a pre-normalized literal map of quest -> attempt nums.

NewAttemptScheduling creates an Attempt in the SCHEDULING state.

NewAttemptWaiting creates an Attempt in the WAITING state.

NewDatalessJsonResult creates a new JsonResult object without data and with optional expiration time.

NewExecutionAbnormalFinish creates an Execution in the ABNORMAL_FINISH state.

NewExecutionFinished creates an Execution in the FINISHED state.

NewExecutionID is a shorthand to New a new *Execution_ID.

NewExecutionRunning creates an Execution in the RUNNING state.

NewExecutionScheduling creates an Execution in the SCHEDULING state.

NewExecutionStopping creates an Execution in the STOPPING state.

NewJsonResult creates a new JsonResult object with optional expiration time.

NewQuestDesc is a shorthand method for building a new *Quest_Desc.

NewQuestID is a shorthand to New a new *Quest_ID.

NewTemplateSpec is a shorthand method for building a new *Quest_TemplateSpec.

The job was cancelled by an external entity (human, automated system).

This entity failed in a bad way.

Waited too long for the job to start.

This entity has a failed result.

This status is invalid and should not be used intentionally.

The job is unrecognized.

The job was prevented from running by the distributor (quota, permissions, etc.) Executions: the distributor refused to run this job.

The distributor ran the job, but returned garbage.

The job started, but took too long.

The Attempt is in an abnormal final state.

The Attempt is currently waiting for its current Execution to finish.

The Attempt is in its final state.

DATA_SIZE_LIMIT is set if the max_data_size limit was reached.

LOADED implies that the result was, in fact, loaded.

NOT_AUTHORIZED is set if the query was authenticated from an Execution whose Attempt doesn't depend on this one.

NOT_LOADED is set if the result failed to load because there was a transient error or the request ran out of time.

The Attempt is waiting to be Executed.

The Attempt is waiting for dependent Attempts to be resolved.

DefaultLimitMaxDataSize is the default MaxDataSize value (16MB).

The execution is in an abnormal final state.

The execution is in its final state.

The execution is running (has activated with DM).

The execution has been accepted by the distributor, but is not running yet.

The execution has been told to stop by DM, but we haven't heard from the distributor yet.

JSONNonNormalizedSizeFactor is the excess multiple of JSONObjectMaxLength that a non-normalized json object must be smaller than.

JSONObjectMaxLength is the maximum number of bytes that may be present in the Object field of a normalized JSONObject.

MaxLimitMaxDataSize is the maximum MaxDataSize value (30MB).

MinimumActivationTokenLength is the minimum number of bytes in an appropriate ExecutionToken.

QuestDescPayloadMaxLength is the maximum length (in bytes) of an un-normalized Quest payload.

QuestIDLength is the number of encoded bytes to use.

ActivateExecutionReq allows a currently-running Execution to activate itself.

This attempt has a live Execution (with the specified ID).

This attempt is complete.

This attempt is ready to be Executed, but hasn't been sent to the distributor yet.

This attempt's last Execution stopped by adding dependencies.

AttemptList is logically a listing of unique attempts, which has a compact representation in the common scenario of listing multiple attempts of the same quest(s).

EnsureGraphDataReq allows you to assert the existence of Attempts in DM's graph, and allows you to declare dependencies from one Attempt to another.

Execution_Auth is a tuple of the requesting ExecutionID and the activated Execution Token (see the ActivateExecution rpc).

FinishAttemptReq sets the final result of an Attempt.

GraphData defines all of the DM graph data that may be returned from DM.

GraphQuery represents a single query into the state of DM's dependency graph.

A Search allows you to query objects whose properties match all of the provided filters.

JsonResult represents a free-form JSON object.

Retry specifies the number of times in a row that DM should re-Execute an Attempt due to the provided abnormal result.

Timing describes the amount of time that Executions for this Quest should have, on the following timeline: Event: execution sent to distributor ^ "start" v Event: execution sends ActivateExecution ^ "run" v Event: execution sends halting RPC (either ActivateExecution or EnsureGraphData) ^ "stop" v Event: distributor gives execution result back to DM If the given timeout hits before the next event in the timeline, DM will mark the Execution as TIMED_OUT, and the appropriate retry policy will be applied.

Result holds either data OR abnormal finish information.

WalkGraphReq allows you to walk from one or more Quests through their Attempt's forward dependencies.

DepsClient is the client API for Deps service.

DepsServer is the server API for Deps service.

TimestampPurger is for testing: invoking this on a struct in this package will remove all timestamps from it.

QuestTemplateSpecs is a sortable slice of *Quest_TemplateSpec.

Direction indicates that direction of dependencies that the request should walk.