Skip to main content

Module dex

Module dex 

Source
Expand description

Generated Dex protocol.

Modules§

dispatch_task_request
Nested message and enum types in DispatchTaskRequest.
dispatch_task_response
Nested message and enum types in DispatchTaskResponse.
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.
internal_async_step_input_snapshot
Nested message and enum types in InternalAsyncStepInputSnapshot.
internal_flow_error
Nested message and enum types in InternalFlowError.
internal_service_client
Generated client implementations.
internal_service_server
Generated server implementations.
invoke_execute_method_output
Nested message and enum types in InvokeExecuteMethodOutput.
invoke_wait_for_method_output
Nested message and enum types in InvokeWaitForMethodOutput.
matching_service_client
Generated client implementations.
matching_service_server
Generated server implementations.
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
BlobStoreCleanupWorkflowInput
BlobStoreCleanupWorkflowOutput
ChannelCondition
ChannelExternalDeleteEvent
ChannelExternalPublishEvent
ChannelInfo
ChannelMessage
ChannelMessageDeletion
ChannelResult
ChannelValues
CleanupBlobStoreActivityInput
CleanupBlobStoreActivityOutput
CloseDecision
ConditionCombination
ConditionResults
Context
ContinueAsNewDump
ContinueAsNewDumpRequest
ContinueAsNewDumpResponse
ContinueAsNewInput
DebugDumpResponse
DeleteChannelMessageRequest
DispatchTaskError
Reports a failure before Dex receives a Worker result.
DispatchTaskRequest
Describes one task dispatched to a Dex task queue.
DispatchTaskResponse
Reports assignment changes, relays Worker output, then ends with a result, Worker error, or dispatch error.
DumpFlowForContinueAsNewActivityInput
DumpFlowForContinueAsNewActivityOutput
EncodedObject
ExecuteRpcSignalRequest
FlowAlreadyStartedOptions
FlowClosedHistoryEvent
FlowConfig
FlowContinuedStart
FlowExecutionId
FlowHistoryEvent
FlowInitialStart
FlowResult
FlowRetryPolicy
FlowStartOptions
FlowStartedOrContinuedHistoryEvent
FlowTimeoutHandlerOptions
GetAttributesQueryRequest
GetAttributesQueryResponse
GetAttributesRequest
GetAttributesResponse
GetChannelMessagesRequest
GetChannelMessagesResponse
GetCurrentTimerInfosQueryResponse
GetFlowStateRequest
GetFlowStateResponse
GetFlowSummaryRequest
GetFlowSummaryResponse
GetHistoryEventsRequest
GetHistoryEventsResponse
GetScheduledGreedyTimerTimesQueryResponse
HealthInfo
IndexConfig
InternalActivityError
InternalAsyncStepInputSnapshot
InternalFlowError
InternalLocalActivityInput
InternalLocalStepActivityFailure
InternalWorkerError
InterpreterWorkflowInput
InterpreterWorkflowOutput
InvokeExecuteMethodActivityInput
InvokeExecuteMethodActivityOutput
InvokeExecuteMethodOutput
InvokeExecuteMethodRequest
InvokeExecuteMethodResponse
InvokeRpcRequest
InvokeRpcResponse
InvokeRpcUpdateResult
Sync-update InvokeRPC handler result when response and error are multiplexed.
InvokeWaitForMethodActivityInput
InvokeWaitForMethodActivityOutput
InvokeWaitForMethodOutput
InvokeWaitForMethodRequest
InvokeWaitForMethodResponse
InvokeWorkerRpcActivityInput
InvokeWorkerRpcActivityOutput
InvokeWorkerRpcRequest
InvokeWorkerRpcResponse
Kv
ListStreamMessagesRequest
ListStreamMessagesResponse
LoadBlobRequestEntry
LoadBlobsRequest
LoadBlobsResponse
LocalActivityMetadata
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.
PrepareRpcQueryRequest
PrepareRpcQueryResponse
PublishToChannelRequest
ReadStreamRequest
ReadStreamResponse
RecoveryErrorInfo
ReportSubFlowCompletionActivityInput
ReportSubFlowCompletionActivityOutput
ResetFlowRequest
ResetFlowResponse
RetryPolicy
RpcExecutionCompletedEvent
Successful RPC history projection. Updates include input/output; signals include them only when configured.
SearchFlowsRequest
SearchFlowsResponse
SearchFlowsResponseEntry
ServerInfo
Describes the Dex Server release and the inclusive protocol range it supports.
ServiceErrorResponse
SetAttributesRequest
SkipTimerRequest
SkipTimerSignalRequest
StaleSkipTimer
StartFlowRequest
StartFlowResponse
StartSubFlowActivityInput
StartSubFlowActivityOutput
StepCompletionOutput
StepDecision
StepExecuteCompletedEvent
StepExecuteCompletedOutput
StepExecuteFailedEvent
StepExecutionCompletedConditions
StepExecutionCounterInfo
StepExecutionNumbers
StepExecutionResumeInfo
StepMethodEventContext
StepMethodEventInput
StepMethodFailedOutput
StepMethodFailure
StepMethodHeartbeat
StepMethodOptions
StepMethodPendingEvent
StepMethodPendingEvent describes a regular Step activity unresolved at flow closure.
StepMovement
StepOptions
StepStreamWrite
StepWaitForCompletedEvent
StepWaitForCompletedOutput
StepWaitForFailedEvent
StopFlowRequest
StopFlowSignalRequest
StreamMessage
SubFlowCompletionSignalRequest
SubFlowCondition
SubFlowConditionState
SubFlowOptions
SyncAttributeBatchActivityInput
SyncAttributeIndexRequest
SyncAttributeIndexResponse
TimeTravelForkHistoryEvent
TimeTravelForkHistoryEvent identifies the preserved run whose history Time Travel forked.
TimerCondition
TimerInfo
TimerInfoList
TimerResult
TriggerContinueAsNewRequest
UpdateFlowConfigRequest
Value
WaitForAttributeRequest
WaitForAttributeResponse
WaitForFlowRequest
WaitForHistoryEventRequest
WaitForHistoryEventResponse
WaitForStepCompletionRequest
WaitForStepCompletionResponse
WaitingCondition
WaitingConditionState
WorkerErrorResponse
WorkerTarget
WriteStreamRequest

Enums§

ActiveStepPhase
ActiveStepSearchMode
AttributeMatchOperator
CloseDecisionType
ConditionStatus
DispatchTaskErrorReason
Distinguishes absence of a Worker from loss of an assigned Worker.
ErrorSubStatus
ExecuteMethodFailurePolicy
FlowErrorType
FlowResetStepMethod
FlowResetType
FlowStatus
FlowTimeoutPolicy
IdReusePolicy
IndexType
InternalTimerStatus
PendingStepMethodPhase
PendingStepMethodPhase reports the latest persisted backend lifecycle event.
PollWorkerTaskRejectReason
Explains why a Worker declined a task.
StepDurability
Was optimize_activity: false=SYNC, true=ASYNC. Timer is always optimized by the server.
StopType
SubFlowCompletionDeliveryStatus
SubFlowReusePolicy
UpdateErrorType
WaitForMethodFailurePolicy
WaitingConditionType