Index

A B C D E F G H I K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

activeStepSearchMode(ActiveStepSearchMode) - Method in class io.superdurable.dex.FlowConfig.Builder

Sets how precisely Dex indexes active Step types for later searches.

ActiveStepSearchMode - Enum Class in io.superdurable.dex

Controls which active Step types Dex records in the ActiveStepTypes search index.

addAttribute(Attribute, T) - Method in class io.superdurable.dex.StartFlowOptions.Builder

Adds an initial Attribute value atomically with Flow start.

addAttribute(Attribute, T) - Method in class io.superdurable.dex.SubFlowOptions.Builder

Adds one initial static Attribute value to the SubFlow start.

addAttribute(AttributeMap, String, T) - Method in class io.superdurable.dex.StartFlowOptions.Builder

Adds an initial Attribute-map value atomically with Flow start.

addAttribute(AttributeMap, String, T) - Method in class io.superdurable.dex.SubFlowOptions.Builder

Adds one initial Attribute-map value to the SubFlow start.

addExecuteLoadAttributeMap(AttributeMap) - Method in class io.superdurable.dex.StepOptions.Builder

Loads every current instance of an AttributeMap for Execute.

addExecuteLoadAttributeMapInstance(AttributeMap, String) - Method in class io.superdurable.dex.StepOptions.Builder

Loads one AttributeMap instance for Execute.

addExecuteLoadChannel(Channel) - Method in class io.superdurable.dex.StepOptions.Builder

Loads pending messages from one Channel for Execute.

addExecuteLoadChannelMap(ChannelMap) - Method in class io.superdurable.dex.StepOptions.Builder

Loads pending messages from every current ChannelMap instance for Execute.

addExecuteLoadChannelMapInstance(ChannelMap, String) - Method in class io.superdurable.dex.StepOptions.Builder

Loads pending messages from one ChannelMap instance for Execute.

addExecuteLock(AttributeLock) - Method in class io.superdurable.dex.StepOptions.Builder

Adds an Attribute lock held while the execute method runs.

addLoadAttributeMap(AttributeMap) - Method in class io.superdurable.dex.FlowTimeoutHandlerOptions.Builder

Loads every current instance of an AttributeMap.

addLoadAttributeMapInstance(AttributeMap, String) - Method in class io.superdurable.dex.FlowTimeoutHandlerOptions.Builder

Loads one AttributeMap instance.

addLoadAttributeMapInstance(AttributeMap, String) - Method in class io.superdurable.dex.RPCInvokeOptions.Builder

Adds an exact Attribute-map instance load for one RPC invocation.

addLoadChannel(Channel) - Method in class io.superdurable.dex.FlowTimeoutHandlerOptions.Builder

Loads pending messages from one Channel.

addLoadChannelMap(ChannelMap) - Method in class io.superdurable.dex.FlowTimeoutHandlerOptions.Builder

Loads pending messages from every current ChannelMap instance.

addLoadChannelMapInstance(ChannelMap, String) - Method in class io.superdurable.dex.FlowTimeoutHandlerOptions.Builder

Loads pending messages from one ChannelMap instance.

addLoadChannelMapInstance(ChannelMap, String) - Method in class io.superdurable.dex.RPCInvokeOptions.Builder

Adds an exact Channel-map instance load for one RPC invocation.

addLock(AttributeLock) - Method in class io.superdurable.dex.FlowTimeoutHandlerOptions.Builder

Adds an Attribute lock held for the handler invocation.

addLockAttributeMapInstance(AttributeMap, String) - Method in class io.superdurable.dex.RPCInvokeOptions.Builder

Adds an invocation-time lock for one Attribute-map instance.

addWaitForLoadAttributeMap(AttributeMap) - Method in class io.superdurable.dex.StepOptions.Builder

Loads every current instance of an AttributeMap for WaitFor.

addWaitForLoadAttributeMapInstance(AttributeMap, String) - Method in class io.superdurable.dex.StepOptions.Builder

Loads one AttributeMap instance for WaitFor.

addWaitForLoadChannel(Channel) - Method in class io.superdurable.dex.StepOptions.Builder

Loads pending messages from one Channel for WaitFor.

addWaitForLoadChannelMap(ChannelMap) - Method in class io.superdurable.dex.StepOptions.Builder

Loads pending messages from every current instance of a ChannelMap for WaitFor.

addWaitForLoadChannelMapInstance(ChannelMap, String) - Method in class io.superdurable.dex.StepOptions.Builder

Loads pending messages from one ChannelMap instance for WaitFor.

addWaitForLock(AttributeLock) - Method in class io.superdurable.dex.StepOptions.Builder

Adds an Attribute lock held while the wait-for method runs.

after(Duration, Throwable) - Static method in exception class io.superdurable.dex.exceptions.RetryAfterException

Creates a retry request while preserving the current attempt failure.

ALL - Enum constant in enum class io.superdurable.dex.ActiveStepSearchMode

Indexes every active Step type, including Steps that execute without waitFor.

allOf(Condition...) - Static method in class io.superdurable.dex.Wait

Waits until every supplied condition is satisfied.

ALLOW_IF_NOT_RUNNING - Enum constant in enum class io.superdurable.dex.IdReusePolicy

Allows reuse when no execution with the ID is currently running.

ALLOW_IF_PREVIOUS_FAILED - Enum constant in enum class io.superdurable.dex.IdReusePolicy

Allows reuse only when the previous execution ended abnormally.

ALWAYS_RESTART - Enum constant in enum class io.superdurable.dex.SubFlowReusePolicy

Starts a new execution and terminates an existing running execution.

anyCombinationOf(ConditionCombination...) - Static method in class io.superdurable.dex.Wait

Waits until every condition in any one supplied combination is satisfied.

anyOf(Condition...) - Static method in class io.superdurable.dex.Wait

Waits until any supplied condition is satisfied.

ApiKeyCredential - Class in io.superdurable.dex

Exchanges a long-lived API key for short-lived Dex bearer tokens.

ApiKeyCredential.Builder - Class in io.superdurable.dex

Configures the timeout and HTTP transport for an API key credential.

ApiKeyCredential.ExchangeException - Exception Class in io.superdurable.dex

Reports a token endpoint, response, transport, or timeout failure.

ApiKeyCredential.HttpConnectionFactory - Interface in io.superdurable.dex

Opens the HTTP connection used for an API key exchange.

appWorkerID(String) - Method in class io.superdurable.dex.PullWorkerOptions.Builder

Sets the process identity used for sticky task routing.

ASYNC - Enum constant in enum class io.superdurable.dex.StepDurability

Allows Dex to advance before the completed method result is durably recorded.

atLeast(int) - Method in class io.superdurable.dex.Channel

Creates a condition requiring at least count messages.

atLeast(int, String) - Method in class io.superdurable.dex.Channel

Creates a named condition requiring at least count messages.

atLeast(String, int) - Method in class io.superdurable.dex.ChannelMap

Creates a condition requiring at least count messages from an instance.

atLeast(String, int, String) - Method in class io.superdurable.dex.ChannelMap

Creates a named condition requiring at least count messages from an instance.

atMost(int) - Method in class io.superdurable.dex.Channel

Creates a non-blocking condition consuming up to count queued messages.

atMost(int, String) - Method in class io.superdurable.dex.Channel

Creates a named, non-blocking condition consuming up to count queued messages.

atMost(String, int) - Method in class io.superdurable.dex.ChannelMap

Creates a non-blocking condition consuming up to count queued messages from an instance.

atMost(String, int, String) - Method in class io.superdurable.dex.ChannelMap

Creates a named, non-blocking condition consuming up to count queued messages from an instance.

ATTACH - Enum constant in enum class io.superdurable.dex.SubFlowReusePolicy

Attaches to a running execution or returns any existing terminal result.

attribute() - Element in annotation interface io.superdurable.dex.RPCAttributeMapLock

Names the registered Attribute map.

Attribute<T> - Class in io.superdurable.dex

Defines one durable, typed value stored with a Flow execution.

AttributeIndex - Class in io.superdurable.dex

Describes how an Attribute is indexed for Flow search.

AttributeIndex(AttributeIndex.Type) - Constructor for class io.superdurable.dex.AttributeIndex

Creates an index using the Attribute name as its search key.

AttributeIndex(AttributeIndex.Type, String) - Constructor for class io.superdurable.dex.AttributeIndex

Creates an index with an explicit physical index key.

AttributeIndex.Type - Enum Class in io.superdurable.dex

Defines the value representation used by the search backend.

attributeIndexSyncTimeout(Duration) - Method in class io.superdurable.dex.WorkerOptions.Builder

Sets the maximum duration for startup index synchronization.

AttributeLock - Class in io.superdurable.dex

Defines one Attribute lock for a Step's waitFor or execute method.

AttributeMap<T> - Class in io.superdurable.dex

Defines a durable map of named, typed Attribute instances.

AttributeMapNotLoadedException - Exception Class in io.superdurable.dex.exceptions

Indicates that an RPC did not load the requested AttributeMap entries.

AttributeMapNotLoadedException(String) - Constructor for exception class io.superdurable.dex.exceptions.AttributeMapNotLoadedException

Creates an exception with an actionable missing-load message.

AttributeMatch<T> - Class in io.superdurable.dex

Describes a scalar Attribute predicate.

attributeStoreNames(String...) - Method in class io.superdurable.dex.FlowConfig.Builder

Selects Server-configured Attribute Stores for enabled Attribute writes.

attributeStoreNames(List) - Method in class io.superdurable.dex.FlowConfig.Builder

Selects Server-configured Attribute Stores for enabled Attribute writes.

B

backoffCoefficient(double) - Method in class io.superdurable.dex.RetryPolicy.Builder

Sets the multiplier applied to each successive retry interval.

BEGINNING - Enum constant in enum class io.superdurable.dex.TimeTravelType

Resumes at the beginning of the Flow execution.

BlobCache - Interface in io.superdurable.dex

Caches immutable, server-addressed blob payloads on local disk.

BlobCacheConfig - Class in io.superdurable.dex

Configures the disk-backed BlobCache.

BlobCacheConfig(String, long) - Constructor for class io.superdurable.dex.BlobCacheConfig

Creates a configuration with 10,000 frequency counters.

BlobCacheConfig(String, long, long) - Constructor for class io.superdurable.dex.BlobCacheConfig

Creates a configuration with an explicit admission-sketch size.

BOOL - Enum constant in enum class io.superdurable.dex.AttributeIndex.Type

Indexes a boolean value.

BufferedTextStream - Class in io.superdurable.dex

Batches text chunks into best-effort Stream messages during one Step invocation.

build() - Method in class io.superdurable.dex.ApiKeyCredential.Builder

Builds the thread-safe credential without contacting the token endpoint.

build() - Method in class io.superdurable.dex.ClientOptions.Builder

Builds immutable options for a Client.

build() - Method in class io.superdurable.dex.FlowConfig.Builder

Builds immutable Flow configuration from the current values.

build() - Method in class io.superdurable.dex.FlowTimeoutHandlerOptions.Builder

Builds immutable timeout-handler options.

build() - Method in class io.superdurable.dex.GrpcErrorStatusMapping.Builder

Builds an immutable mapping from the current entries.

build() - Method in class io.superdurable.dex.PullWorkerOptions.Builder

Builds pull options for a Worker.

build() - Method in class io.superdurable.dex.RetryPolicy.Builder

Builds an immutable retry policy from the current values.

build() - Method in class io.superdurable.dex.RPCInvokeOptions.Builder

Creates immutable invocation options.

build() - Method in class io.superdurable.dex.SearchFlowsOptions.Builder

Builds options.

build() - Method in class io.superdurable.dex.StartFlowOptions.Builder

Builds immutable start options from the current values.

build() - Method in class io.superdurable.dex.StepOptions.Builder

Builds immutable Step options from the current values.

build() - Method in class io.superdurable.dex.SubFlowOptions.Builder

Builds immutable options.

build() - Method in class io.superdurable.dex.TimeTravelOptions.Builder

Builds immutable time travel options from the current values.

build() - Method in class io.superdurable.dex.WaitForAttributeOptions.Builder

Builds the options.

build() - Method in class io.superdurable.dex.WaitForStepCompletionOptions.Builder

Builds the options.

build() - Method in class io.superdurable.dex.WorkerOptions.Builder

Builds immutable worker options from the current values.

builder(URI, String, String) - Static method in class io.superdurable.dex.ApiKeyCredential

Begins configuring an API key exchange without contacting the token endpoint.

byConditionId(String) - Static method in class io.superdurable.dex.TimerId

Selects a timer by its user-defined condition ID.

byConditionIndex(int) - Static method in class io.superdurable.dex.TimerId

Selects a timer by its condition index.

byDuration(Duration) - Static method in class io.superdurable.dex.Timer

Creates a server-side durable timer condition without a condition ID.

byDuration(Duration, String) - Static method in class io.superdurable.dex.Timer

Creates a server-side durable timer condition with a stable condition ID.

C

CANCEL - Enum constant in enum class io.superdurable.dex.FlowTimeoutPolicy

Cancels the Flow without retrying it.

CANCEL - Enum constant in enum class io.superdurable.dex.StopType

Requests cooperative cancellation.

CANCELED - Enum constant in enum class io.superdurable.dex.FlowStatus

The Flow was canceled.

cancelStepOutput() - Method in class io.superdurable.dex.BufferedTextStream

Discards buffered text and stops the timer after invocation cancellation.

Channel<T> - Class in io.superdurable.dex

Defines one durable, typed message Channel for a Flow.

CHANNEL_MESSAGE_NOT_FOUND - Enum constant in enum class io.superdurable.dex.exceptions.ErrorSubStatus

Indicates that a pending Channel message ID no longer exists.

ChannelMap<T> - Class in io.superdurable.dex

Defines a durable map of named, typed Channel instances.

ChannelMessage<T> - Class in io.superdurable.dex

Identifies one typed value that is still pending in a Channel.

ChannelMessageNotFoundException - Exception Class in io.superdurable.dex.exceptions

Thrown when a requested Channel message is no longer pending.

ChannelMessageNotFoundException(Status.Code, String, Throwable) - Constructor for exception class io.superdurable.dex.exceptions.ChannelMessageNotFoundException

Creates the exception from Dex service status metadata.

ChannelMessagesNotLoadedException - Exception Class in io.superdurable.dex.exceptions

Indicates that an RPC did not load the requested pending Channel messages.

ChannelMessagesNotLoadedException(String) - Constructor for exception class io.superdurable.dex.exceptions.ChannelMessagesNotLoadedException

Creates an exception with an actionable missing-load message.

channelResults(Channel) - Method in interface io.superdurable.dex.Context

Returns condition results for a Channel.

channelResults(ChannelMap, String) - Method in interface io.superdurable.dex.Context

Returns condition results for one Channel-map instance.

channelSize(Channel) - Method in interface io.superdurable.dex.Context

Returns the visible message count for a Channel.

channelSize(ChannelMap, String) - Method in interface io.superdurable.dex.Context

Returns the visible message count for one Channel-map instance.

Client - Class in io.superdurable.dex

Provides synchronous, strongly typed operations for starting and controlling Dex Flows.

Client(Registry, BlobCache) - Constructor for class io.superdurable.dex.Client

Creates a client using local development defaults.

Client(Registry, BlobCache, ClientOptions) - Constructor for class io.superdurable.dex.Client

Creates a client with explicit connection, routing, and serialization options.

CLIENT_API_FAILED - Enum constant in enum class io.superdurable.dex.FlowErrorType

A client API operation caused the Flow to fail.

ClientOptions - Class in io.superdurable.dex

Configures a synchronous Client connection and value mapper.

ClientOptions() - Constructor for class io.superdurable.dex.ClientOptions

Creates options for localhost:8801 with the default Jackson mapper.

ClientOptions(String) - Constructor for class io.superdurable.dex.ClientOptions

Creates options for a Dex server with default worker routing and serialization.

ClientOptions(String, ObjectMapper) - Constructor for class io.superdurable.dex.ClientOptions

Creates options with explicit transport and serialization settings.

ClientOptions.Builder - Class in io.superdurable.dex

Builds immutable Client options.

close() - Method in class io.superdurable.dex.ApiKeyCredential

Cancels an exchange and interrupts its daemon thread.

close() - Method in interface io.superdurable.dex.BlobCache

Flushes pending cache work and releases native resources.

close() - Method in class io.superdurable.dex.Client

Shuts down the client's gRPC channel.

close() - Method in class io.superdurable.dex.Worker

Stops the worker and permanently closes its lifecycle.

COMPLETED - Enum constant in enum class io.superdurable.dex.FlowStatus

The Flow completed successfully.

Condition - Class in io.superdurable.dex

Represents one Timer, Channel, or SubFlow condition used by a Wait.

ConditionCombination - Class in io.superdurable.dex

Groups conditions that must all be satisfied as one alternative in a combined wait.

conditionId(String) - Method in class io.superdurable.dex.SubFlowOptions.Builder

Sets the condition ID required by Wait.anyCombinationOf(ConditionCombination...).

configOverride(FlowConfig) - Method in class io.superdurable.dex.StartFlowOptions.Builder

Overrides Flow configuration for the new execution.

configOverride(FlowConfig) - Method in class io.superdurable.dex.SubFlowOptions.Builder

Overrides fields in the parent Flow's effective configuration for the SubFlow.

Context - Interface in io.superdurable.dex

Exposes invocation metadata and durable state operations to Step and RPC code.

continueAsNewPageSizeBytes(int) - Method in class io.superdurable.dex.FlowConfig.Builder

Sets the history page-size threshold that triggers continue-as-new.

continueAsNewThreshold(int) - Method in class io.superdurable.dex.FlowConfig.Builder

Sets the history-event threshold that triggers continue-as-new.

CONTINUED_AS_NEW - Enum constant in enum class io.superdurable.dex.FlowStatus

The Flow continued as a new execution.

create(Context, Stream) - Static method in class io.superdurable.dex.BufferedTextStream

Creates a writer with a one-second interval and 16 KiB soft threshold.

create(Context, Stream, Duration, int) - Static method in class io.superdurable.dex.BufferedTextStream

Creates a writer with explicit buffering settings.

credential(Credential) - Method in class io.superdurable.dex.ClientOptions.Builder

Sets the token source for every Client FlowService call.

credential(Credential) - Method in class io.superdurable.dex.WorkerOptions.Builder

Sets the token source for Worker FlowService calls and pull stream opens.

Credential - Interface in io.superdurable.dex

Supplies a bearer token before each Client or Worker service call.

D

DATETIME - Enum constant in enum class io.superdurable.dex.AttributeIndex.Type

Indexes a date-and-time value.

deadEnd() - Static method in class io.superdurable.dex.StepDecision

Leaves this execution with no next Step and without completing the Flow.

DEFAULT - Enum constant in enum class io.superdurable.dex.ActiveStepSearchMode

Uses the server default, which indexes active Steps whose waitFor method is used.

DEFAULT - Enum constant in enum class io.superdurable.dex.FlowTimeoutPolicy

Uses Flow.handleTimeout(Context) when overridden, and FlowTimeoutPolicy.FAIL otherwise.

DEFAULT - Enum constant in enum class io.superdurable.dex.IdReusePolicy

Uses the Dex server default, which rejects every previously used Flow ID.

DEFAULT - Enum constant in enum class io.superdurable.dex.StepDurability

Uses the applicable Flow configuration or the synchronous server default.

DEFAULT_FLUSH_INTERVAL - Static variable in class io.superdurable.dex.BufferedTextStream

Default one-shot flush interval.

DEFAULT_MAX_BUFFERED_BYTES - Static variable in class io.superdurable.dex.BufferedTextStream

Default soft UTF-8 batch threshold.

define(String, Class) - Static method in class io.superdurable.dex.Attribute

Defines an Attribute without a search index.

define(String, Class) - Static method in class io.superdurable.dex.AttributeMap

Defines an Attribute map without a search index.

define(String, Class) - Static method in class io.superdurable.dex.Channel

Defines a typed Channel.

define(String, Class) - Static method in class io.superdurable.dex.ChannelMap

Defines a typed Channel map.

define(String, Class, long) - Static method in class io.superdurable.dex.Stream

Creates a typed Stream definition.

define(String, Class, AttributeIndex) - Static method in class io.superdurable.dex.Attribute

Defines an Attribute with a search index.

define(String, Class, AttributeIndex) - Static method in class io.superdurable.dex.AttributeMap

Defines an Attribute map with a search index.

delete(Context) - Method in class io.superdurable.dex.Attribute

Deletes this Attribute in the current invocation.

delete(Context, String) - Method in class io.superdurable.dex.AttributeMap

Deletes one map instance in the current invocation.

delete(Context, String) - Method in class io.superdurable.dex.Channel

Stages deletion of one pending message from a Step, timeout handler, or RPC.

delete(Context, String, String) - Method in class io.superdurable.dex.ChannelMap

Stages deletion of one pending message from a Channel-map instance.

delete(String) - Method in interface io.superdurable.dex.BlobCache

Deletes one cached blob if present.

deleteAll() - Method in interface io.superdurable.dex.BlobCache

Deletes all entries managed by this cache.

deleteAttribute(Attribute) - Method in interface io.superdurable.dex.Context

Deletes an Attribute.

deleteAttribute(AttributeMap, String) - Method in interface io.superdurable.dex.Context

Deletes one Attribute-map instance.

deleteChannelMessage(Channel, String) - Method in interface io.superdurable.dex.Context

Stages deletion of one pending singleton Channel message from an RPC.

deleteChannelMessage(ChannelMap, String, String) - Method in interface io.superdurable.dex.Context

Stages deletion of one pending Channel-map message from an RPC.

describeFlow(String) - Method in class io.superdurable.dex.Client

Returns a FlowInfo summary of the current Flow run.

DexServiceException - Exception Class in io.superdurable.dex.exceptions

Reports a Dex API failure translated from a gRPC response.

DexServiceException(Status.Code, ErrorSubStatus, String, Throwable) - Constructor for exception class io.superdurable.dex.exceptions.DexServiceException

Creates a service exception with transport and Dex-specific status metadata.

DISABLED - Enum constant in enum class io.superdurable.dex.ActiveStepSearchMode

Does not index active Step types, so active-Step searches cannot find this Flow.

DISALLOW - Enum constant in enum class io.superdurable.dex.IdReusePolicy

Rejects every attempt to reuse the Flow ID.

DOUBLE - Enum constant in enum class io.superdurable.dex.AttributeIndex.Type

Indexes a floating-point value.

durability(StepDurability) - Method in class io.superdurable.dex.FlowTimeoutHandlerOptions.Builder

Overrides durability for timeout-handler side effects.

E

empty() - Static method in class io.superdurable.dex.StepList

Creates an empty Step list for a Flow with no Steps.

equalTo(T) - Static method in class io.superdurable.dex.AttributeMatch

Creates an equality match.

ErrorSubStatus - Enum Class in io.superdurable.dex.exceptions

Identifies a Dex-specific category within a transport error.

exchangeTimeout(Duration) - Method in class io.superdurable.dex.ApiKeyCredential.Builder

Sets the maximum duration for one exchange, including connection and response.

execute(Context) - Method in interface io.superdurable.dex.RpcDefinitions.RpcFunc0

Executes the RPC implementation on the worker.

execute(Context) - Method in interface io.superdurable.dex.RpcDefinitions.RpcProc0

Executes the RPC implementation on the worker.

execute(Context, I) - Method in interface io.superdurable.dex.RpcDefinitions.RpcFunc1

Executes the RPC implementation on the worker.

execute(Context, I) - Method in interface io.superdurable.dex.RpcDefinitions.RpcProc1

Executes the RPC implementation on the worker.

execute(Context, I) - Method in interface io.superdurable.dex.Step

Executes the Step's application logic and returns its durable decision.

EXECUTE - Enum constant in enum class io.superdurable.dex.TimeTravelStepMethod

Resumes before the selected Step execution's Execute method.

executeDurability(StepDurability) - Method in class io.superdurable.dex.StepOptions.Builder

Overrides durability for this Step's execute method result.

executeMethodTimeout(Duration) - Method in class io.superdurable.dex.StepOptions.Builder

Sets the maximum duration of one execute method attempt.

executeRetry(RetryPolicy) - Method in class io.superdurable.dex.StepOptions.Builder

Sets the retry policy for execute method failures.

F

FAIL - Enum constant in enum class io.superdurable.dex.FlowTimeoutPolicy

Fails the Flow with FlowErrorType.FLOW_TIMEOUT and permits Flow retries.

FAIL - Enum constant in enum class io.superdurable.dex.StopType

Ends the Flow as failed.

FAIL_FLOW - Enum constant in enum class io.superdurable.dex.WaitForFailurePolicy

Fails the Flow when the wait-for method cannot complete.

FAILED - Enum constant in enum class io.superdurable.dex.FlowStatus

The Flow failed.

FileCredential - Class in io.superdurable.dex

Reads a bearer token from a file and picks up rotations without a restart.

FileCredential(String) - Constructor for class io.superdurable.dex.FileCredential

Reads the initial token from a file path.

FileCredential(Path) - Constructor for class io.superdurable.dex.FileCredential

Reads the initial token from a file.

finalizeStepOutput() - Method in class io.superdurable.dex.BufferedTextStream

Flushes the tail and closes this writer during invocation finalization.

findPendingMessage(Context, String) - Method in class io.superdurable.dex.Channel

Finds one pending message in the loaded handler snapshot.

findPendingMessage(Context, String, String) - Method in class io.superdurable.dex.ChannelMap

Finds one instance message in the loaded handler snapshot.

Flow<StartInput> - Interface in io.superdurable.dex

Defines the Steps, persistence, and RPC surface of one Flow type.

FLOW_ALREADY_STARTED - Enum constant in enum class io.superdurable.dex.exceptions.ErrorSubStatus

Indicates that the requested Flow ID is already in use.

FLOW_CLOSING - Enum constant in enum class io.superdurable.dex.exceptions.ErrorSubStatus

Indicates that Dex rejected an update-class request during Flow close cleanup.

FLOW_NOT_EXISTS - Enum constant in enum class io.superdurable.dex.exceptions.ErrorSubStatus

Indicates that the requested Flow execution does not exist.

FLOW_TIMEOUT - Enum constant in enum class io.superdurable.dex.FlowErrorType

A Dex soft Flow timeout expired under FlowTimeoutPolicy.FAIL.

FlowAlreadyStartedException - Exception Class in io.superdurable.dex.exceptions

Reports that a Flow start request conflicts with an existing Flow ID.

FlowAlreadyStartedException(Status.Code, String, Throwable) - Constructor for exception class io.superdurable.dex.exceptions.FlowAlreadyStartedException

Creates a duplicate-Flow exception from a Dex service response.

FlowClosingException - Exception Class in io.superdurable.dex.exceptions

Reports a request rejected while Dex closes a Flow.

FlowClosingException(Status.Code, String, Throwable) - Constructor for exception class io.superdurable.dex.exceptions.FlowClosingException

Creates a Flow-closing exception from a Dex service response.

FlowConfig - Class in io.superdurable.dex

Configures server behavior for one Flow execution.

FlowConfig.Builder - Class in io.superdurable.dex

Builds immutable FlowConfig values.

FlowDefinitionException - Exception Class in io.superdurable.dex.exceptions

Reports an invalid local Flow, Step, persistence, or RPC definition.

FlowDefinitionException(String) - Constructor for exception class io.superdurable.dex.exceptions.FlowDefinitionException

Creates a definition failure without an underlying cause.

FlowDefinitionException(String, Throwable) - Constructor for exception class io.superdurable.dex.exceptions.FlowDefinitionException

Creates a definition failure caused by reflection or mapping work.

FlowErrorType - Enum Class in io.superdurable.dex

Classifies why a Flow reached a terminal status other than FlowStatus.COMPLETED.

FlowInfo - Class in io.superdurable.dex

Describes the identity and current status of one Flow execution.

FlowNotActiveOrNotFoundException - Exception Class in io.superdurable.dex.exceptions

Reports a missing Flow or an operation that cannot use a closed Flow.

FlowNotActiveOrNotFoundException(Status.Code, String, Throwable) - Constructor for exception class io.superdurable.dex.exceptions.FlowNotActiveOrNotFoundException

Creates a missing-or-inactive-Flow exception from a Dex service response.

FlowNotFoundException - Exception Class in io.superdurable.dex.exceptions

Reports that a read or history operation cannot find a matching Flow execution.

FlowNotFoundException(Status.Code, String, Throwable) - Constructor for exception class io.superdurable.dex.exceptions.FlowNotFoundException

Creates a missing-Flow exception from a Dex service response.

FlowResult - Class in io.superdurable.dex

Describes the observed state and output of a Flow used as a SubFlow or waited on by a client.

FlowStatus - Enum Class in io.superdurable.dex

Represents the lifecycle status of a Flow execution.

FlowTimeoutHandlerOptions - Class in io.superdurable.dex

Configures one Flow timeout handler's Execute semantics and state snapshot.

FlowTimeoutHandlerOptions.Builder - Class in io.superdurable.dex

Builds immutable FlowTimeoutHandlerOptions values.

FlowTimeoutPolicy - Enum Class in io.superdurable.dex

Controls how Dex responds when a positive soft Flow timeout expires.

forceComplete() - Static method in class io.superdurable.dex.StepDecision

Immediately completes the Flow without an output value.

forceComplete(Object) - Static method in class io.superdurable.dex.StepDecision

Immediately completes the Flow with an output value.

forceCompleteIfChannelsEmpty(Object, StepMovement, Object...) - Static method in class io.superdurable.dex.StepDecision

Completes when all selected Channels are empty, otherwise schedules a fallback movement.

forceFail(String) - Static method in class io.superdurable.dex.StepDecision

Fails the Flow with an application-provided reason.

forN(int) - Method in class io.superdurable.dex.Channel

Creates a condition requiring exactly count messages.

forN(int, String) - Method in class io.superdurable.dex.Channel

Creates a named condition requiring exactly count messages.

forN(String, int) - Method in class io.superdurable.dex.ChannelMap

Creates a condition requiring exactly count messages from an instance.

forN(String, int, String) - Method in class io.superdurable.dex.ChannelMap

Creates a named condition requiring exactly count messages from an instance.

forOne() - Method in class io.superdurable.dex.Channel

Creates a condition requiring exactly one message.

forOne(String) - Method in class io.superdurable.dex.Channel

Creates a named condition requiring exactly one message.

forOne(String) - Method in class io.superdurable.dex.ChannelMap

Creates a condition requiring exactly one message from an instance.

forOne(String, String) - Method in class io.superdurable.dex.ChannelMap

Creates a named condition requiring exactly one message from an instance.

FULL_TEXT - Enum constant in enum class io.superdurable.dex.AttributeIndex.Type

Indexes analyzed text for full-text search queries.

G

get(Context) - Method in class io.superdurable.dex.Attribute

Reads this Attribute from the current invocation.

get(Context, String) - Method in class io.superdurable.dex.AttributeMap

Reads one map instance from the current invocation.

get(String) - Method in interface io.superdurable.dex.BlobCache

Reads and validates one cached blob.

getAllInstanceKeys(Context) - Method in class io.superdurable.dex.AttributeMap

Returns existing instance keys in ascending order, including buffered writes.

getAllInstanceKeys(Context) - Method in class io.superdurable.dex.ChannelMap

Returns non-empty instance keys in ascending order for the current RPC.

getAttempt() - Method in interface io.superdurable.dex.Context

Returns the one-based attempt number of the current method invocation.

getAttribute(Attribute) - Method in interface io.superdurable.dex.Context

Reads an Attribute.

getAttribute(AttributeMap, String) - Method in interface io.superdurable.dex.Context

Reads one Attribute-map instance.

getClosedAt() - Method in class io.superdurable.dex.SearchFlowEntry

Returns when this Flow execution closed.

getCode() - Method in exception class io.superdurable.dex.exceptions.DexServiceException

Returns the standard gRPC status code.

getCompletions() - Method in class io.superdurable.dex.FlowResult

Returns every output-bearing Step completion in server collection order.

getConditionResults(Context) - Method in class io.superdurable.dex.Channel

Returns messages consumed by this Channel's satisfied condition.

getConditionResults(Context) - Static method in class io.superdurable.dex.SubFlow

Returns the first SubFlow condition result from this Step invocation.

getConditionResults(Context, int) - Static method in class io.superdurable.dex.SubFlow

Returns one SubFlow condition result from this Step invocation.

getConditionResults(Context, String) - Method in class io.superdurable.dex.ChannelMap

Returns messages consumed by a satisfied condition for one map instance.

getCreatedTime() - Method in class io.superdurable.dex.StreamMessage

Returns the server-assigned creation time.

getDetail() - Method in exception class io.superdurable.dex.exceptions.DexServiceException

Returns the server-provided error detail.

getDetail() - Method in class io.superdurable.dex.RecoveryErrorInfo

Returns the failure detail supplied by the Worker or backend.

getErrorMessage() - Method in class io.superdurable.dex.FlowResult

Returns the server-provided failure detail.

getErrorType() - Method in class io.superdurable.dex.FlowResult

Returns the Dex Flow failure category.

getErrorType() - Method in class io.superdurable.dex.RecoveryErrorInfo

Returns the original Worker exception type or backend failure type.

getFirstAttemptAt() - Method in interface io.superdurable.dex.Context

Returns when the first attempt of the current method began.

getFlowId() - Method in interface io.superdurable.dex.Context

Returns the Flow ID for the current invocation.

getFlowId() - Method in exception class io.superdurable.dex.exceptions.LongPollTimeoutException

Returns the Flow ID whose long poll timed out.

getFlowId() - Method in class io.superdurable.dex.FlowInfo

Returns the application-assigned Flow ID.

getFlowId() - Method in class io.superdurable.dex.SearchFlowEntry

Returns the application-assigned Flow ID.

getFlowId(Context) - Static method in class io.superdurable.dex.SubFlow

Returns the generated Flow ID for the first SubFlow condition in this Step invocation.

getFlowId(Context, int) - Static method in class io.superdurable.dex.SubFlow

Returns the generated Flow ID for one SubFlow condition in this Step invocation.

getFlows() - Method in class io.superdurable.dex.SearchFlowsPage

Returns the Flow entries in this page.

getFlowStartedAt() - Method in interface io.superdurable.dex.Context

Returns when the current Flow execution started.

getFlowType() - Method in interface io.superdurable.dex.Flow

Returns the Flow type used to register and start this Flow.

getFlowType() - Method in class io.superdurable.dex.FlowInfo

Returns the registered Flow type.

getFlowType() - Method in class io.superdurable.dex.SearchFlowEntry

Returns the registered Flow type.

getFromStepExecutionId() - Method in interface io.superdurable.dex.Context

Returns the Step execution that scheduled the current Step.

getHttpStatus() - Method in exception class io.superdurable.dex.ApiKeyCredential.ExchangeException

Returns the token endpoint's HTTP status.

getIncludeContinuedAsNew() - Method in class io.superdurable.dex.SearchFlowsOptions

Reports inclusion.

getIndexedAttributes() - Method in class io.superdurable.dex.SearchFlowEntry

Returns decoded Indexed Attribute values for this execution.

getInputType() - Method in interface io.superdurable.dex.Step

Returns the concrete class used to decode this Step's input.

getLastHeartbeatValue(Class) - Method in interface io.superdurable.dex.Context

Decodes heartbeat details restored from an earlier attempt.

getLastPermanentError() - Method in class io.superdurable.dex.PullQueueRegistrationState

Returns the most recent permanent rejection, cleared by re-registration.

getMapSize(Context) - Method in class io.superdurable.dex.AttributeMap

Returns the number of existing instances, including writes buffered by this invocation.

getMapSize(Context) - Method in class io.superdurable.dex.ChannelMap

Returns the number of non-empty instances visible to the current RPC.

getMessageId() - Method in class io.superdurable.dex.ChannelMessage

Returns the UUIDv7 assigned by Dex when the message was published.

getMessages() - Method in class io.superdurable.dex.StreamMessagesPage

Returns retained messages in newest-first order.

getNextPageToken() - Method in class io.superdurable.dex.SearchFlowsPage

Returns the token for fetching the next page.

getNextPageToken() - Method in class io.superdurable.dex.StreamMessagesPage

Returns the token for fetching the next older page.

getOutput(Class) - Method in class io.superdurable.dex.StepCompletion

Decodes this Step output as a concrete Java class.

getPersistenceSchema() - Method in interface io.superdurable.dex.Flow

Returns the persistent Attributes and Channels used by this Flow.

getPullRegistrationState() - Method in class io.superdurable.dex.Worker

Returns an independent snapshot for pull Worker readiness probes.

getPullReservedRpcDeclines() - Method in class io.superdurable.dex.Worker

Returns cumulative Step declines caused by reserved RPC capacity for this Worker.

getQueue() - Method in class io.superdurable.dex.PullQueueRegistrationState

Returns the queue name.

getQueue() - Method in exception class io.superdurable.dex.PullRegistrationError

Returns the rejected queue name.

getQueues() - Method in class io.superdurable.dex.PullRegistrationState

Returns queue snapshots ordered by app Worker ID and then sorted Flow types.

getRecoveryError() - Method in interface io.superdurable.dex.Context

Returns the previous Step method failure that caused this recovery invocation.

getResumeToken() - Method in class io.superdurable.dex.StreamMessage

Returns the token for the next read.

getRetryAfter() - Method in exception class io.superdurable.dex.exceptions.RetryAfterException

Returns the requested delay before the next retry.

getRunId() - Method in interface io.superdurable.dex.Context

Returns the current Flow run ID.

getRunId() - Method in class io.superdurable.dex.FlowInfo

Returns the server-assigned run ID.

getRunId() - Method in class io.superdurable.dex.SearchFlowEntry

Returns the server-assigned run ID.

getSingleOutput(Class) - Method in class io.superdurable.dex.FlowResult

Decodes the output when exactly one Step completion exists.

getSource() - Method in class io.superdurable.dex.StreamMessage

Returns the producer metadata supplied when the message was appended.

getStartedAt() - Method in class io.superdurable.dex.FlowInfo

Returns when this Flow execution started.

getStartedAt() - Method in class io.superdurable.dex.SearchFlowEntry

Returns when this Flow execution started.

getStatus() - Method in class io.superdurable.dex.FlowInfo

Returns the status captured by this snapshot.

getStatus() - Method in class io.superdurable.dex.FlowResult

Returns the observed Flow status.

getStatus() - Method in class io.superdurable.dex.SearchFlowEntry

Returns the status captured by this search result.

getStepExecutionId() - Method in interface io.superdurable.dex.Context

Returns the server-assigned identifier of the current Step execution.

getStepExecutionId() - Method in class io.superdurable.dex.StepCompletion

Returns the server identity of the exact Step execution that produced this output.

getStepExecutionLocal(String, Class) - Method in interface io.superdurable.dex.Context

Reads a value scoped to the current Step execution.

getStepOptions() - Method in interface io.superdurable.dex.Step

Returns retry, timeout, durability, locking, and failure behavior for this Step.

getSteps() - Method in interface io.superdurable.dex.Flow

Returns the Flow's start Step and all other registered Steps.

getStepType() - Method in interface io.superdurable.dex.Step

Returns the Step type used to register this Step.

getStepType() - Method in class io.superdurable.dex.StepCompletion

Returns the registered Step type that produced this output.

getStreamCapacityBytes() - Method in class io.superdurable.dex.Stream

Returns the approximate shared byte budget.

getStreamName() - Method in class io.superdurable.dex.Stream

Returns the logical Stream name.

getSubStatus() - Method in exception class io.superdurable.dex.exceptions.DexServiceException

Returns the Dex-specific error category.

getValue() - Method in class io.superdurable.dex.ChannelMessage

Returns the decoded Channel value.

getValue() - Method in class io.superdurable.dex.StreamMessage

Returns the decoded application message.

getWorkerCode() - Method in exception class io.superdurable.dex.exceptions.WorkerInvocationException

Returns the original worker-side gRPC status code.

getWorkerErrorDetail() - Method in exception class io.superdurable.dex.exceptions.WorkerInvocationException

Returns the original worker exception detail.

getWorkerErrorType() - Method in exception class io.superdurable.dex.exceptions.WorkerInvocationException

Returns the original worker exception type.

getWorkerStackTrace() - Method in exception class io.superdurable.dex.exceptions.WorkerInvocationException

Returns the original worker-side stack trace.

goTo(Class, I) - Static method in class io.superdurable.dex.StepDecision

Schedules one typed next Step.

goToMany(StepMovement...) - Static method in class io.superdurable.dex.StepDecision

Schedules zero or more next-Step movements together.

gracefulComplete() - Static method in class io.superdurable.dex.StepDecision

Requests successful Flow completion after all execution branches stop, without an output.

gracefulComplete(Object) - Static method in class io.superdurable.dex.StepDecision

Requests successful Flow completion after all execution branches stop and records an output.

greaterThan(T) - Static method in class io.superdurable.dex.AttributeMatch

Creates a numeric greater-than match.

greaterThanOrEqual(T) - Static method in class io.superdurable.dex.AttributeMatch

Creates a numeric greater-than-or-equal match.

grpcErrorStatusMapping(GrpcErrorStatusMapping) - Method in class io.superdurable.dex.WorkerOptions.Builder

Sets how Worker application exceptions map to gRPC status codes.

GrpcErrorStatusMapping - Class in io.superdurable.dex

Maps Java Worker application exceptions to gRPC status codes.

GrpcErrorStatusMapping.Builder - Class in io.superdurable.dex

Builds immutable exception-to-status mappings.

H

HANDLER - Enum constant in enum class io.superdurable.dex.FlowTimeoutPolicy

Starts one logical Flow.handleTimeout(Context) execution after the durable timer completes or is skipped.

handleTimeout(Context) - Method in interface io.superdurable.dex.Flow

Handles expiration of this Flow's soft timeout.

hardDeleteOnNull() - Method in class io.superdurable.dex.Attribute

Returns a definition whose value is stored only in the Dex blob store and is permanently deleted when the Attribute is deleted or set to null.

hardDeleteOnNull() - Method in class io.superdurable.dex.AttributeMap

Returns a definition whose instance values are stored only in the Dex blob store and are permanently deleted when an instance is deleted or set to null.

hasLastHeartbeatValue() - Method in interface io.superdurable.dex.Context

Reports whether Dex restored heartbeat details from an earlier attempt.

hasRegisteredStream() - Method in class io.superdurable.dex.PullQueueRegistrationState

Reports whether a stream is currently registered for this queue.

hasTimerFired() - Method in interface io.superdurable.dex.Context

Reports whether any timer condition in the current wait has fired.

hasTimerFired(int) - Method in interface io.superdurable.dex.Context

Reports whether the timer at a specific condition index fired.

heartbeatTimeout(Duration) - Method in class io.superdurable.dex.FlowTimeoutHandlerOptions.Builder

Sets the heartbeat timeout for regular timeout-handler attempts.

heartbeatTimeout(Duration) - Method in class io.superdurable.dex.StepOptions.Builder

Sets the heartbeat timeout for regular wait-for and execute activities.

HISTORY_EVENT_TIME - Enum constant in enum class io.superdurable.dex.TimeTravelType

Resumes at a history event selected by timestamp.

historyEventTime(Instant) - Method in class io.superdurable.dex.TimeTravelOptions.Builder

Selects the latest eligible history event at or before a timestamp.

httpConnectionFactory(ApiKeyCredential.HttpConnectionFactory) - Method in class io.superdurable.dex.ApiKeyCredential.Builder

Uses a connection factory for token exchanges and proxy configuration.

I

idleStreamsPerQueue(int) - Method in class io.superdurable.dex.PullWorkerOptions.Builder

Sets the number of waiting streams maintained for each task queue.

idReusePolicy(IdReusePolicy) - Method in class io.superdurable.dex.StartFlowOptions.Builder

Sets how an existing Flow ID may be reused.

IdReusePolicy - Enum Class in io.superdurable.dex

Controls whether Client.startFlow(Flow, String, I) may reuse an existing Flow ID.

ignoreAlreadyStarted(boolean) - Method in class io.superdurable.dex.StartFlowOptions.Builder

Controls whether an already-started response is accepted.

initialInterval(Duration) - Method in class io.superdurable.dex.RetryPolicy.Builder

Sets the delay before the first retry.

instance() - Element in annotation interface io.superdurable.dex.RPCAttributeMapLock

Names the map instance to lock.

INT - Enum constant in enum class io.superdurable.dex.AttributeIndex.Type

Indexes a signed integer value.

INTERNAL - Enum constant in enum class io.superdurable.dex.FlowErrorType

Dex encountered an internal failure.

internalHandlerTimeout(Duration) - Method in class io.superdurable.dex.WaitForAttributeOptions.Builder

Bounds one internal Temporal Update handler generation.

internalHandlerTimeout(Duration) - Method in class io.superdurable.dex.WaitForStepCompletionOptions.Builder

Bounds one internal Temporal Update handler generation.

INVALID_USER_FLOW_CODE - Enum constant in enum class io.superdurable.dex.FlowErrorType

Dex rejected invalid user Flow code or an invalid definition.

InvalidStepResultException - Exception Class in io.superdurable.dex.exceptions

Reports an invalid value returned by user Step code.

InvalidStepResultException(String) - Constructor for exception class io.superdurable.dex.exceptions.InvalidStepResultException

Creates an invalid-result exception with the violated Step contract.

invokeRPC(RpcDefinitions.RpcFunc0) - Method in class io.superdurable.dex.Client

Invokes a function-style RPC without application input.

invokeRPC(RpcDefinitions.RpcFunc0, RPCInvokeOptions) - Method in class io.superdurable.dex.Client

Invokes a function-style RPC without application input and adds map-instance selections.

invokeRPC(RpcDefinitions.RpcFunc1, I) - Method in class io.superdurable.dex.Client

Invokes a function-style RPC with one input and returns its typed output.

invokeRPC(RpcDefinitions.RpcFunc1, I, RPCInvokeOptions) - Method in class io.superdurable.dex.Client

Invokes a function-style RPC with one input and runtime-selected map instances.

invokeRPC(RpcDefinitions.RpcProc0) - Method in class io.superdurable.dex.Client

Invokes a procedure-style RPC without application input.

invokeRPC(RpcDefinitions.RpcProc0, RPCInvokeOptions) - Method in class io.superdurable.dex.Client

Invokes a procedure-style RPC without input and adds map-instance selections.

invokeRPC(RpcDefinitions.RpcProc1, I) - Method in class io.superdurable.dex.Client

Invokes a procedure-style RPC with one input.

invokeRPC(RpcDefinitions.RpcProc1, I, RPCInvokeOptions) - Method in class io.superdurable.dex.Client

Invokes a procedure-style RPC with one input and runtime-selected map instances.

io.superdurable.dex - package io.superdurable.dex

io.superdurable.dex.exceptions - package io.superdurable.dex.exceptions

isCancellationRequested() - Method in interface io.superdurable.dex.Context

Reports whether Dex requested cancellation of the current Step execution.

isReady() - Method in class io.superdurable.dex.PullRegistrationState

Reports whether initial registration completed without an uncovered permanent rejection.

isTerminal() - Method in class io.superdurable.dex.FlowResult

Returns whether this result represents a terminal Flow execution.

isTransactional() - Element in annotation interface io.superdurable.dex.RPC

Requests transactional reads and writes without requiring Attribute locks.

K

KEYWORD - Enum constant in enum class io.superdurable.dex.AttributeIndex.Type

Indexes one exact string value for equality and aggregation queries.

KEYWORD_ARRAY - Enum constant in enum class io.superdurable.dex.AttributeIndex.Type

Indexes an array of exact string values.

L

lessThan(T) - Static method in class io.superdurable.dex.AttributeMatch

Creates a numeric less-than match.

lessThanOrEqual(T) - Static method in class io.superdurable.dex.AttributeMatch

Creates a numeric less-than-or-equal match.

listStreamMessages(String, Stream, int, String) - Method in class io.superdurable.dex.Client

Returns one newest-first page of retained Stream messages without waiting for writes.

loadAttributeMapInstances() - Element in annotation interface io.superdurable.dex.RPC

Selects exact AttributeMap instances included in the RPC snapshot.

loadAttributeMaps() - Element in annotation interface io.superdurable.dex.RPC

Selects AttributeMaps whose current entries are included in the RPC snapshot.

loadChannelMapInstances() - Element in annotation interface io.superdurable.dex.RPC

Selects exact ChannelMap instance messages included in the RPC snapshot.

loadChannelMaps() - Element in annotation interface io.superdurable.dex.RPC

Selects ChannelMaps whose current pending messages are included in the RPC snapshot.

loadChannels() - Element in annotation interface io.superdurable.dex.RPC

Selects Channels whose pending messages are included in the RPC snapshot.

lockAttributeMaps() - Element in annotation interface io.superdurable.dex.RPC

Selects Attribute-map instances to lock for the RPC invocation.

lockAttributes() - Element in annotation interface io.superdurable.dex.RPC

Names Attributes to lock for the RPC invocation.

LONG_POLL_TIMEOUT - Enum constant in enum class io.superdurable.dex.exceptions.ErrorSubStatus

Indicates that a long-poll operation reached its wait timeout.

LongPollTimeoutException - Exception Class in io.superdurable.dex.exceptions

Thrown when a Dex long-poll operation reaches its timeout before satisfying the requested wait.

LongPollTimeoutException(Status.Code, String, String, Throwable) - Constructor for exception class io.superdurable.dex.exceptions.LongPollTimeoutException

Creates a long-poll timeout with the target Flow identity.

M

map(Class, Status.Code) - Method in class io.superdurable.dex.GrpcErrorStatusMapping.Builder

Maps an exception class and its otherwise-unmapped subclasses to a gRPC status.

maxConcurrentTasks(int) - Method in class io.superdurable.dex.PullWorkerOptions.Builder

Sets the maximum number of concurrent Step and RPC tasks across all queues.

maximumAttempts(int) - Method in class io.superdurable.dex.RetryPolicy.Builder

Limits the total number of attempts, including the initial attempt.

maximumInterval(Duration) - Method in class io.superdurable.dex.RetryPolicy.Builder

Caps the delay between attempts.

methodTimeout(Duration) - Method in class io.superdurable.dex.FlowTimeoutHandlerOptions.Builder

Sets the maximum duration of one timeout-handler attempt.

N

name() - Element in annotation interface io.superdurable.dex.RPC

Overrides the RPC name.

newBuilder() - Static method in class io.superdurable.dex.ClientOptions

Creates a builder with local development defaults.

newBuilder() - Static method in class io.superdurable.dex.FlowConfig

Creates a builder whose unset values use server defaults.

newBuilder() - Static method in class io.superdurable.dex.FlowTimeoutHandlerOptions

Creates a builder initialized with server defaults.

newBuilder() - Static method in class io.superdurable.dex.GrpcErrorStatusMapping

Creates a builder whose unmatched exceptions resolve to Status.Code.INTERNAL.

newBuilder() - Static method in class io.superdurable.dex.PullWorkerOptions

Creates a builder with CPU-count task capacity, one idle stream per queue, and a 30-second drain.

newBuilder() - Static method in class io.superdurable.dex.RetryPolicy

Creates a builder whose unset values use server defaults.

newBuilder() - Static method in class io.superdurable.dex.RPCInvokeOptions

Creates an empty builder.

newBuilder() - Static method in class io.superdurable.dex.SearchFlowsOptions

Creates a builder.

newBuilder() - Static method in class io.superdurable.dex.StartFlowOptions

Creates a builder initialized with start defaults.

newBuilder() - Static method in class io.superdurable.dex.StepOptions

Creates a builder initialized with Dex defaults.

newBuilder() - Static method in class io.superdurable.dex.SubFlowOptions

Returns a builder initialized with SubFlow defaults.

newBuilder() - Static method in class io.superdurable.dex.WaitForAttributeOptions

Creates an empty builder.

newBuilder() - Static method in class io.superdurable.dex.WaitForStepCompletionOptions

Creates an empty builder.

newBuilder() - Static method in class io.superdurable.dex.WorkerOptions

Creates a builder initialized with local development defaults.

newBuilder(TimeTravelType) - Static method in class io.superdurable.dex.TimeTravelOptions

Creates a builder for a time travel strategy.

newRpcStub(Class, String) - Method in class io.superdurable.dex.Client

Creates a strongly typed RPC stub targeting the current run of a Flow.

newRpcStub(Class, String, String) - Method in class io.superdurable.dex.Client

Creates a strongly typed RPC stub targeting a specific Flow run.

notEqualTo(T) - Static method in class io.superdurable.dex.AttributeMatch

Creates a not-equal match.

O

objectMapper(ObjectMapper) - Method in class io.superdurable.dex.ClientOptions.Builder

Sets the Jackson mapper for application values.

objectMapper(ObjectMapper) - Method in class io.superdurable.dex.WorkerOptions.Builder

Sets the Jackson mapper used for application values.

of(Attribute) - Static method in class io.superdurable.dex.AttributeLock

Locks the value stored by an Attribute.

of(AttributeMap, String) - Static method in class io.superdurable.dex.AttributeLock

Locks one instance of an Attribute map.

of(Condition...) - Static method in class io.superdurable.dex.ConditionCombination

Creates a combination whose conditions must all be satisfied.

of(PersistenceDefinition...) - Static method in class io.superdurable.dex.PersistenceSchema

Creates a schema by classifying mixed definitions.

of(Class, I) - Static method in class io.superdurable.dex.StepMovement

Creates a movement using the target Step's default options.

of(Class, I, StepOptions) - Static method in class io.superdurable.dex.StepMovement

Creates a movement with per-execution Step options.

of(String) - Static method in class io.superdurable.dex.StepExecutionId

Selects the first execution of a Step type.

of(String, int) - Static method in class io.superdurable.dex.StepExecutionId

Selects an explicit execution number of a Step type.

of(List) - Static method in class io.superdurable.dex.PersistenceSchema

Creates a schema by classifying a mixed list of definitions.

of(List, List) - Static method in class io.superdurable.dex.PersistenceSchema

Creates a schema from separate Attribute and Channel lists.

of(List, List, List) - Static method in class io.superdurable.dex.PersistenceSchema

Creates a schema from separate Attribute, Channel, and Stream lists.

of(O) - Static method in class io.superdurable.dex.RPCResult

Creates an RPC result without next Steps.

of(O, StepMovement...) - Static method in class io.superdurable.dex.RPCResult

Creates an RPC result that also schedules next Steps.

onExecuteFailureProceedTo(Class) - Method in class io.superdurable.dex.StepOptions.Builder

Continues to a recovery Step after execute retries are exhausted.

onExecuteFailureProceedTo(Class, StepOptions) - Method in class io.superdurable.dex.StepOptions.Builder

Continues to a recovery Step with per-execution options after execute retries fail.

onFailureProceedTo(Class) - Method in class io.superdurable.dex.FlowTimeoutHandlerOptions.Builder

Routes exhausted timeout-handler failures to a registered no-input Step.

onFailureProceedTo(Class, StepOptions) - Method in class io.superdurable.dex.FlowTimeoutHandlerOptions.Builder

Routes exhausted failures to a no-input Step with execution overrides.

open(BlobCacheConfig) - Static method in interface io.superdurable.dex.BlobCache

Opens or recovers a disk-backed blob cache.

openConnection(URI) - Method in interface io.superdurable.dex.ApiKeyCredential.HttpConnectionFactory

Opens an unconnected HTTP connection to the validated token URL.

otherSteps(Step...) - Method in class io.superdurable.dex.StepList

Returns a new list with additional non-start Steps.

P

pendingChannelMessages(Channel) - Method in interface io.superdurable.dex.Context

Returns a singleton Channel's loaded pending-message snapshot in FIFO order.

pendingChannelMessages(ChannelMap, String) - Method in interface io.superdurable.dex.Context

Returns one ChannelMap instance's loaded pending-message snapshot in FIFO order.

pendingMessages(Context) - Method in class io.superdurable.dex.Channel

Returns this Channel's loaded pending-message snapshot in FIFO order.

pendingMessages(Context, String) - Method in class io.superdurable.dex.ChannelMap

Returns one instance's loaded pending-message snapshot in FIFO order.

PersistenceDefinition - Class in io.superdurable.dex

Represents a typed Attribute, Channel, or Stream definition in a PersistenceSchema.

PersistenceSchema - Class in io.superdurable.dex

Declares the Attributes, Channels, and Streams that belong to a Flow.

PROCEED - Enum constant in enum class io.superdurable.dex.WaitForFailurePolicy

Continues to the execute method after recording the wait-for failure.

publish(Channel, T) - Method in interface io.superdurable.dex.Context

Publishes one message to a Channel.

publish(ChannelMap, String, T) - Method in interface io.superdurable.dex.Context

Publishes one message to a Channel-map instance.

publish(Context, String, T) - Method in class io.superdurable.dex.ChannelMap

Publishes one message to a map instance from the current invocation.

publish(Context, T) - Method in class io.superdurable.dex.Channel

Publishes one message from the current invocation.

pull(PullWorkerOptions) - Method in class io.superdurable.dex.WorkerOptions.Builder

Configures outbound task polling capacity and lifecycle.

PullQueueRegistrationState - Class in io.superdurable.dex

Describes one queue in an immutable pull readiness snapshot.

PullRegistrationError - Exception Class in io.superdurable.dex

Identifies a permanent pull rejection leaving a queue without a registered stream.

PullRegistrationError(String, Throwable) - Constructor for exception class io.superdurable.dex.PullRegistrationError

Creates a rejection retaining its original transport cause.

PullRegistrationState - Class in io.superdurable.dex

Provides an independent, immutable snapshot of pull queue readiness.

PullWorkerOptions - Class in io.superdurable.dex

Configures a Worker that opens outbound task streams to Dex.

PullWorkerOptions.Builder - Class in io.superdurable.dex

Builds immutable outbound polling options.

put(String, byte[]) - Method in interface io.superdurable.dex.BlobCache

Offers one payload to the cache's admission policy.

R

range(Integer, Integer) - Method in class io.superdurable.dex.Channel

Creates a condition with optional minimum and maximum message counts.

range(Integer, Integer, String) - Method in class io.superdurable.dex.Channel

Creates a named condition with optional minimum and maximum message counts.

range(String, Integer, Integer) - Method in class io.superdurable.dex.ChannelMap

Creates a condition with optional message-count bounds for one instance.

range(String, Integer, Integer, String) - Method in class io.superdurable.dex.ChannelMap

Creates a named condition with optional message-count bounds for one instance.

readStream(String, Stream, String) - Method in class io.superdurable.dex.Client

Blocks for the next retained Stream message using the server default wait.

readStream(String, Stream, String, Duration) - Method in class io.superdurable.dex.Client

Blocks for the next retained Stream message with an explicit long-poll duration.

reason(String) - Method in class io.superdurable.dex.TimeTravelOptions.Builder

Records a human-readable time travel reason.

recordEvent(String, T, Class) - Method in interface io.superdurable.dex.Context

Appends a named user event to the Flow execution history.

recordHeartbeat(Object) - Method in interface io.superdurable.dex.Context

Sends a best-effort heartbeat for the current Step method or Flow timeout attempt.

RecoveryErrorInfo - Class in io.superdurable.dex

Describes the final failure that caused a Step method recovery.

Registry - Class in io.superdurable.dex

Validates and indexes the Flow definitions shared by a client or worker.

Registry(List) - Constructor for class io.superdurable.dex.Registry

Builds and validates a registry from application Flow instances.

rejectToken(String) - Method in class io.superdurable.dex.ApiKeyCredential

Discards a rejected access token only when it is still cached.

REQUEST_TIMEOUT - Enum constant in enum class io.superdurable.dex.exceptions.ErrorSubStatus

Indicates that a caller-visible request budget expired.

requestId(String) - Method in class io.superdurable.dex.StartFlowOptions.Builder

Sets an idempotency key for this start request.

requestId(String) - Method in class io.superdurable.dex.WaitForAttributeOptions.Builder

Overrides the stable Request ID derived from the Attribute condition.

requestId(String) - Method in class io.superdurable.dex.WaitForStepCompletionOptions.Builder

Overrides the stable Request ID derived from the Step execution.

requestTimeout(Duration) - Method in class io.superdurable.dex.WaitForAttributeOptions.Builder

Bounds the caller-visible request across transparent transport reattachments.

requestTimeout(Duration) - Method in class io.superdurable.dex.WaitForStepCompletionOptions.Builder

Bounds the caller-visible request across transparent transport reattachments.

RequestTimeoutException - Exception Class in io.superdurable.dex.exceptions

Thrown when a caller-defined request budget expires.

RequestTimeoutException(Status.Code, String, Throwable) - Constructor for exception class io.superdurable.dex.exceptions.RequestTimeoutException

Creates a typed request timeout.

reservedRpcTasks(Integer) - Method in class io.superdurable.dex.PullWorkerOptions.Builder

Reserves handler capacity to protect synchronous RPC latency from long-running Steps.

RESTART_IF_PREVIOUS_EXITS_ABNORMALLY - Enum constant in enum class io.superdurable.dex.SubFlowReusePolicy

Attaches to running or completed executions and restarts an abnormally closed execution.

retry(RetryPolicy) - Method in class io.superdurable.dex.FlowTimeoutHandlerOptions.Builder

Sets retry behavior for timeout-handler failures.

RetryAfterException - Exception Class in io.superdurable.dex.exceptions

Requests a specific delay before retrying a failed Step method.

retryPolicy(RetryPolicy) - Method in class io.superdurable.dex.StartFlowOptions.Builder

Sets retry behavior for abnormal Flow completion.

retryPolicy(RetryPolicy) - Method in class io.superdurable.dex.SubFlowOptions.Builder

Sets retry behavior for abnormal SubFlow completion.

RetryPolicy - Class in io.superdurable.dex

Configures exponential-backoff retries for Flow or Step operations.

RetryPolicy.Builder - Class in io.superdurable.dex

Builds immutable RetryPolicy values.

reusePolicy(SubFlowReusePolicy) - Method in class io.superdurable.dex.SubFlowOptions.Builder

Sets how an execution already using the generated Flow ID is resolved.

RPC - Annotation Interface in io.superdurable.dex

Marks a public Flow method as an RPC endpoint.

RPCAttributeMapLock - Annotation Interface in io.superdurable.dex

Selects one Attribute-map instance to lock during an RPC invocation.

RpcDefinitions - Class in io.superdurable.dex

Provides serializable functional types for strongly typed RPC method references.

RpcDefinitions.RpcFunc0<O> - Interface in io.superdurable.dex

Represents an RPC function with no application input and one output.

RpcDefinitions.RpcFunc1<I,O> - Interface in io.superdurable.dex

Represents an RPC function with one input and one output.

RpcDefinitions.RpcProc0 - Interface in io.superdurable.dex

Represents an RPC procedure with no application input or output.

RpcDefinitions.RpcProc1<I> - Interface in io.superdurable.dex

Represents an RPC procedure with one input and no output.

RPCInvokeOptions - Class in io.superdurable.dex

Adds runtime-selected Attribute-map locks and exact map-instance loads to one RPC invocation.

RPCInvokeOptions.Builder - Class in io.superdurable.dex

Builds immutable RPCInvokeOptions values.

RpcLockConflictException - Exception Class in io.superdurable.dex.exceptions

Reports that a locking RPC could not acquire its requested Attribute locks.

RpcLockConflictException(String, Throwable) - Constructor for exception class io.superdurable.dex.exceptions.RpcLockConflictException

Creates an RPC lock-conflict exception.

RPCResult<O> - Class in io.superdurable.dex

Carries a typed RPC output, optional next-Step movements, and Step type cancellation.

run(Class, I) - Static method in class io.superdurable.dex.SubFlow

Creates a SubFlow condition using default options.

run(Class, I, SubFlowOptions) - Static method in class io.superdurable.dex.SubFlow

Creates a SubFlow condition with explicit options.

RUNNING - Enum constant in enum class io.superdurable.dex.FlowStatus

The Flow execution can still make progress.

S

SearchFlowEntry - Class in io.superdurable.dex

Represents one Flow execution returned by a search query.

searchFlows(String, int) - Method in class io.superdurable.dex.Client

Searches Flow executions and returns the first page.

searchFlows(String, int, String) - Method in class io.superdurable.dex.Client

Searches Flow executions from a continuation token.

searchFlows(String, int, String, SearchFlowsOptions) - Method in class io.superdurable.dex.Client

Searches with inclusion options.

SearchFlowsOptions - Class in io.superdurable.dex

Controls inclusion of earlier Continue-as-New runs in visibility searches.

SearchFlowsOptions.Builder - Class in io.superdurable.dex

Builds immutable search options.

SearchFlowsPage - Class in io.superdurable.dex

Contains one page of Flow search results and its continuation token.

SERVER_SIDE_TIMEOUT_INTERNAL_ONLY - Enum constant in enum class io.superdurable.dex.FlowStatus

Reserved for backend hard-timeout reporting.

serverAddress(String) - Method in class io.superdurable.dex.ClientOptions.Builder

Sets the Dex gRPC server target.

serverAddress(String) - Method in class io.superdurable.dex.WorkerOptions.Builder

Sets the Dex Server gRPC target used for outbound task streams and API calls.

set(Context, String, T) - Method in class io.superdurable.dex.AttributeMap

Writes one map instance in the current invocation.

set(Context, T) - Method in class io.superdurable.dex.Attribute

Writes this Attribute in the current invocation.

setAttribute(Attribute, T) - Method in interface io.superdurable.dex.Context

Writes an Attribute.

setAttribute(AttributeMap, String, T) - Method in interface io.superdurable.dex.Context

Writes one Attribute-map instance.

setIncludeContinuedAsNew(boolean) - Method in class io.superdurable.dex.SearchFlowsOptions.Builder

Sets whether to include earlier Continue-as-New runs.

setStepExecutionLocal(String, T, Class) - Method in interface io.superdurable.dex.Context

Stores a value scoped to the current Step execution.

size(Context) - Method in class io.superdurable.dex.Channel

Returns the number of messages currently visible to this invocation.

size(Context, String) - Method in class io.superdurable.dex.ChannelMap

Returns the number of messages visible in one map instance.

skipImmediately() - Static method in class io.superdurable.dex.Wait

Skips condition evaluation and makes the Step immediately eligible to execute.

skipTimer(String, StepExecutionId, TimerId) - Method in class io.superdurable.dex.Client

Makes one durable timer condition fire immediately.

skipWritesReapply(boolean) - Method in class io.superdurable.dex.TimeTravelOptions.Builder

Controls whether historical writes are omitted from replay.

start() - Method in class io.superdurable.dex.Worker

Starts the worker pull streams and blocks until termination.

startDelay(Duration) - Method in class io.superdurable.dex.StartFlowOptions.Builder

Delays creation of the first Step execution.

startDelay(Duration) - Method in class io.superdurable.dex.SubFlowOptions.Builder

Sets the delay before the SubFlow starts.

startFlow(Flow, String, I) - Method in class io.superdurable.dex.Client

Starts a registered Flow using default start options.

startFlow(Flow, String, I, StartFlowOptions) - Method in class io.superdurable.dex.Client

Starts a registered Flow with explicit start options.

StartFlowOptions - Class in io.superdurable.dex

Configures one Client.startFlow(Flow, String, I) request.

StartFlowOptions() - Constructor for class io.superdurable.dex.StartFlowOptions

Creates options that use all SDK and server defaults.

StartFlowOptions.Builder - Class in io.superdurable.dex

Builds immutable StartFlowOptions values.

startStep(Step) - Static method in class io.superdurable.dex.StepList

Creates a Step list with a typed start Step.

Step<I> - Interface in io.superdurable.dex

Implements one durable unit of Flow logic.

STEP_DECISION_FAILED - Enum constant in enum class io.superdurable.dex.FlowErrorType

A Step returned a decision that failed the Flow.

STEP_EXECUTION_ID - Enum constant in enum class io.superdurable.dex.TimeTravelType

Resumes at a specific Step execution ID.

STEP_TYPE - Enum constant in enum class io.superdurable.dex.TimeTravelType

Resumes at an occurrence of a Step type.

StepCompletion - Class in io.superdurable.dex

Contains one output-bearing Step completion returned by Client.waitForFlow(String).

StepDecision - Class in io.superdurable.dex

Describes the durable action Dex takes after a Step executes.

stepDurability(StepDurability) - Method in class io.superdurable.dex.FlowConfig.Builder

Sets the normal default durability for Step methods in this Flow.

StepDurability - Enum Class in io.superdurable.dex

Selects when Dex durably records a Step method result relative to subsequent Flow work.

stepExecutionId(String) - Method in class io.superdurable.dex.TimeTravelOptions.Builder

Selects a time travel point by server Step execution ID.

StepExecutionId - Class in io.superdurable.dex

Selects one execution of a Step within a Flow.

StepList<StartInput> - Class in io.superdurable.dex

Declares a Flow's ordered collection of registered Steps.

stepMethod(TimeTravelStepMethod) - Method in class io.superdurable.dex.TimeTravelOptions.Builder

Selects the WaitFor or Execute boundary for a Step execution.

StepMovement<I> - Class in io.superdurable.dex

Describes one transition to a typed Step and its input.

StepOptions - Class in io.superdurable.dex

Configures timeout, retry, durability, locking, and failure behavior for a Step.

StepOptions.Builder - Class in io.superdurable.dex

Builds immutable StepOptions values.

stepType(String) - Method in class io.superdurable.dex.TimeTravelOptions.Builder

Selects a time travel point by Step type.

stop() - Method in class io.superdurable.dex.Worker

Gracefully stops the pull streams, handler executor, and server channel.

stopDrainTimeout(Duration) - Method in class io.superdurable.dex.PullWorkerOptions.Builder

Sets how long Stop waits for active pull tasks before canceling them.

stopFlow(String) - Method in class io.superdurable.dex.Client

Cancels a running Flow without an explicit reason.

stopFlow(String, StopFlowOptions) - Method in class io.superdurable.dex.Client

Stops a running Flow with explicit terminal behavior.

StopFlowOptions - Class in io.superdurable.dex

Configures how Client.stopFlow(String) ends a running Flow.

StopFlowOptions() - Constructor for class io.superdurable.dex.StopFlowOptions

Creates cancellation options without an explicit reason.

StopFlowOptions(StopType, String) - Constructor for class io.superdurable.dex.StopFlowOptions

Creates stop options with an explicit mode and reason.

stopOnPermanentStreamRejection(boolean) - Method in class io.superdurable.dex.PullWorkerOptions.Builder

Stops the Worker on a permanent rejection leaving a queue without a registered stream.

StopType - Enum Class in io.superdurable.dex

Selects how Client.stopFlow(String) ends a running Flow.

Stream<T> - Class in io.superdurable.dex

Defines a typed best-effort resumable message Stream owned by one Flow type.

StreamMessage<T> - Class in io.superdurable.dex

Describes one retained Stream message returned by Stream Client reads.

StreamMessagesPage<T> - Class in io.superdurable.dex

Contains one newest-first page returned by Client.listStreamMessages(String, Stream, int, String).

SubFlow - Class in io.superdurable.dex

Creates durable SubFlow conditions and reads their results during Step execution.

SubFlowOptions - Class in io.superdurable.dex

Configures one durable SubFlow condition.

SubFlowOptions.Builder - Class in io.superdurable.dex

Builds immutable SubFlow options.

SubFlowReusePolicy - Enum Class in io.superdurable.dex

Controls how a SubFlow condition resolves an execution that already uses its generated Flow ID.

SYNC - Enum constant in enum class io.superdurable.dex.StepDurability

Persists the method result before Dex advances based on it.

syncToAttributeStore() - Method in class io.superdurable.dex.Attribute

Returns a definition whose writes are projected through the Flow's Attribute Store.

syncToAttributeStore() - Method in class io.superdurable.dex.AttributeMap

Returns a definition whose instance writes are projected through the Flow's Attribute Store.

T

TERMINATE - Enum constant in enum class io.superdurable.dex.StopType

Terminates the Flow immediately.

TERMINATE_IF_RUNNING - Enum constant in enum class io.superdurable.dex.IdReusePolicy

Terminates a running execution before starting the replacement.

TERMINATED - Enum constant in enum class io.superdurable.dex.FlowStatus

The Flow was forcibly terminated.

timeout(Duration) - Method in class io.superdurable.dex.StartFlowOptions.Builder

Sets Dex's durable soft timeout for the Flow execution.

timeout(Duration) - Method in class io.superdurable.dex.SubFlowOptions.Builder

Sets Dex's durable soft timeout for the SubFlow execution.

timeoutHandlerOptions(FlowTimeoutHandlerOptions) - Method in class io.superdurable.dex.StartFlowOptions.Builder

Configures timeout-handler execution and selective state loading.

timeoutHandlerOptions(FlowTimeoutHandlerOptions) - Method in class io.superdurable.dex.SubFlowOptions.Builder

Configures timeout-handler execution and selective state loading.

timeoutPolicy(FlowTimeoutPolicy) - Method in class io.superdurable.dex.StartFlowOptions.Builder

Sets the action taken when the positive Flow timeout expires.

timeoutPolicy(FlowTimeoutPolicy) - Method in class io.superdurable.dex.SubFlowOptions.Builder

Sets the action taken when the positive SubFlow timeout expires.

timeoutSeconds() - Element in annotation interface io.superdurable.dex.RPC

Sets the RPC execution timeout in whole seconds.

Timer - Class in io.superdurable.dex

Creates server-side durable timer conditions for Step waits.

TimerId - Class in io.superdurable.dex

Selects a timer condition within one Step execution.

timeTravel(String, TimeTravelOptions) - Method in class io.superdurable.dex.Client

Creates a new run from a selected point in an existing Flow's history.

TimeTravelOptions - Class in io.superdurable.dex

Selects a historical point and replay behavior for Client.timeTravel(String, TimeTravelOptions).

TimeTravelOptions.Builder - Class in io.superdurable.dex

Builds immutable TimeTravelOptions values.

TimeTravelStepMethod - Enum Class in io.superdurable.dex

Selects the Step method used as a TimeTravelType.STEP_EXECUTION_ID boundary.

TimeTravelType - Enum Class in io.superdurable.dex

Selects the historical point from which a Flow resumes in a new run.

token() - Method in class io.superdurable.dex.ApiKeyCredential

Returns a cached access token or waits for one exchange when no valid token exists.

token() - Method in interface io.superdurable.dex.Credential

Returns the current printable ASCII token without the Bearer prefix.

token() - Method in class io.superdurable.dex.FileCredential

Returns the cached token after any due file check.

toString() - Method in class io.superdurable.dex.ApiKeyCredential

Describes this credential without revealing either secret.

toString() - Method in class io.superdurable.dex.FileCredential

Describes this credential without revealing its token.

totalDuration(Duration) - Method in class io.superdurable.dex.RetryPolicy.Builder

Limits the total elapsed retry duration.

triggerContinueAsNew(String) - Method in class io.superdurable.dex.Client

Requests that the current Flow run continue as new.

U

UNCATEGORIZED - Enum constant in enum class io.superdurable.dex.exceptions.ErrorSubStatus

Indicates an error without a more specific Dex category.

until(Condition) - Static method in class io.superdurable.dex.Wait

Waits for one condition to be satisfied.

updateFlowConfig(String, FlowConfig) - Method in class io.superdurable.dex.Client

Updates the supplied mutable Flow configuration fields for the current run.

V

ValueMappingException - Exception Class in io.superdurable.dex.exceptions

Reports that the SDK cannot encode, hydrate, or decode an application value.

ValueMappingException(String) - Constructor for exception class io.superdurable.dex.exceptions.ValueMappingException

Creates a value-mapping failure without an underlying cause.

ValueMappingException(String, Throwable) - Constructor for exception class io.superdurable.dex.exceptions.ValueMappingException

Creates a value-mapping failure with its underlying serializer error.

valueOf(String) - Static method in enum class io.superdurable.dex.ActiveStepSearchMode

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.superdurable.dex.AttributeIndex.Type

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.superdurable.dex.exceptions.ErrorSubStatus

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.superdurable.dex.FlowErrorType

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.superdurable.dex.FlowStatus

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.superdurable.dex.FlowTimeoutPolicy

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.superdurable.dex.IdReusePolicy

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.superdurable.dex.StepDurability

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.superdurable.dex.StopType

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.superdurable.dex.SubFlowReusePolicy

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.superdurable.dex.TimeTravelStepMethod

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.superdurable.dex.TimeTravelType

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.superdurable.dex.WaitForFailurePolicy

Returns the enum constant of this class with the specified name.

values() - Static method in enum class io.superdurable.dex.ActiveStepSearchMode

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.superdurable.dex.AttributeIndex.Type

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.superdurable.dex.exceptions.ErrorSubStatus

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.superdurable.dex.FlowErrorType

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.superdurable.dex.FlowStatus

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.superdurable.dex.FlowTimeoutPolicy

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.superdurable.dex.IdReusePolicy

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.superdurable.dex.StepDurability

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.superdurable.dex.StopType

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.superdurable.dex.SubFlowReusePolicy

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.superdurable.dex.TimeTravelStepMethod

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.superdurable.dex.TimeTravelType

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.superdurable.dex.WaitForFailurePolicy

Returns an array containing the constants of this enum class, in the order they are declared.

W

Wait - Class in io.superdurable.dex

Describes when Dex may invoke a Step's execute method.

WAIT_FOR - Enum constant in enum class io.superdurable.dex.TimeTravelStepMethod

Resumes before the selected Step execution's WaitFor method.

waitFor(Context, I) - Method in interface io.superdurable.dex.Step

Declares the conditions that must be satisfied before execution.

waitForAttributeMatch(String, Attribute, AttributeMatch, WaitForAttributeOptions) - Method in class io.superdurable.dex.Client

Blocks until a singleton Attribute satisfies a scalar match or its request timeout expires.

waitForAttributeMatch(String, AttributeMap, String, AttributeMatch, WaitForAttributeOptions) - Method in class io.superdurable.dex.Client

Blocks until an AttributeMap instance satisfies a scalar match.

WaitForAttributeOptions - Class in io.superdurable.dex

Configures one durable Attribute match wait.

WaitForAttributeOptions.Builder - Class in io.superdurable.dex

Builds immutable Attribute wait options.

waitForDurability(StepDurability) - Method in class io.superdurable.dex.StepOptions.Builder

Overrides durability for this Step's wait-for method result.

waitForFailure(WaitForFailurePolicy) - Method in class io.superdurable.dex.StepOptions.Builder

Sets the action taken after wait-for retries are exhausted.

WaitForFailurePolicy - Enum Class in io.superdurable.dex

Controls what happens after a Step's wait-for method exhausts its retry policy.

waitForFlow(String) - Method in class io.superdurable.dex.Client

Blocks until a Flow reaches any terminal status.

waitForFlow(String, Duration) - Method in class io.superdurable.dex.Client

Blocks for a bounded duration until a Flow reaches any terminal status.

waitForMethodFailed() - Method in interface io.superdurable.dex.Context

Reports whether execute is running after a failed wait-for method.

waitForMethodTimeout(Duration) - Method in class io.superdurable.dex.StepOptions.Builder

Sets the maximum duration of one wait-for method attempt.

waitForRetry(RetryPolicy) - Method in class io.superdurable.dex.StepOptions.Builder

Sets the retry policy for wait-for method failures.

waitForStepCompletion(String, StepExecutionId, WaitForStepCompletionOptions) - Method in class io.superdurable.dex.Client

Blocks until a specific Step execution completes or its caller-visible request expires.

WaitForStepCompletionOptions - Class in io.superdurable.dex

Configures one durable Step completion wait.

WaitForStepCompletionOptions.Builder - Class in io.superdurable.dex

Builds immutable Step completion wait options.

waitPullRegistered(Duration) - Method in class io.superdurable.dex.Worker

Waits until every pull queue has received a Registered acknowledgement at least once.

WITH_WAIT_FOR - Enum constant in enum class io.superdurable.dex.ActiveStepSearchMode

Indexes an active Step type only when its Step.waitFor(Context, Object) method runs.

withCancelingSiblingSteps(Class...) - Method in class io.superdurable.dex.StepDecision

Cancels selected sibling Step executions that share the current execution's scheduling source.

withCancelingSteps(Class...) - Method in class io.superdurable.dex.RPCResult

Cancels queued or active executions of the selected Step types in the current Flow.

withCancelingSteps(Class...) - Method in class io.superdurable.dex.StepDecision

Cancels queued or active executions of the selected Step types in the current Flow.

withoutStartStep(Step...) - Static method in class io.superdurable.dex.StepList

Creates a Step list with no start Step and one or more RPC-targetable Steps.

Worker - Class in io.superdurable.dex

Hosts synchronous Java Step and RPC implementations for registered Flows.

Worker(Registry, BlobCache) - Constructor for class io.superdurable.dex.Worker

Creates a worker using local development defaults.

Worker(Registry, BlobCache, WorkerOptions) - Constructor for class io.superdurable.dex.Worker

Creates a worker with explicit polling, connection, and serialization options.

WORKER_API_ERROR - Enum constant in enum class io.superdurable.dex.exceptions.ErrorSubStatus

Indicates that a worker invocation failed.

WORKER_API_FAILED - Enum constant in enum class io.superdurable.dex.FlowErrorType

A worker API invocation caused the Flow to fail.

WorkerInvocationException - Exception Class in io.superdurable.dex.exceptions

Reports that a Java worker failed while executing a Step or RPC invocation.

WorkerInvocationException(Status.Code, String, String, String, String, Status.Code, Throwable) - Constructor for exception class io.superdurable.dex.exceptions.WorkerInvocationException

Creates a worker failure with its original worker metadata.

WorkerOptions - Class in io.superdurable.dex

Configures a Java Worker's outbound polling, connection, and serialization.

WorkerOptions.Builder - Class in io.superdurable.dex

Builds immutable WorkerOptions values.

write(Context, T) - Method in class io.superdurable.dex.Stream

Appends one message immediately from the current Step execution.

write(String) - Method in class io.superdurable.dex.BufferedTextStream

Appends one chunk and flushes after crossing the soft size threshold.

writeStream(Stream, T) - Method in interface io.superdurable.dex.Context

Appends one immediate best-effort Stream message.

writeStream(String, Stream, String, T) - Method in class io.superdurable.dex.Client

Appends one typed best-effort Stream message with producer metadata.

A B C D E F G H I K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form