All Classes and Interfaces
Class
Description
Controls which active Step types Dex records in the
ActiveStepTypes search index.Exchanges a long-lived API key for short-lived Dex bearer tokens.
Configures the timeout and HTTP transport for an API key credential.
Reports a token endpoint, response, transport, or timeout failure.
Opens the HTTP connection used for an API key exchange.
Defines one durable, typed value stored with a Flow execution.
Describes how an Attribute is indexed for Flow search.
Defines the value representation used by the search backend.
Defines one Attribute lock for a Step's
waitFor or execute method.Defines a durable map of named, typed Attribute instances.
Selects one typed AttributeMap instance for a Client Attribute read.
Indicates that an RPC did not load the requested AttributeMap entries.
Describes a scalar Attribute predicate.
Selects one Attribute value for
Client.getAttributes(String, AttributeRead...).Holds the decoded values of one
Client.getAttributes(String, AttributeRead...) call.Caches immutable, server-addressed blob payloads on local disk.
Configures the disk-backed
BlobCache.Batches text chunks into best-effort Stream messages during one Step invocation.
Defines one durable, typed message Channel for a Flow.
Defines a durable map of named, typed Channel instances.
Identifies one typed value that is still pending in a Channel.
Thrown when a requested Channel message is no longer pending.
Indicates that an RPC did not load the requested pending Channel messages.
Provides synchronous, strongly typed operations for starting and controlling Dex Flows.
Configures a synchronous
Client connection and value mapper.Builds immutable Client options.
Represents one Timer, Channel, or SubFlow condition used by a
Wait.Groups conditions that must all be satisfied as one alternative in a combined wait.
Exposes invocation metadata and durable state operations to Step and RPC code.
Supplies a bearer token before each Client or Worker service call.
Reports a Dex API failure translated from a gRPC response.
Identifies a Dex-specific category within a transport error.
Reads a bearer token from a file and picks up rotations without a restart.
Defines the Steps, persistence, and RPC surface of one Flow type.
Reports that a Flow start request conflicts with an existing Flow ID.
Reports a request rejected while Dex closes a Flow.
Configures server behavior for one Flow execution.
Builds immutable
FlowConfig values.Reports an invalid local Flow, Step, persistence, or RPC definition.
Classifies why a Flow reached a terminal status other than
FlowStatus.COMPLETED.Describes the identity and current status of one Flow execution.
Reports a missing Flow or an operation that cannot use a closed Flow.
Reports that a read or history operation cannot find a matching Flow execution.
Describes the observed state and output of a Flow used as a SubFlow or waited on by a client.
Represents the lifecycle status of a Flow execution.
Configures one Flow timeout handler's Execute semantics and state snapshot.
Builds immutable
FlowTimeoutHandlerOptions values.Controls how Dex responds when a positive soft Flow timeout expires.
Maps Java Worker application exceptions to gRPC status codes.
Builds immutable exception-to-status mappings.
Controls whether
Client.startFlow(Flow, String, I) may reuse an existing Flow ID.Reports an invalid value returned by user Step code.
Thrown when a Dex long-poll operation reaches its timeout before satisfying the requested wait.
Represents a typed Attribute, Channel, or Stream definition in a
PersistenceSchema.Declares the Attributes, Channels, and Streams that belong to a Flow.
Describes one slot kind in an immutable pull readiness snapshot.
Identifies a permanent pull rejection leaving a slot kind without a registered stream.
Provides an independent, immutable snapshot of pull slot readiness.
Configures a Worker that opens outbound task streams to Dex.
Builds immutable outbound polling options.
Describes the final failure that caused a Step method recovery.
Validates and indexes the Flow definitions shared by a client or worker.
Thrown when a caller-defined request budget expires.
Requests a specific delay before retrying a failed Step method.
Configures exponential-backoff retries for Flow or Step operations.
Builds immutable
RetryPolicy values.Marks a public Flow method as an RPC endpoint.
Selects one Attribute-map instance to lock during an RPC invocation.
Provides serializable functional types for strongly typed RPC method references.
Represents an RPC function with no application input and one output.
Represents an RPC function with one input and one output.
Represents an RPC procedure with no application input or output.
Represents an RPC procedure with one input and no output.
Adds runtime-selected Attribute-map locks and exact map-instance loads to one RPC invocation.
Builds immutable
RPCInvokeOptions values.Reports that a locking RPC could not acquire its requested Attribute locks.
Carries a typed RPC output, optional next-Step movements, and Step type cancellation.
Represents one Flow execution returned by a search query.
Controls inclusion of earlier Continue-as-New runs in visibility searches.
Builds immutable search options.
Contains one page of Flow search results and its continuation token.
Configures one
Client.startFlow(Flow, String, I) request.Builds immutable
StartFlowOptions values.Implements one durable unit of Flow logic.
Describes how far a failed Step method progressed across all its attempts.
Contains one output-bearing Step completion returned by
Client.waitForFlow(String).Describes the durable action Dex takes after a Step executes.
Selects when Dex durably records a Step method result relative to subsequent Flow work.
Selects one execution of a Step within a Flow.
Declares a Flow's ordered collection of registered Steps.
Describes one transition to a typed Step and its input.
Configures timeout, retry, durability, locking, and failure behavior for a Step.
Builds immutable
StepOptions values.Configures how
Client.stopFlow(String) ends a running Flow.Selects how
Client.stopFlow(String) ends a running Flow.Defines a typed best-effort resumable message Stream owned by one Flow type.
Describes one retained Stream message returned by Stream Client reads.
Contains one newest-first page returned by
Client.listStreamMessages(String, Stream, int, String).Creates durable SubFlow conditions and reads their results during Step execution.
Configures one durable SubFlow condition.
Builds immutable SubFlow options.
Controls how a SubFlow condition resolves an execution that already uses its generated Flow ID.
Creates server-side durable timer conditions for Step waits.
Selects a timer condition within one Step execution.
Selects a historical point and replay behavior for
Client.timeTravel(String, TimeTravelOptions).Builds immutable
TimeTravelOptions values.Selects the Step method used as a
TimeTravelType.STEP_EXECUTION_ID boundary.Selects the historical point from which a Flow resumes in a new run.
Reports that the SDK cannot encode, hydrate, or decode an application value.
Describes when Dex may invoke a Step's execute method.
Configures one durable Attribute match wait.
Builds immutable Attribute wait options.
Controls what happens after a Step's wait-for method exhausts its retry policy.
Configures one durable Step completion wait.
Builds immutable Step completion wait options.
Hosts synchronous Java Step and RPC implementations for registered Flows.
Reports that a Java worker failed while executing a Step or RPC invocation.
Configures a Java Worker's outbound polling, connection, and serialization.
Builds immutable
WorkerOptions values.