Package io.superdurable.dex

package io.superdurable.dex

Related Packages

Package	Description
io.superdurable.dex.exceptions

Class	Description
ActiveStepSearchMode	Controls which active Step types Dex records in the ActiveStepTypes search index.
ApiKeyCredential	Exchanges a long-lived API key for short-lived Dex bearer tokens.
ApiKeyCredential.Builder	Configures the timeout and HTTP transport for an API key credential.
ApiKeyCredential.ExchangeException	Reports a token endpoint, response, transport, or timeout failure.
ApiKeyCredential.HttpConnectionFactory	Opens the HTTP connection used for an API key exchange.
Attribute<T>	Defines one durable, typed value stored with a Flow execution.
AttributeIndex	Describes how an Attribute is indexed for Flow search.
AttributeIndex.Type	Defines the value representation used by the search backend.
AttributeLock	Defines one Attribute lock for a Step's waitFor or execute method.
AttributeMap<T>	Defines a durable map of named, typed Attribute instances.
AttributeMatch<T>	Describes a scalar Attribute predicate.
BlobCache	Caches immutable, server-addressed blob payloads on local disk.
BlobCacheConfig	Configures the disk-backed BlobCache.
BufferedTextStream	Batches text chunks into best-effort Stream messages during one Step invocation.
Channel<T>	Defines one durable, typed message Channel for a Flow.
ChannelMap<T>	Defines a durable map of named, typed Channel instances.
ChannelMessage<T>	Identifies one typed value that is still pending in a Channel.
Client	Provides synchronous, strongly typed operations for starting and controlling Dex Flows.
ClientOptions	Configures a synchronous Client connection and value mapper.
ClientOptions.Builder	Builds immutable Client options.
Condition	Represents one Timer, Channel, or SubFlow condition used by a Wait.
ConditionCombination	Groups conditions that must all be satisfied as one alternative in a combined wait.
Context	Exposes invocation metadata and durable state operations to Step and RPC code.
Credential	Supplies a bearer token before each Client or Worker service call.
FileCredential	Reads a bearer token from a file and picks up rotations without a restart.
Flow<StartInput>	Defines the Steps, persistence, and RPC surface of one Flow type.
FlowConfig	Configures server behavior for one Flow execution.
FlowConfig.Builder	Builds immutable FlowConfig values.
FlowErrorType	Classifies why a Flow reached a terminal status other than FlowStatus.COMPLETED.
FlowInfo	Describes the identity and current status of one Flow execution.
FlowResult	Describes the observed state and output of a Flow used as a SubFlow or waited on by a client.
FlowStatus	Represents the lifecycle status of a Flow execution.
FlowTimeoutHandlerOptions	Configures one Flow timeout handler's Execute semantics and state snapshot.
FlowTimeoutHandlerOptions.Builder	Builds immutable FlowTimeoutHandlerOptions values.
FlowTimeoutPolicy	Controls how Dex responds when a positive soft Flow timeout expires.
GrpcErrorStatusMapping	Maps Java Worker application exceptions to gRPC status codes.
GrpcErrorStatusMapping.Builder	Builds immutable exception-to-status mappings.
IdReusePolicy	Controls whether Client.startFlow(Flow, String, I) may reuse an existing Flow ID.
PersistenceDefinition	Represents a typed Attribute, Channel, or Stream definition in a PersistenceSchema.
PersistenceSchema	Declares the Attributes, Channels, and Streams that belong to a Flow.
PullQueueRegistrationState	Describes one queue in an immutable pull readiness snapshot.
PullRegistrationError	Identifies a permanent pull rejection leaving a queue without a registered stream.
PullRegistrationState	Provides an independent, immutable snapshot of pull queue readiness.
PullWorkerOptions	Configures a Worker that opens outbound task streams to Dex.
PullWorkerOptions.Builder	Builds immutable outbound polling options.
RecoveryErrorInfo	Describes the final failure that caused a Step method recovery.
Registry	Validates and indexes the Flow definitions shared by a client or worker.
RetryPolicy	Configures exponential-backoff retries for Flow or Step operations.
RetryPolicy.Builder	Builds immutable RetryPolicy values.
RPC	Marks a public Flow method as an RPC endpoint.
RPCAttributeMapLock	Selects one Attribute-map instance to lock during an RPC invocation.
RpcDefinitions	Provides serializable functional types for strongly typed RPC method references.
RpcDefinitions.RpcFunc0<O>	Represents an RPC function with no application input and one output.
RpcDefinitions.RpcFunc1<I,O>	Represents an RPC function with one input and one output.
RpcDefinitions.RpcProc0	Represents an RPC procedure with no application input or output.
RpcDefinitions.RpcProc1<I>	Represents an RPC procedure with one input and no output.
RPCInvokeOptions	Adds runtime-selected Attribute-map locks and exact map-instance loads to one RPC invocation.
RPCInvokeOptions.Builder	Builds immutable RPCInvokeOptions values.
RPCResult<O>	Carries a typed RPC output, optional next-Step movements, and Step type cancellation.
SearchFlowEntry	Represents one Flow execution returned by a search query.
SearchFlowsOptions	Controls inclusion of earlier Continue-as-New runs in visibility searches.
SearchFlowsOptions.Builder	Builds immutable search options.
SearchFlowsPage	Contains one page of Flow search results and its continuation token.
StartFlowOptions	Configures one Client.startFlow(Flow, String, I) request.
StartFlowOptions.Builder	Builds immutable StartFlowOptions values.
Step<I>	Implements one durable unit of Flow logic.
StepCompletion	Contains one output-bearing Step completion returned by Client.waitForFlow(String).
StepDecision	Describes the durable action Dex takes after a Step executes.
StepDurability	Selects when Dex durably records a Step method result relative to subsequent Flow work.
StepExecutionId	Selects one execution of a Step within a Flow.
StepList<StartInput>	Declares a Flow's ordered collection of registered Steps.
StepMovement<I>	Describes one transition to a typed Step and its input.
StepOptions	Configures timeout, retry, durability, locking, and failure behavior for a Step.
StepOptions.Builder	Builds immutable StepOptions values.
StopFlowOptions	Configures how Client.stopFlow(String) ends a running Flow.
StopType	Selects how Client.stopFlow(String) ends a running Flow.
Stream<T>	Defines a typed best-effort resumable message Stream owned by one Flow type.
StreamMessage<T>	Describes one retained Stream message returned by Stream Client reads.
StreamMessagesPage<T>	Contains one newest-first page returned by Client.listStreamMessages(String, Stream, int, String).
SubFlow	Creates durable SubFlow conditions and reads their results during Step execution.
SubFlowOptions	Configures one durable SubFlow condition.
SubFlowOptions.Builder	Builds immutable SubFlow options.
SubFlowReusePolicy	Controls how a SubFlow condition resolves an execution that already uses its generated Flow ID.
Timer	Creates server-side durable timer conditions for Step waits.
TimerId	Selects a timer condition within one Step execution.
TimeTravelOptions	Selects a historical point and replay behavior for Client.timeTravel(String, TimeTravelOptions).
TimeTravelOptions.Builder	Builds immutable TimeTravelOptions values.
TimeTravelStepMethod	Selects the Step method used as a TimeTravelType.STEP_EXECUTION_ID boundary.
TimeTravelType	Selects the historical point from which a Flow resumes in a new run.
Wait	Describes when Dex may invoke a Step's execute method.
WaitForAttributeOptions	Configures one durable Attribute match wait.
WaitForAttributeOptions.Builder	Builds immutable Attribute wait options.
WaitForFailurePolicy	Controls what happens after a Step's wait-for method exhausts its retry policy.
WaitForStepCompletionOptions	Configures one durable Step completion wait.
WaitForStepCompletionOptions.Builder	Builds immutable Step completion wait options.
Worker	Hosts synchronous Java Step and RPC implementations for registered Flows.
WorkerOptions	Configures a Java Worker's outbound polling, connection, and serialization.
WorkerOptions.Builder	Builds immutable WorkerOptions values.