Skip to main content

Module dex

Module dex 

Source
Expand description

Generated Dex protocol.

Modules§

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.
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
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
IndexConfig
InvokeExecuteMethodOutput
InvokeExecuteMethodRequest
InvokeExecuteMethodResponse
InvokeRpcRequest
InvokeRpcResponse
InvokeWaitForMethodOutput
InvokeWaitForMethodRequest
InvokeWaitForMethodResponse
InvokeWorkerRpcRequest
InvokeWorkerRpcResponse
Kv
ListStreamMessagesRequest
ListStreamMessagesResponse
LoadBlobRequestEntry
LoadBlobsRequest
LoadBlobsResponse
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 ownership changes or shutdown.
PollWorkerTaskRegister
Registers one queue stream for a Worker process.
PollWorkerTaskRegistered
Confirms that Dex accepted the queue registration.
PollWorkerTaskReject
Declines a task so Dex can assign it to another available Worker stream.
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
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
StepExecuteCompletedEvent
StepExecuteCompletedOutput
StepExecuteFailedEvent
StepExecutionCompletedConditions
StepExecutionResumeInfo
StepMethodEventContext
StepMethodEventInput
StepMethodFailedOutput
StepMethodFailure
StepMethodHeartbeat
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.
PollWorkerTaskRejectReason
Explains why a Worker declined a task.
PullRoutingSource
ServerEngine
Identifies the engine behind a Dex Server. Clients use it only to adapt behavior that differs between engines.
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.
StopType
SubFlowReusePolicy
WaitForMethodFailurePolicy
WaitingConditionType