Skip to main content

Module dex

Module dex 

Source
Expand description

Generated Dex protocol.

Modules§

admin_service_client
Generated client implementations.
admin_service_server
Generated server implementations.
flow_history_event
Nested message and enum types in FlowHistoryEvent.
flow_service_client
Generated client implementations.
flow_service_server
Generated server implementations.
flow_started_or_continued_history_event
Nested message and enum types in FlowStartedOrContinuedHistoryEvent.
invoke_execute_method_output
Nested message and enum types in InvokeExecuteMethodOutput.
invoke_wait_for_method_output
Nested message and enum types in InvokeWaitForMethodOutput.
poll_worker_task
Nested message and enum types in PollWorkerTask.
poll_worker_task_frame
Nested message and enum types in PollWorkerTaskFrame.
poll_worker_task_request
Nested message and enum types in PollWorkerTaskRequest.
poll_worker_task_response
Nested message and enum types in PollWorkerTaskResponse.
step_down_active_node_response
Nested message and enum types in StepDownActiveNodeResponse.
value
Nested message and enum types in Value.
worker_service_client
Generated client implementations.
worker_service_server
Generated server implementations.
worker_task_service_client
Generated client implementations.
worker_task_service_server
Generated server implementations.

Structs§

ActionPermissionMapping
ActionPermissionMappings
ActiveStepExecutionState
AttributeMatch
AttributeStoreNames
AttributeSyncConfig
AttributeSyncItem
AttributeWrite
ChannelCondition
ChannelExternalDeleteEvent
ChannelExternalPublishEvent
ChannelInfo
ChannelMessage
ChannelMessageDeletion
ChannelResult
ChannelValues
CloseDecision
ConditionCombination
ConditionResults
Context
DeleteChannelMessageRequest
DescribeActiveNodeRequest
Requests the identity of the active Server process that receives the call.
DescribeActiveNodeResponse
Identifies the active Server process of a node ID.
EncodedObject
FlowAlreadyStartedOptions
FlowClosedHistoryEvent
FlowConfig
FlowContinuedStart
Deprecated: Dex does not continue Flows as new and never records this start.
FlowExecutionId
FlowHistoryEvent
FlowInitialStart
FlowResult
FlowRetryPolicy
Dex does not support Flow retry and rejects a set policy with INVALID_ARGUMENT.
FlowStartOptions
FlowStartedOrContinuedHistoryEvent
FlowTimeoutHandlerOptions
GetAttributesRequest
GetAttributesResponse
GetChannelMessagesRequest
GetChannelMessagesResponse
GetFlowStateRequest
GetFlowStateResponse
GetFlowSummaryRequest
GetFlowSummaryResponse
GetHistoryEventsRequest
GetHistoryEventsResponse
HealthInfo
HistoryEventIdRange
HistoryEventIDRange is an inclusive range of history event IDs of one run.
IndexConfig
InvokeExecuteMethodOutput
InvokeExecuteMethodRequest
InvokeExecuteMethodResponse
InvokeRpcRequest
InvokeRpcResponse
InvokeWaitForMethodOutput
InvokeWaitForMethodRequest
InvokeWaitForMethodResponse
InvokeWorkerRpcRequest
InvokeWorkerRpcResponse
Kv
ListStreamMessagesRequest
ListStreamMessagesResponse
LoadBlobRequestEntry
LoadBlobsRequest
LoadBlobsResponse
NodeLeaseHolder
Identifies the process that holds a node lease.
NodeLeaseHolderUnknown
Says why the stepped-down process could not confirm which process holds the node lease.
PollWorkerTask
Assigns one task to this stream until its final result, error, or rejection.
PollWorkerTaskCancelTask
Requests cancellation of the task currently assigned to this stream.
PollWorkerTaskFrame
Carries a task’s heartbeat, stream write, result, or Worker error.
PollWorkerTaskPing
Checks that an idle pull stream remains responsive.
PollWorkerTaskPong
Acknowledges a server Ping on the same stream.
PollWorkerTaskReconnect
Asks the Worker to finish its task and reconnect for queue or slot ownership changes or shutdown.
PollWorkerTaskRegister
Registers one queue stream or reserved execution slot for a Worker process.
PollWorkerTaskRegistered
Confirms that Dex accepted the queue or reserved-slot registration.
PollWorkerTaskReject
Declines a task so Dex can assign it to another available Worker stream. Reserved-slot streams may send only UNKNOWN_STEP or UNKNOWN_RPC; the handler never ran. NO_CAPACITY on a reserved-slot stream is a protocol error. Dex then fails that attempt as not run, which consumes an attempt, and ends the stream with INVALID_ARGUMENT.
PollWorkerTaskRequest
Carries one Worker frame on a pull stream. Register must be the first frame.
PollWorkerTaskResponse
Carries one server frame on a pull stream.
PublishToChannelRequest
PullRouting
ReadStreamRequest
ReadStreamResponse
RecoveryErrorInfo
Describes a Step method failure for its recovery path.
ResetFlowRequest
ResetFlowResponse
RetryPolicy
RpcExecutionCompletedEvent
Successful RPC history projection. Transactional RPCs include input/output; other RPCs omit them.
SearchFlowsRequest
SearchFlowsResponse
SearchFlowsResponseEntry
ServerInfo
Describes the Dex Server release and the inclusive protocol range it supports.
ServiceErrorResponse
SetAttributesRequest
SkipTimerRequest
StartFlowRequest
StartFlowResponse
StepCompletionOutput
StepDecision
StepDownActiveNodeRequest
Requests a step down of the active Server process that receives the call.
StepDownActiveNodeResponse
Reports a completed step down and which process held the node lease when the call returned.
StepExecuteCompletedEvent
StepExecuteCompletedOutput
StepExecuteFailedEvent
StepExecutionCompletedConditions
StepExecutionResumeInfo
StepMethodEventContext
StepMethodEventInput
StepMethodFailedOutput
StepMethodFailure
StepMethodHeartbeat
StepMethodInvocationState
The current invocation of one Step method: its phase, its attempt, and why a pending attempt waits.
StepMethodOptions
StepMethodPendingEvent
StepMethodPendingEvent describes a regular Step method unresolved at flow closure.
StepMovement
StepOptions
StepStreamWrite
StepWaitForCompletedEvent
StepWaitForCompletedOutput
StepWaitForFailedEvent
StopFlowRequest
StreamMessage
SubFlowCondition
SubFlowConditionState
SubFlowOptions
SyncAttributeIndexRequest
SyncAttributeIndexResponse
TimeTravelForkHistoryEvent
TimeTravelForkHistoryEvent identifies the preserved run whose history Time Travel forked.
TimerCondition
TimerInfo
TimerResult
TriggerContinueAsNewRequest
Deprecated: TriggerContinueAsNew always returns UNIMPLEMENTED.
UpdateFlowConfigRequest
Value
WaitForAttributeRequest
WaitForAttributeResponse
WaitForFlowRequest
WaitForHistoryEventRequest
WaitForHistoryEventResponse
WaitForStepCompletionRequest
WaitForStepCompletionResponse
WaitingCondition
WaitingConditionState
WorkerErrorResponse
WorkerTarget
WriteStreamRequest

Enums§

ActiveStepPhase
ActiveStepSearchMode
AttributeMatchOperator
CloseDecisionType
ConditionStatus
DispatchTaskErrorReason
Distinguishes no available Worker, a disconnected Worker, and a missing Step or RPC registration. Dex persists it in Step method failure events.
ErrorSubStatus
ExecuteMethodFailurePolicy
FlowErrorType
FlowResetStepMethod
FlowResetType
FlowStatus
FlowTimeoutPolicy
IdReusePolicy
IndexType
InternalTimerStatus
PendingStepMethodPhase
PendingStepMethodPhase reports the latest persisted backend lifecycle event. SCHEDULED waits for locks or dispatch. STARTED means an attempt is running.
PollWorkerSlotKind
Selects the tasks accepted by a reserved Worker execution slot.
PollWorkerTaskRejectReason
Explains why a Worker declined a task. See PollWorkerTaskReject for the reasons a reserved-slot stream may send.
PullRoutingSource
ServerEngine
Identifies the engine behind a Dex Server. Clients use it only to adapt behavior that differs between engines.
StepAttemptProgress
Reports the furthest progress across attempts of a Step method call.
StepDurability
Was optimize_activity: false=SYNC, true=ASYNC. Timer is always optimized by the server. Both durabilities record the same events. ASYNC advances without waiting for the commit; there is no local phase.
StepMethodInvocationPhase
Where the current invocation of a Step method stands.
StepMethodPendingReason
Why a pending Step method attempt has not reached a Worker yet.
StopType
SubFlowReusePolicy
WaitForMethodFailurePolicy
WaitingConditionType