Index (Orchestra 1.0.0 API)

A C D E F G H I J L M N O P R S T U V W Y 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.
action() - Method in record class com.iantapply.orchestra.audit.AuditEntry: Returns the value of the action record component.
action(String) - Method in class com.iantapply.orchestra.engine.ActionRegistry: Looks up a registered action.
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.
ActionRegistry - Class in com.iantapply.orchestra.engine: Thread-safe registry of named action and condition extensions.
ActionRegistry() - Constructor for class com.iantapply.orchestra.engine.ActionRegistry: Creates an empty registry.
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.
actor() - Method in record class com.iantapply.orchestra.audit.AuditEntry: Returns the value of the actor record component.
Actor - Record Class in com.iantapply.orchestra.security: Authenticated principal and its assigned role.
Actor(String, Role) - Constructor for record class com.iantapply.orchestra.security.Actor: Validates that the actor has a usable identifier.
addListener(EventLifecycleListener) - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Registers a lifecycle listener.
ADMIN - Enum constant in enum class com.iantapply.orchestra.security.Permission: Perform unrestricted administrative operations.
ADMINISTRATOR - Enum constant in enum class com.iantapply.orchestra.security.Role: Every available permission.
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.
allows(Permission) - Method in enum class com.iantapply.orchestra.security.Role: Tests whether this role includes a permission.
append(AuditEntry) - Method in class com.iantapply.orchestra.adapter.postgres.PostgresAuditRepository
append(AuditEntry) - Method in interface com.iantapply.orchestra.audit.AuditRepository: Persists an audit entry.
append(AuditEntry) - Method in class com.iantapply.orchestra.audit.InMemoryAuditRepository
APPROVE - Enum constant in enum class com.iantapply.orchestra.security.Permission: Approve a protected operation.
APPROVER - Enum constant in enum class com.iantapply.orchestra.security.Role: Read and approval access.
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.
AuditEntry - Record Class in com.iantapply.orchestra.audit: Immutable record of an operator or API operation.
AuditEntry(Instant, String, String, String, String, String) - Constructor for record class com.iantapply.orchestra.audit.AuditEntry: Creates an instance of a AuditEntry record class.
AuditRepository - Interface in com.iantapply.orchestra.audit: Stores immutable audit entries in newest-first query order.

C

cancel(UUID) - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Cancels an execution.
CANCELLED - Enum constant in enum class com.iantapply.orchestra.api.EventStatus: Execution was explicitly terminated.
classloader(PluginClasspathBuilder) - Method in class com.iantapply.orchestra.platform.paper.OrchestraLoader: Adds HikariCP and the PostgreSQL driver to the Paper plugin classpath.
close() - Method in class com.iantapply.orchestra.adapter.redis.RedisTransport
close() - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Stops polling and shuts down engine workers.
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.
close() - Method in class com.iantapply.orchestra.schedule.RecurringEventScheduler: Stops future recurring schedule checks.
close() - Method in class com.iantapply.orchestra.velocity.VelocityAgent: Stops heartbeats and closes the command subscription.
close() - Method in class com.iantapply.orchestra.web.OrchestraHttpServer: Stops accepting requests after a one-second grace period.
com.iantapply.orchestra.adapter.memory - package com.iantapply.orchestra.adapter.memory: Thread-safe in-memory adapters for local operation and tests.
com.iantapply.orchestra.adapter.postgres - package com.iantapply.orchestra.adapter.postgres: PostgreSQL migrations and durable repository implementations.
com.iantapply.orchestra.adapter.redis - package com.iantapply.orchestra.adapter.redis: Minimal RESP transport and ownership-token distributed leases for Redis.
com.iantapply.orchestra.adapter.yaml - package com.iantapply.orchestra.adapter.yaml: YAML event-definition parsing and scalar conversion.
com.iantapply.orchestra.api - package com.iantapply.orchestra.api: Stable extension points and immutable event-definition types exposed to plugin developers.
com.iantapply.orchestra.audit - package com.iantapply.orchestra.audit: Immutable audit records and repository contracts.
com.iantapply.orchestra.domain - package com.iantapply.orchestra.domain: Runtime state persisted by Orchestra repositories.
com.iantapply.orchestra.engine - package com.iantapply.orchestra.engine: Platform-independent workflow scheduling and execution.
com.iantapply.orchestra.metrics - package com.iantapply.orchestra.metrics: Low-overhead application metrics and Prometheus text exposition.
com.iantapply.orchestra.platform.paper - package com.iantapply.orchestra.platform.paper: Paper plugin lifecycle, targeting, and server-local behavior.
com.iantapply.orchestra.platform.paper.action - package com.iantapply.orchestra.platform.paper.action: Paper and Folia implementations of built-in event actions.
com.iantapply.orchestra.platform.velocity - package com.iantapply.orchestra.platform.velocity: Velocity bootstrap and proxy facade for Orchestra network commands.
com.iantapply.orchestra.port - package com.iantapply.orchestra.port: Infrastructure contracts implemented by storage, coordination, and discovery adapters.
com.iantapply.orchestra.schedule - package com.iantapply.orchestra.schedule: Recurring cron evaluation and distributed occurrence dispatch.
com.iantapply.orchestra.security - package com.iantapply.orchestra.security: Authentication principals, roles, and permission checks.
com.iantapply.orchestra.velocity - package com.iantapply.orchestra.velocity: Transport-independent Velocity heartbeat and command agent.
com.iantapply.orchestra.web - package com.iantapply.orchestra.web: Authenticated REST API, embedded web status page, and Prometheus exposition.
compareAndSet(long, EventExecution) - Method in class com.iantapply.orchestra.adapter.memory.InMemoryStores
compareAndSet(long, EventExecution) - Method in class com.iantapply.orchestra.adapter.postgres.PostgresExecutionRepository
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.
condition(String) - Method in class com.iantapply.orchestra.engine.ActionRegistry: Looks up a registered condition.
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 class com.iantapply.orchestra.adapter.memory.InMemoryStores
create(EventExecution) - Method in class com.iantapply.orchestra.adapter.postgres.PostgresExecutionRepository
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.
CronExpression - Class in com.iantapply.orchestra.schedule: Five-field cron parser supporting wildcards, lists, ranges, steps, and English month/day names.
CronExpression(String) - Constructor for class com.iantapply.orchestra.schedule.CronExpression: Parses a five-field cron expression.

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.
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.
delayBefore(int) - Method in record class com.iantapply.orchestra.api.RetryPolicy: Computes the delay before a one-based attempt number.
DEPLOY - Enum constant in enum class com.iantapply.orchestra.security.Permission: Deploy event configuration.
detail() - Method in record class com.iantapply.orchestra.audit.AuditEntry: Returns the value of the detail record component.
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.
DurationParser - Class in com.iantapply.orchestra.adapter.yaml: Parses compact event-duration values such as 500ms, 5m, or 2h30m.

E

engine() - Method in class com.iantapply.orchestra.platform.paper.OrchestraPlugin: Exposes the active engine to other plugins.
equals(Object) - Method in record class com.iantapply.orchestra.adapter.postgres.PostgresSettings: Indicates whether some other object is "equal to" this one.
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.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.audit.AuditEntry: 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.
equals(Object) - Method in record class com.iantapply.orchestra.platform.paper.ServerIdentity: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.iantapply.orchestra.security.Actor: 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.
EventStateMachine - Class in com.iantapply.orchestra.engine: Validates legal transitions between persisted execution states.
EventStateMachine() - Constructor for class com.iantapply.orchestra.engine.EventStateMachine: Creates a validator for the fixed Orchestra transition graph.
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.
executeGlobal(Plugin, Runnable) - Static method in class com.iantapply.orchestra.platform.paper.FoliaSupport: Executes work through the global-region scheduler available on Paper and Folia.
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 class com.iantapply.orchestra.adapter.memory.InMemoryStores
find(String) - Method in interface com.iantapply.orchestra.port.DefinitionRepository: Finds one definition.
find(UUID) - Method in class com.iantapply.orchestra.adapter.memory.InMemoryStores
find(UUID) - Method in class com.iantapply.orchestra.adapter.postgres.PostgresExecutionRepository
find(UUID) - Method in interface com.iantapply.orchestra.port.ExecutionRepository: Finds one execution.
findActive(int) - Method in class com.iantapply.orchestra.adapter.memory.InMemoryStores
findActive(int) - Method in class com.iantapply.orchestra.adapter.postgres.PostgresExecutionRepository
findActive(int) - Method in interface com.iantapply.orchestra.port.ExecutionRepository: Finds execution state eligible for startup recovery.
findAll() - Method in class com.iantapply.orchestra.adapter.memory.InMemoryStores
findAll() - Method in interface com.iantapply.orchestra.port.DefinitionRepository: Lists known definitions.
findDue(Instant, int) - Method in class com.iantapply.orchestra.adapter.memory.InMemoryStores
findDue(Instant, int) - Method in class com.iantapply.orchestra.adapter.postgres.PostgresExecutionRepository
findDue(Instant, int) - Method in interface com.iantapply.orchestra.port.ExecutionRepository: Finds runnable work due on or before a time.
FoliaSupport - Class in com.iantapply.orchestra.platform.paper: Small compatibility layer for Paper and Folia scheduler behavior.
from(FileConfiguration) - Static method in record class com.iantapply.orchestra.platform.paper.ServerIdentity: Loads a server identity from plugin configuration.

G

gauge(String, DoubleSupplier) - Method in class com.iantapply.orchestra.metrics.MetricsRegistry: Registers or replaces a lazily evaluated gauge.
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.
groups() - Method in record class com.iantapply.orchestra.platform.paper.ServerIdentity: Returns the value of the groups record component.

H

hashCode() - Method in record class com.iantapply.orchestra.adapter.postgres.PostgresSettings: Returns a hash code value for this object.
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.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.audit.AuditEntry: 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.
hashCode() - Method in record class com.iantapply.orchestra.platform.paper.ServerIdentity: Returns a hash code value for this object.
hashCode() - Method in record class com.iantapply.orchestra.security.Actor: 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.
id() - Method in record class com.iantapply.orchestra.platform.paper.ServerIdentity: Returns the value of the id record component.
id() - Method in record class com.iantapply.orchestra.security.Actor: 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.
increment(String) - Method in class com.iantapply.orchestra.metrics.MetricsRegistry: Increments a counter by one.
initialDelay() - Method in record class com.iantapply.orchestra.api.RetryPolicy: Returns the value of the initialDelay record component.
InMemoryAuditRepository - Class in com.iantapply.orchestra.audit: Thread-safe bounded audit repository for local operation and tests.
InMemoryAuditRepository(int) - Constructor for class com.iantapply.orchestra.audit.InMemoryAuditRepository: Creates a repository that evicts the oldest entry when full.
InMemoryStores - Class in com.iantapply.orchestra.adapter.memory: Thread-safe in-memory implementation of the core stores and lease provider.
InMemoryStores() - Constructor for class com.iantapply.orchestra.adapter.memory.InMemoryStores: Creates empty in-memory definition, execution, and lease stores.
isFolia() - Static method in class com.iantapply.orchestra.platform.paper.FoliaSupport: Detects the active scheduler implementation.

J

jdbcUrl() - Method in record class com.iantapply.orchestra.adapter.postgres.PostgresSettings: Returns the value of the jdbcUrl record component.
JoinGate - Class in com.iantapply.orchestra.platform.paper: Thread-safe server-local gate that rejects new connections while disabled.
JoinGate() - Constructor for class com.iantapply.orchestra.platform.paper.JoinGate: Creates an enabled join gate.

L

load(Path) - Method in class com.iantapply.orchestra.adapter.yaml.YamlEventLoader: Loads one event definition.

M

matches(Instant, ZoneId) - Method in class com.iantapply.orchestra.schedule.CronExpression: Tests one instant against this expression.
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.
maximumPoolSize() - Method in record class com.iantapply.orchestra.adapter.postgres.PostgresSettings: Returns the value of the maximumPoolSize record component.
MetricsRegistry - Class in com.iantapply.orchestra.metrics: Thread-safe registry that renders counters and gauges in Prometheus text format.
MetricsRegistry() - Constructor for class com.iantapply.orchestra.metrics.MetricsRegistry: Creates an empty metrics registry.
migrate() - Method in class com.iantapply.orchestra.adapter.postgres.MigrationRunner: Applies all bundled schema statements in one transaction.
MigrationRunner - Class in com.iantapply.orchestra.adapter.postgres: Applies the bundled, idempotent Orchestra PostgreSQL schema migration.
MigrationRunner(DataSource) - Constructor for class com.iantapply.orchestra.adapter.postgres.MigrationRunner: Creates a migration runner.
movePlayer(String, String) - Method in interface com.iantapply.orchestra.velocity.ProxyFacade: Requests that a player connect to a backend server.
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.
nextAfter(Instant, ZoneId) - Method in class com.iantapply.orchestra.schedule.CronExpression: Finds the next matching minute.
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

occurredAt() - Method in record class com.iantapply.orchestra.audit.AuditEntry: Returns the value of the occurredAt record component.
onDisable() - Method in class com.iantapply.orchestra.platform.paper.OrchestraPlugin: Stops the engine and closes owned resources in reverse creation order.
onEnable() - Method in class com.iantapply.orchestra.platform.paper.OrchestraPlugin: Wires infrastructure, loads definitions, recovers work, and starts services.
onInitialize(ProxyInitializeEvent) - Method in class com.iantapply.orchestra.platform.velocity.OrchestraVelocityPlugin: Starts Redis transport and the proxy command agent.
onlinePlayers() - Method in interface com.iantapply.orchestra.velocity.ProxyFacade: Counts connected players.
onLogin(PlayerConnectionValidateLoginEvent) - Method in class com.iantapply.orchestra.platform.paper.JoinGate: Rejects a login early when event operations have disabled joins.
onShutdown(ProxyShutdownEvent) - Method in class com.iantapply.orchestra.platform.velocity.OrchestraVelocityPlugin: Stops the proxy agent and Redis transport.
onTransition(EventExecution, EventExecution) - Method in interface com.iantapply.orchestra.api.EventLifecycleListener: Handles a transition after the updated execution has been persisted.
openDataSource() - Method in record class com.iantapply.orchestra.adapter.postgres.PostgresSettings: Opens a configured connection pool.
OPERATE - Enum constant in enum class com.iantapply.orchestra.security.Permission: Start, pause, resume, cancel, or retry executions.
OPERATOR - Enum constant in enum class com.iantapply.orchestra.security.Role: Read and execution-operation access.
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.
OrchestraHttpServer - Class in com.iantapply.orchestra.web: Small authenticated HTTP server exposing health and Prometheus metrics.
OrchestraHttpServer(InetSocketAddress, MetricsRegistry, Map, OrchestraHttpServer.EventTrigger) - Constructor for class com.iantapply.orchestra.web.OrchestraHttpServer: Creates the HTTP listener without starting it.
OrchestraHttpServer.EventTrigger - Interface in com.iantapply.orchestra.web: Callback used by the HTTP adapter to create an immediate event execution.
OrchestraLoader - Class in com.iantapply.orchestra.platform.paper: Resolves runtime database libraries through Paper's plugin classpath loader.
OrchestraLoader() - Constructor for class com.iantapply.orchestra.platform.paper.OrchestraLoader: Creates the Paper classpath loader.
OrchestraPlugin - Class in com.iantapply.orchestra.platform.paper: Paper entry point.
OrchestraPlugin() - Constructor for class com.iantapply.orchestra.platform.paper.OrchestraPlugin: Creates the Paper plugin entry point.
OrchestratorEngine - Class in com.iantapply.orchestra.engine: Durable, at-least-once orchestration engine.
OrchestratorEngine(DefinitionRepository, ExecutionRepository, DistributedLock, TargetResolver, ActionRegistry, Clock, int, int) - Constructor for class com.iantapply.orchestra.engine.OrchestratorEngine: Creates an engine with bounded worker concurrency and queue capacity.
OrchestraVelocityPlugin - Class in com.iantapply.orchestra.platform.velocity: Velocity bootstrap for the proxy-side Orchestra agent.
OrchestraVelocityPlugin(ProxyServer, Logger) - Constructor for class com.iantapply.orchestra.platform.velocity.OrchestraVelocityPlugin: Creates the Velocity entry point.

P

PaperActionRegistrar - Class in com.iantapply.orchestra.platform.paper.action: Registers actions and conditions implemented by a Paper server agent.
PaperActionRegistrar(Plugin, JoinGate) - Constructor for class com.iantapply.orchestra.platform.paper.action.PaperActionRegistrar: Creates a registrar for one backend.
PaperTargetResolver - Class in com.iantapply.orchestra.platform.paper: Resolves selectors against the identity of the current Paper server.
PaperTargetResolver(ServerIdentity) - Constructor for class com.iantapply.orchestra.platform.paper.PaperTargetResolver: Creates a local target resolver.
parse(Object) - Static method in class com.iantapply.orchestra.adapter.yaml.DurationParser: Parses a supported duration representation.
password() - Method in record class com.iantapply.orchestra.adapter.postgres.PostgresSettings: Returns the value of the password record component.
pause(UUID) - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Pauses an execution.
PAUSED - Enum constant in enum class com.iantapply.orchestra.api.EventStatus: Execution is suspended until explicitly resumed.
Permission - Enum Class in com.iantapply.orchestra.security: Fine-grained operations that may be granted through a Role.
PostgresAuditRepository - Class in com.iantapply.orchestra.adapter.postgres: PostgreSQL-backed audit repository.
PostgresAuditRepository(DataSource) - Constructor for class com.iantapply.orchestra.adapter.postgres.PostgresAuditRepository: Creates an audit repository.
PostgresExecutionRepository - Class in com.iantapply.orchestra.adapter.postgres: PostgreSQL execution repository with atomic version-checked updates.
PostgresExecutionRepository(DataSource) - Constructor for class com.iantapply.orchestra.adapter.postgres.PostgresExecutionRepository: Creates an execution repository.
PostgresSettings - Record Class in com.iantapply.orchestra.adapter.postgres: Validated PostgreSQL connection-pool settings.
PostgresSettings(String, String, String, int) - Constructor for record class com.iantapply.orchestra.adapter.postgres.PostgresSettings: Validates the JDBC URL and normalizes the pool size.
prometheus() - Method in class com.iantapply.orchestra.metrics.MetricsRegistry: Renders all current metric values.
ProxyFacade - Interface in com.iantapply.orchestra.velocity: Platform-neutral proxy operations used by the Velocity transport agent.
publish(String, byte[]) - Method in class com.iantapply.orchestra.adapter.redis.RedisTransport
publish(String, byte[]) - Method in interface com.iantapply.orchestra.port.NetworkTransport: Publishes one binary message.

R

recent(int) - Method in class com.iantapply.orchestra.adapter.postgres.PostgresAuditRepository
recent(int) - Method in interface com.iantapply.orchestra.audit.AuditRepository: Returns the most recent entries, newest first.
recent(int) - Method in class com.iantapply.orchestra.audit.InMemoryAuditRepository
recover() - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Immediately scans persisted state; called on startup to recover interrupted work.
RecurringEventScheduler - Class in com.iantapply.orchestra.schedule: Polls recurring definitions and uses distributed leases to emit each minute-level occurrence at most once across concurrently running nodes.
RecurringEventScheduler(DefinitionRepository, OrchestratorEngine, DistributedLock, Clock) - Constructor for class com.iantapply.orchestra.schedule.RecurringEventScheduler: Creates a distributed recurring-event dispatcher.
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.
RedisDistributedLock - Class in com.iantapply.orchestra.adapter.redis: Redis lease provider using atomic NX/PX acquisition and token-checked release.
RedisDistributedLock(URI, String) - Constructor for class com.iantapply.orchestra.adapter.redis.RedisDistributedLock: Creates a Redis-backed lease provider.
RedisTransport - Class in com.iantapply.orchestra.adapter.redis: Redis Pub/Sub transport with daemon subscription threads and reconnect handling.
RedisTransport(URI, String) - Constructor for class com.iantapply.orchestra.adapter.redis.RedisTransport: Creates a Redis Pub/Sub transport.
registerAction(String, OrchestraAction) - Method in class com.iantapply.orchestra.engine.ActionRegistry: Registers a unique action type.
registerCondition(String, OrchestraCondition) - Method in class com.iantapply.orchestra.engine.ActionRegistry: Registers a unique condition type.
registerInto(ActionRegistry) - Method in class com.iantapply.orchestra.platform.paper.action.PaperActionRegistrar: Registers built-in actions and conditions.
remoteAddress() - Method in record class com.iantapply.orchestra.audit.AuditEntry: Returns the value of the remoteAddress record component.
require(Permission) - Method in record class com.iantapply.orchestra.security.Actor: Requires this actor to hold a permission.
requireTransition(EventStatus, EventStatus) - Method in class com.iantapply.orchestra.engine.EventStateMachine: Rejects a transition that is not present in the transition graph.
resolve(TargetSelector) - Method in class com.iantapply.orchestra.platform.paper.PaperTargetResolver
resolve(TargetSelector) - Method in interface com.iantapply.orchestra.port.TargetResolver: Resolves a selector against current server state.
resource() - Method in record class com.iantapply.orchestra.audit.AuditEntry: Returns the value of the resource record component.
resume(UUID) - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Resumes an execution.
retry(UUID) - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Reschedules 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.
role() - Method in record class com.iantapply.orchestra.security.Actor: Returns the value of the role record component.
Role - Enum Class in com.iantapply.orchestra.security: Built-in role-to-permission mappings used by the HTTP API.
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 class com.iantapply.orchestra.adapter.memory.InMemoryStores
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 class com.iantapply.orchestra.engine.OrchestratorEngine: Creates a durable execution for a known definition.
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.
ServerIdentity - Record Class in com.iantapply.orchestra.platform.paper: Immutable identity and labels of one Paper server.
ServerIdentity(String, Set, Map) - Constructor for record class com.iantapply.orchestra.platform.paper.ServerIdentity: Snapshots group and tag collections.
servers() - Method in record class com.iantapply.orchestra.api.TargetSelector: Returns the value of the servers record component.
setEnabled(boolean) - Method in class com.iantapply.orchestra.platform.paper.JoinGate: Updates the gate state.
setGroupJoins(String, boolean) - Method in interface com.iantapply.orchestra.velocity.ProxyFacade: Publishes or applies the requested join state for a server group.
setVariable(UUID, String, Object) - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Atomically sets or removes an execution variable.
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.
start() - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Starts the due-execution polling loop once.
start() - Method in class com.iantapply.orchestra.schedule.RecurringEventScheduler: Starts the recurring schedule poller once.
start() - Method in class com.iantapply.orchestra.velocity.VelocityAgent: Starts command subscription and periodic proxy heartbeats once.
start() - Method in class com.iantapply.orchestra.web.OrchestraHttpServer: Starts accepting HTTP requests.
start(String) - Method in interface com.iantapply.orchestra.web.OrchestraHttpServer.EventTrigger: Starts a loaded event definition.
STARTING - Enum constant in enum class com.iantapply.orchestra.api.EventStatus: First stage is being prepared.
startNow(String) - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Schedules an event immediately with no initial variables.
status() - Method in record class com.iantapply.orchestra.domain.EventExecution: Returns the value of the status record component.
subscribe(String, Consumer) - Method in class com.iantapply.orchestra.adapter.redis.RedisTransport
subscribe(String, Consumer) - Method in interface com.iantapply.orchestra.port.NetworkTransport: Subscribes to a logical channel.

T

tags() - Method in record class com.iantapply.orchestra.api.TargetSelector: Returns the value of the tags record component.
tags() - Method in record class com.iantapply.orchestra.platform.paper.ServerIdentity: 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.adapter.postgres.PostgresSettings: Returns a string representation of this record class.
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.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.audit.AuditEntry: 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.
toString() - Method in record class com.iantapply.orchestra.platform.paper.ServerIdentity: Returns a string representation of this record class.
toString() - Method in record class com.iantapply.orchestra.security.Actor: 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 class com.iantapply.orchestra.adapter.memory.InMemoryStores
tryAcquire(String, Duration) - Method in class com.iantapply.orchestra.adapter.redis.RedisDistributedLock
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.
username() - Method in record class com.iantapply.orchestra.adapter.postgres.PostgresSettings: Returns the value of the username 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.
valueOf(String) - Static method in enum class com.iantapply.orchestra.security.Permission: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.iantapply.orchestra.security.Role: 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.
values() - Static method in enum class com.iantapply.orchestra.security.Permission: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.iantapply.orchestra.security.Role: 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.
VelocityAgent - Class in com.iantapply.orchestra.velocity: Transport-facing Velocity agent; a proxy bootstrap supplies the small ProxyFacade implementation.
VelocityAgent(String, NetworkTransport, ProxyFacade) - Constructor for class com.iantapply.orchestra.velocity.VelocityAgent: Creates a proxy agent.
version() - Method in record class com.iantapply.orchestra.domain.EventExecution: Returns the value of the version record component.
VIEW - Enum constant in enum class com.iantapply.orchestra.security.Permission: Read operational state and metrics.
VIEWER - Enum constant in enum class com.iantapply.orchestra.security.Role: Read-only access.

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.

Y

YamlEventLoader - Class in com.iantapply.orchestra.adapter.yaml: Loads and validates event definitions from Bukkit-compatible YAML files.
YamlEventLoader() - Constructor for class com.iantapply.orchestra.adapter.yaml.YamlEventLoader: Creates a stateless YAML event loader.

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 J L M N O P R S T U V W Y Z
All Classes and Interfaces|All Packages