Index (orchestra-api 1.1.1 API)

A C D E F G H I M N O P Q R S T U V W Z
All Classes and Interfaces|All Packages

A

action() - Method in record class com.iantapply.orchestra.api.ActionContext: Returns the value of the action record component.
ActionContext - Record Class in com.iantapply.orchestra.api: Immutable context supplied to an OrchestraAction invocation.
ActionContext(UUID, EventDefinition, StageDefinition, ActionSpec, String, Instant, Map) - Constructor for record class com.iantapply.orchestra.api.ActionContext: Validates required values and snapshots the variable map.
actions() - Method in record class com.iantapply.orchestra.api.StageDefinition: Returns the value of the actions record component.
ActionSpec - Record Class in com.iantapply.orchestra.api: Declarative configuration for one stage action.
ActionSpec(String, String, Map, RetryPolicy) - Constructor for record class com.iantapply.orchestra.api.ActionSpec: Validates identifiers and snapshots arguments.
activeExecutionCount() - Method in record class com.iantapply.orchestra.api.OrchestraStatus: Returns the value of the activeExecutionCount record component.
activeExecutions(int) - Method in interface com.iantapply.orchestra.api.OrchestraService: Returns active execution snapshots up to the requested limit.
activeWorkerCount() - Method in record class com.iantapply.orchestra.api.OrchestraStatus: Returns the value of the activeWorkerCount record component.
addListener(EventLifecycleListener) - Method in interface com.iantapply.orchestra.api.OrchestraService: Registers a listener for persisted lifecycle transitions.
ALL_ONLINE - Static variable in record class com.iantapply.orchestra.api.TargetSelector: Selector matching every online server.
allOnline() - Method in record class com.iantapply.orchestra.api.TargetSelector: Returns the value of the allOnline record component.
arguments() - Method in record class com.iantapply.orchestra.api.ActionSpec: Returns the value of the arguments record component.
arguments() - Method in record class com.iantapply.orchestra.api.ConditionSpec: Returns the value of the arguments record component.

C

cancel(UUID) - Method in interface com.iantapply.orchestra.api.OrchestraService: Cancels an execution if its current state permits the transition.
CANCELLED - Enum constant in enum class com.iantapply.orchestra.api.EventStatus: Execution was explicitly terminated.
close() - Method in interface com.iantapply.orchestra.port.DistributedLock.Lease: Releases this lease; repeated calls must be harmless.
close() - Method in interface com.iantapply.orchestra.port.NetworkTransport: Closes all subscriptions and rejects new work.
close() - Method in interface com.iantapply.orchestra.port.NetworkTransport.Subscription: Stops delivery and releases transport resources.
com.iantapply.orchestra.api - package com.iantapply.orchestra.api: Stable extension points and immutable event-definition types exposed to plugin developers.
com.iantapply.orchestra.domain - package com.iantapply.orchestra.domain: Runtime state persisted by Orchestra repositories.
com.iantapply.orchestra.port - package com.iantapply.orchestra.port: Infrastructure contracts implemented by storage, coordination, and discovery adapters.
compareAndSet(long, EventExecution) - Method in interface com.iantapply.orchestra.port.ExecutionRepository: Replaces an execution only if its current version equals the expected version.
COMPLETED - Enum constant in enum class com.iantapply.orchestra.api.EventStatus: Every stage completed successfully.
completedActions() - Method in record class com.iantapply.orchestra.domain.EventExecution: Returns the value of the completedActions record component.
condition() - Method in record class com.iantapply.orchestra.api.ConditionContext: Returns the value of the condition record component.
ConditionContext - Record Class in com.iantapply.orchestra.api: Immutable context supplied while evaluating an OrchestraCondition.
ConditionContext(UUID, EventDefinition, StageDefinition, ConditionSpec, Instant, Map) - Constructor for record class com.iantapply.orchestra.api.ConditionContext: Snapshots the variable map for safe asynchronous evaluation.
conditions() - Method in record class com.iantapply.orchestra.api.StageDefinition: Returns the value of the conditions record component.
ConditionSpec - Record Class in com.iantapply.orchestra.api: Declarative configuration for a stage condition.
ConditionSpec(String, Map) - Constructor for record class com.iantapply.orchestra.api.ConditionSpec: Validates the type and snapshots arguments.
create(EventExecution) - Method in interface com.iantapply.orchestra.port.ExecutionRepository: Persists a new execution.
createdAt() - Method in record class com.iantapply.orchestra.domain.EventExecution: Returns the value of the createdAt record component.
cron() - Method in record class com.iantapply.orchestra.api.RecurringSchedule: Returns the value of the cron record component.

D

DEFAULT - Static variable in record class com.iantapply.orchestra.api.RetryPolicy: Default policy: three attempts with one-second exponential backoff capped at 30 seconds.
definitionCount() - Method in record class com.iantapply.orchestra.api.OrchestraStatus: Returns the value of the definitionCount record component.
definitionId() - Method in record class com.iantapply.orchestra.domain.EventExecution: Returns the value of the definitionId record component.
DefinitionRepository - Interface in com.iantapply.orchestra.port: Persistence contract for event definitions.
definitions() - Method in interface com.iantapply.orchestra.api.OrchestraService: Returns a snapshot of all registered definitions.
delayBefore(int) - Method in record class com.iantapply.orchestra.api.RetryPolicy: Computes the delay before a one-based attempt number.
displayName() - Method in record class com.iantapply.orchestra.api.EventDefinition: Returns the value of the displayName record component.
DistributedLock - Interface in com.iantapply.orchestra.port: Provides short-lived, owner-safe leases shared by orchestrator nodes.
DistributedLock.Lease - Interface in com.iantapply.orchestra.port: A lock claim that releases only its own ownership token when closed.
DRAFT - Enum constant in enum class com.iantapply.orchestra.api.EventStatus: Definition exists but cannot execute.
dueAt() - Method in record class com.iantapply.orchestra.domain.EventExecution: Returns the value of the dueAt record component.
duration() - Method in record class com.iantapply.orchestra.api.StageDefinition: Returns the value of the duration record component.

E

equals(Object) - Method in record class com.iantapply.orchestra.api.ActionContext: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.iantapply.orchestra.api.ActionSpec: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.iantapply.orchestra.api.ConditionContext: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.iantapply.orchestra.api.ConditionSpec: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.iantapply.orchestra.api.EventDefinition: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.iantapply.orchestra.api.OrchestraStatus: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.iantapply.orchestra.api.RecurringSchedule: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.iantapply.orchestra.api.RetryPolicy: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.iantapply.orchestra.api.StageDefinition: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.iantapply.orchestra.api.TargetSelector: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.iantapply.orchestra.domain.EventExecution: Indicates whether some other object is "equal to" this one.
event() - Method in record class com.iantapply.orchestra.api.ActionContext: Returns the value of the event record component.
event() - Method in record class com.iantapply.orchestra.api.ConditionContext: Returns the value of the event record component.
EventDefinition - Record Class in com.iantapply.orchestra.api: Immutable definition of a complete event workflow.
EventDefinition(String, String, RecurringSchedule, TargetSelector, List) - Constructor for record class com.iantapply.orchestra.api.EventDefinition: Validates the definition and snapshots its ordered stages.
EventDefinition(String, String, TargetSelector, List) - Constructor for record class com.iantapply.orchestra.api.EventDefinition: Creates a definition without a recurring schedule.
EventExecution - Record Class in com.iantapply.orchestra.domain: Immutable, versioned runtime state for one event execution.
EventExecution(UUID, String, EventStatus, int, long, Instant, Instant, Instant, Instant, Map, Set, String) - Constructor for record class com.iantapply.orchestra.domain.EventExecution: Snapshots mutable collections before execution state is shared.
EventLifecycleListener - Interface in com.iantapply.orchestra.api: Observes successfully persisted event status transitions.
EventStatus - Enum Class in com.iantapply.orchestra.api: Lifecycle states persisted for an event execution.
execute(ActionContext) - Method in interface com.iantapply.orchestra.api.OrchestraAction: Performs the action without blocking the caller.
execution(UUID) - Method in interface com.iantapply.orchestra.api.OrchestraService: Returns one current execution snapshot.
executionId() - Method in record class com.iantapply.orchestra.api.ActionContext: Returns the value of the executionId record component.
executionId() - Method in record class com.iantapply.orchestra.api.ConditionContext: Returns the value of the executionId record component.
ExecutionRepository - Interface in com.iantapply.orchestra.port: Durable execution store using optimistic version checks for updates.

F

FAILED - Enum constant in enum class com.iantapply.orchestra.api.EventStatus: Execution stopped because a condition or action failed.
failure() - Method in record class com.iantapply.orchestra.domain.EventExecution: Returns the value of the failure record component.
find(String) - Method in interface com.iantapply.orchestra.port.DefinitionRepository: Finds one definition.
find(UUID) - Method in interface com.iantapply.orchestra.port.ExecutionRepository: Finds one execution.
findActive(int) - Method in interface com.iantapply.orchestra.port.ExecutionRepository: Finds execution state eligible for startup recovery.
findAll() - Method in interface com.iantapply.orchestra.port.DefinitionRepository: Lists known definitions.
findDue(Instant, int) - Method in interface com.iantapply.orchestra.port.ExecutionRepository: Finds runnable work due on or before a time.

G

getString(String) - Method in record class com.iantapply.orchestra.api.ActionContext: Reads a required action argument as text.
groups() - Method in record class com.iantapply.orchestra.api.TargetSelector: Returns the value of the groups record component.

H

hashCode() - Method in record class com.iantapply.orchestra.api.ActionContext: Returns a hash code value for this object.
hashCode() - Method in record class com.iantapply.orchestra.api.ActionSpec: Returns a hash code value for this object.
hashCode() - Method in record class com.iantapply.orchestra.api.ConditionContext: Returns a hash code value for this object.
hashCode() - Method in record class com.iantapply.orchestra.api.ConditionSpec: Returns a hash code value for this object.
hashCode() - Method in record class com.iantapply.orchestra.api.EventDefinition: Returns a hash code value for this object.
hashCode() - Method in record class com.iantapply.orchestra.api.OrchestraStatus: Returns a hash code value for this object.
hashCode() - Method in record class com.iantapply.orchestra.api.RecurringSchedule: Returns a hash code value for this object.
hashCode() - Method in record class com.iantapply.orchestra.api.RetryPolicy: Returns a hash code value for this object.
hashCode() - Method in record class com.iantapply.orchestra.api.StageDefinition: Returns a hash code value for this object.
hashCode() - Method in record class com.iantapply.orchestra.api.TargetSelector: Returns a hash code value for this object.
hashCode() - Method in record class com.iantapply.orchestra.domain.EventExecution: Returns a hash code value for this object.

I

id() - Method in record class com.iantapply.orchestra.api.ActionSpec: Returns the value of the id record component.
id() - Method in record class com.iantapply.orchestra.api.EventDefinition: Returns the value of the id record component.
id() - Method in record class com.iantapply.orchestra.api.StageDefinition: Returns the value of the id record component.
id() - Method in record class com.iantapply.orchestra.domain.EventExecution: Returns the value of the id record component.
idempotencyKey() - Method in record class com.iantapply.orchestra.api.ActionContext: Returns a stable key suitable for deduplicating external side effects.
initialDelay() - Method in record class com.iantapply.orchestra.api.RetryPolicy: Returns the value of the initialDelay record component.

M

maxAttempts() - Method in record class com.iantapply.orchestra.api.RetryPolicy: Returns the value of the maxAttempts record component.
maximumDelay() - Method in record class com.iantapply.orchestra.api.RetryPolicy: Returns the value of the maximumDelay record component.
multiplier() - Method in record class com.iantapply.orchestra.api.RetryPolicy: Returns the value of the multiplier record component.

N

NetworkTransport - Interface in com.iantapply.orchestra.port: Binary publish/subscribe transport used for cross-server messages.
NetworkTransport.Subscription - Interface in com.iantapply.orchestra.port: Closeable subscription to one logical channel.
now() - Method in record class com.iantapply.orchestra.api.ActionContext: Returns the value of the now record component.
now() - Method in record class com.iantapply.orchestra.api.ConditionContext: Returns the value of the now record component.

O

onTransition(EventExecution, EventExecution) - Method in interface com.iantapply.orchestra.api.EventLifecycleListener: Handles a transition after the updated execution has been persisted.
OrchestraAction - Interface in com.iantapply.orchestra.api: Extension point for an asynchronous event action.
OrchestraCondition - Interface in com.iantapply.orchestra.api: Extension point for an asynchronous stage condition.
OrchestraService - Interface in com.iantapply.orchestra.api: Public facade exposed by the installed Orchestra Paper plugin.
OrchestraStatus - Record Class in com.iantapply.orchestra.api: Platform-neutral operational snapshot.
OrchestraStatus(int, int, int, int) - Constructor for record class com.iantapply.orchestra.api.OrchestraStatus: Creates an instance of a OrchestraStatus record class.

P

pause(UUID) - Method in interface com.iantapply.orchestra.api.OrchestraService: Pauses an execution if its current state permits the transition.
PAUSED - Enum constant in enum class com.iantapply.orchestra.api.EventStatus: Execution is suspended until explicitly resumed.
publish(String, byte[]) - Method in interface com.iantapply.orchestra.port.NetworkTransport: Publishes one binary message.

Q

queuedTaskCount() - Method in record class com.iantapply.orchestra.api.OrchestraStatus: Returns the value of the queuedTaskCount record component.

R

RecurringSchedule - Record Class in com.iantapply.orchestra.api: Five-field cron schedule evaluated in a named time zone.
RecurringSchedule(String, ZoneId) - Constructor for record class com.iantapply.orchestra.api.RecurringSchedule: Validates the expression and applies the UTC default zone.
registerAction(String, OrchestraAction) - Method in interface com.iantapply.orchestra.api.OrchestraService: Registers a custom action type for this server session.
registerCondition(String, OrchestraCondition) - Method in interface com.iantapply.orchestra.api.OrchestraService: Registers a custom condition type for this server session.
registerDefinition(EventDefinition) - Method in interface com.iantapply.orchestra.api.OrchestraService: Registers or replaces an event definition by identifier.
renew(Duration) - Method in interface com.iantapply.orchestra.port.DistributedLock.Lease: Extends this lease only if it is still owned by this instance.
replaceAll(Collection) - Method in interface com.iantapply.orchestra.port.DefinitionRepository: Atomically replaces the complete definition snapshot.
resolve(TargetSelector) - Method in interface com.iantapply.orchestra.port.TargetResolver: Resolves a selector against current server state.
resume(UUID) - Method in interface com.iantapply.orchestra.api.OrchestraService: Resumes a paused execution.
retry(UUID) - Method in interface com.iantapply.orchestra.api.OrchestraService: Restarts a failed execution from its first stage.
retryPolicy() - Method in record class com.iantapply.orchestra.api.ActionSpec: Returns the value of the retryPolicy record component.
RetryPolicy - Record Class in com.iantapply.orchestra.api: Bounded exponential-backoff policy for action attempts.
RetryPolicy(int, Duration, double, Duration) - Constructor for record class com.iantapply.orchestra.api.RetryPolicy: Validates retry bounds and delay ordering.
RUNNING - Enum constant in enum class com.iantapply.orchestra.api.EventStatus: One or more stages have run and further work may be due.

S

save(EventDefinition) - Method in interface com.iantapply.orchestra.port.DefinitionRepository: Inserts or replaces a definition.
schedule() - Method in record class com.iantapply.orchestra.api.EventDefinition: Returns the value of the schedule record component.
schedule(String, Instant, Map) - Method in interface com.iantapply.orchestra.api.OrchestraService: Creates a durable execution at the requested time with initial variables.
scheduled(UUID, String, Instant, Instant) - Static method in record class com.iantapply.orchestra.domain.EventExecution: Creates a new scheduled execution at version zero.
SCHEDULED - Enum constant in enum class com.iantapply.orchestra.api.EventStatus: Execution is waiting for its due time.
server() - Method in record class com.iantapply.orchestra.api.ActionContext: Returns the value of the server record component.
servers() - Method in record class com.iantapply.orchestra.api.TargetSelector: Returns the value of the servers record component.
setVariable(UUID, String, Object) - Method in interface com.iantapply.orchestra.api.OrchestraService: Sets an execution variable, or removes it when value is null.
stage() - Method in record class com.iantapply.orchestra.api.ActionContext: Returns the value of the stage record component.
stage() - Method in record class com.iantapply.orchestra.api.ConditionContext: Returns the value of the stage record component.
StageDefinition - Record Class in com.iantapply.orchestra.api: One ordered stage in an event workflow.
StageDefinition(String, Duration, Duration, List, List) - Constructor for record class com.iantapply.orchestra.api.StageDefinition: Validates timing values and snapshots conditions and actions.
stageIndex() - Method in record class com.iantapply.orchestra.domain.EventExecution: Returns the value of the stageIndex record component.
stages() - Method in record class com.iantapply.orchestra.api.EventDefinition: Returns the value of the stages record component.
stageStartedAt() - Method in record class com.iantapply.orchestra.domain.EventExecution: Returns the value of the stageStartedAt record component.
STARTING - Enum constant in enum class com.iantapply.orchestra.api.EventStatus: First stage is being prepared.
startNow(String) - Method in interface com.iantapply.orchestra.api.OrchestraService: Starts a known event immediately.
status() - Method in interface com.iantapply.orchestra.api.OrchestraService: Returns current platform-neutral administration status.
status() - Method in record class com.iantapply.orchestra.domain.EventExecution: Returns the value of the status record component.
subscribe(String, Consumer) - Method in interface com.iantapply.orchestra.port.NetworkTransport: Subscribes to a logical channel.
summary() - Method in record class com.iantapply.orchestra.api.OrchestraStatus: Returns one consistent human-readable status line for commands and logs.

T

tags() - Method in record class com.iantapply.orchestra.api.TargetSelector: Returns the value of the tags record component.
TargetResolver - Interface in com.iantapply.orchestra.port: Resolves declarative selectors against the current network topology.
targets() - Method in record class com.iantapply.orchestra.api.EventDefinition: Returns the value of the targets record component.
TargetSelector - Record Class in com.iantapply.orchestra.api: Selects target servers by identity, group, tags, or online status.
TargetSelector(Set, Set, Map, boolean) - Constructor for record class com.iantapply.orchestra.api.TargetSelector: Snapshots selector values and rejects an empty selector.
test(ConditionContext) - Method in interface com.iantapply.orchestra.api.OrchestraCondition: Evaluates whether a stage may execute.
timeout() - Method in record class com.iantapply.orchestra.api.StageDefinition: Returns the value of the timeout record component.
toString() - Method in record class com.iantapply.orchestra.api.ActionContext: Returns a string representation of this record class.
toString() - Method in record class com.iantapply.orchestra.api.ActionSpec: Returns a string representation of this record class.
toString() - Method in record class com.iantapply.orchestra.api.ConditionContext: Returns a string representation of this record class.
toString() - Method in record class com.iantapply.orchestra.api.ConditionSpec: Returns a string representation of this record class.
toString() - Method in record class com.iantapply.orchestra.api.EventDefinition: Returns a string representation of this record class.
toString() - Method in record class com.iantapply.orchestra.api.OrchestraStatus: Returns a string representation of this record class.
toString() - Method in record class com.iantapply.orchestra.api.RecurringSchedule: Returns a string representation of this record class.
toString() - Method in record class com.iantapply.orchestra.api.RetryPolicy: Returns a string representation of this record class.
toString() - Method in record class com.iantapply.orchestra.api.StageDefinition: Returns a string representation of this record class.
toString() - Method in record class com.iantapply.orchestra.api.TargetSelector: Returns a string representation of this record class.
toString() - Method in record class com.iantapply.orchestra.domain.EventExecution: Returns a string representation of this record class.
transition(EventStatus, int, Instant, Instant) - Method in record class com.iantapply.orchestra.domain.EventExecution: Creates the next version with a new lifecycle state.
tryAcquire(String, Duration) - Method in interface com.iantapply.orchestra.port.DistributedLock: Attempts to claim a key for a bounded duration without waiting.
type() - Method in record class com.iantapply.orchestra.api.ActionSpec: Returns the value of the type record component.
type() - Method in record class com.iantapply.orchestra.api.ConditionSpec: Returns the value of the type record component.

U

updatedAt() - Method in record class com.iantapply.orchestra.domain.EventExecution: Returns the value of the updatedAt record component.

V

valueOf(String) - Static method in enum class com.iantapply.orchestra.api.EventStatus: Returns the enum constant of this class with the specified name.
values() - Static method in enum class com.iantapply.orchestra.api.EventStatus: Returns an array containing the constants of this enum class, in the order they are declared.
variables() - Method in record class com.iantapply.orchestra.api.ActionContext: Returns the value of the variables record component.
variables() - Method in record class com.iantapply.orchestra.api.ConditionContext: Returns the value of the variables record component.
variables() - Method in record class com.iantapply.orchestra.domain.EventExecution: Returns the value of the variables record component.
version() - Method in record class com.iantapply.orchestra.domain.EventExecution: Returns the value of the version record component.

W

withCompletedAction(String, Instant) - Method in record class com.iantapply.orchestra.domain.EventExecution: Records one action as durably completed.
withFailure(String, Instant) - Method in record class com.iantapply.orchestra.domain.EventExecution: Creates a failed copy of this execution.
withVariables(Map, Instant) - Method in record class com.iantapply.orchestra.domain.EventExecution: Replaces the complete variable snapshot.

Z

zone() - Method in record class com.iantapply.orchestra.api.RecurringSchedule: Returns the value of the zone record component.

A C D E F G H I M N O P Q R S T U V W Z
All Classes and Interfaces|All Packages