Index (orchestra-core 1.1.1 API)

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

A

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.
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.
activeExecutions(int) - Method in class com.iantapply.orchestra.administration.DefaultOrchestraService
activeWorkerCount() - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Returns the number of workers currently executing a task.
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.administration.DefaultOrchestraService
addListener(EventLifecycleListener) - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Registers a lifecycle listener.
ADMINISTRATOR - Enum constant in enum class com.iantapply.orchestra.security.Role: Every available permission.
allows(Permission) - Method in enum class com.iantapply.orchestra.security.Role: Tests whether this role includes a permission.
append(AuditEntry) - Method in interface com.iantapply.orchestra.audit.AuditRepository: Persists an audit entry.
append(AuditEntry) - Method in class com.iantapply.orchestra.audit.InMemoryAuditRepository
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.administration.DefaultOrchestraService
cancel(UUID) - Method in class com.iantapply.orchestra.administration.OrchestraAdministrationService: Cancels one execution when its current state permits it.
cancel(UUID) - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Cancels an execution.
close() - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Stops polling and shuts down engine workers.
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.administration - package com.iantapply.orchestra.administration: Platform-neutral administration operations, status snapshots, and validation results.
com.iantapply.orchestra.audit - package com.iantapply.orchestra.audit: Immutable audit records and repository contracts.
com.iantapply.orchestra.configuration - package com.iantapply.orchestra.configuration: Shared resolution of external configuration, environment overrides, and secret files.
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.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.
condition(String) - Method in class com.iantapply.orchestra.engine.ActionRegistry: Looks up a registered condition.
ConfigurationValueResolver - Class in com.iantapply.orchestra.configuration: Resolves configured values consistently from system properties, environment, files, and inline values.
ConfigurationValueResolver(Path) - Constructor for class com.iantapply.orchestra.configuration.ConfigurationValueResolver: Uses the current process environment and system properties.
ConfigurationValueResolver(Path, Map, Function) - Constructor for class com.iantapply.orchestra.configuration.ConfigurationValueResolver: Creates a resolver with injectable process sources for platforms and tests.
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

DefaultOrchestraService - Class in com.iantapply.orchestra.administration: Default platform-neutral implementation of the public administration facade.
DefaultOrchestraService(OrchestratorEngine, ActionRegistry, DefinitionRepository, ExecutionRepository) - Constructor for class com.iantapply.orchestra.administration.DefaultOrchestraService: Creates a facade over one fully wired engine and its repositories.
defaults(int, int) - Static method in record class com.iantapply.orchestra.engine.EngineOptions: Returns production defaults with the supplied worker and queue bounds.
definitions() - Method in class com.iantapply.orchestra.administration.DefaultOrchestraService
definitions() - Method in record class com.iantapply.orchestra.administration.DefinitionValidationReport: Returns the value of the definitions record component.
DefinitionValidationReport - Record Class in com.iantapply.orchestra.administration: Immutable definition-validation result shared by CLI and platform administration adapters.
DefinitionValidationReport(List, List) - Constructor for record class com.iantapply.orchestra.administration.DefinitionValidationReport: Snapshots report collections.
detail() - Method in record class com.iantapply.orchestra.audit.AuditEntry: Returns the value of the detail record component.

E

EngineOptions - Record Class in com.iantapply.orchestra.engine: Tunable orchestration limits and timing values.
EngineOptions(int, int, Duration, int, Duration, Duration) - Constructor for record class com.iantapply.orchestra.engine.EngineOptions: Validates that every capacity and duration is positive.
equals(Object) - Method in record class com.iantapply.orchestra.administration.DefinitionValidationReport: 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.engine.EngineOptions: 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.
errors() - Method in record class com.iantapply.orchestra.administration.DefinitionValidationReport: Returns the value of the errors record component.
events() - Method in class com.iantapply.orchestra.administration.OrchestraAdministrationService: Returns registered event definitions in deterministic identifier order.
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.
execution(UUID) - Method in class com.iantapply.orchestra.administration.DefaultOrchestraService
executions(int) - Method in class com.iantapply.orchestra.administration.OrchestraAdministrationService: Returns active execution snapshots up to the requested limit.

G

gauge(String, DoubleSupplier) - Method in class com.iantapply.orchestra.metrics.MetricsRegistry: Registers or replaces a lazily evaluated gauge.

H

hashCode() - Method in record class com.iantapply.orchestra.administration.DefinitionValidationReport: 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.engine.EngineOptions: 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.security.Actor: Returns the value of the id record component.
increment(String) - Method in class com.iantapply.orchestra.metrics.MetricsRegistry: Increments a counter by one.
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.

L

leaseDuration() - Method in record class com.iantapply.orchestra.engine.EngineOptions: Returns the value of the leaseDuration record component.

M

matches(Instant, ZoneId) - Method in class com.iantapply.orchestra.schedule.CronExpression: Tests one instant against this expression.
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.
movePlayer(String, String) - Method in interface com.iantapply.orchestra.velocity.ProxyFacade: Requests that a player connect to a backend server.
movePlayer(String, String, String) - Method in class com.iantapply.orchestra.velocity.ProxyCommandPublisher: Requests that a proxy move a player to a backend server.

N

nextAfter(Instant, ZoneId) - Method in class com.iantapply.orchestra.schedule.CronExpression: Finds the next matching minute.

O

occurredAt() - Method in record class com.iantapply.orchestra.audit.AuditEntry: Returns the value of the occurredAt record component.
onlinePlayers() - Method in interface com.iantapply.orchestra.velocity.ProxyFacade: Counts connected players.
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.
OrchestraAdministrationService - Class in com.iantapply.orchestra.administration: Platform-neutral operations used by administrative command and HTTP adapters.
OrchestraAdministrationService(OrchestraService, DefinitionRepository, Supplier) - Constructor for class com.iantapply.orchestra.administration.OrchestraAdministrationService: Creates the administration facade.
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(InetSocketAddress, MetricsRegistry, Map, OrchestraHttpServer.EventTrigger, AuditRepository, Clock) - Constructor for class com.iantapply.orchestra.web.OrchestraHttpServer: Creates the HTTP listener with durable operation auditing.
OrchestraHttpServer.EventTrigger - Interface in com.iantapply.orchestra.web: Callback used by the HTTP adapter to create an immediate event execution.
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.
OrchestratorEngine(DefinitionRepository, ExecutionRepository, DistributedLock, TargetResolver, ActionRegistry, Clock, EngineOptions) - Constructor for class com.iantapply.orchestra.engine.OrchestratorEngine: Creates an engine with explicit operational timing and capacity options.
OrchestratorEngine(DefinitionRepository, ExecutionRepository, DistributedLock, TargetResolver, ActionRegistry, Clock, EngineOptions, Consumer) - Constructor for class com.iantapply.orchestra.engine.OrchestratorEngine: Creates an engine whose operational failure paths increment named counters.

P

pause(UUID) - Method in class com.iantapply.orchestra.administration.DefaultOrchestraService
pause(UUID) - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Pauses an execution.
Permission - Enum Class in com.iantapply.orchestra.security: Fine-grained operations that may be granted through a Role.
pollBatchSize() - Method in record class com.iantapply.orchestra.engine.EngineOptions: Returns the value of the pollBatchSize record component.
pollInterval() - Method in record class com.iantapply.orchestra.engine.EngineOptions: Returns the value of the pollInterval record component.
prometheus() - Method in class com.iantapply.orchestra.metrics.MetricsRegistry: Renders all current metric values.
ProxyCommandPublisher - Class in com.iantapply.orchestra.velocity: Publishes validated commands understood by a configured Velocity agent.
ProxyCommandPublisher(NetworkTransport) - Constructor for class com.iantapply.orchestra.velocity.ProxyCommandPublisher: Creates a publisher over the shared network transport.
ProxyFacade - Interface in com.iantapply.orchestra.velocity: Platform-neutral proxy operations used by the Velocity transport agent.

Q

queueCapacity() - Method in record class com.iantapply.orchestra.engine.EngineOptions: Returns the value of the queueCapacity record component.
queuedTaskCount() - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Returns the number of execution tasks currently waiting for a worker.

R

readSecretFile(String) - Method in class com.iantapply.orchestra.configuration.ConfigurationValueResolver: Reads an optional UTF-8 secret file, resolving relative paths against the base directory.
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.
RecurringEventScheduler(DefinitionRepository, OrchestratorEngine, DistributedLock, Clock, Consumer) - Constructor for class com.iantapply.orchestra.schedule.RecurringEventScheduler: Creates a scheduler with an operational failure counter sink.
registerAction(String, OrchestraAction) - Method in class com.iantapply.orchestra.administration.DefaultOrchestraService
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.administration.DefaultOrchestraService
registerCondition(String, OrchestraCondition) - Method in class com.iantapply.orchestra.engine.ActionRegistry: Registers a unique condition type.
registerDefinition(EventDefinition) - Method in class com.iantapply.orchestra.administration.DefaultOrchestraService
reload() - Method in class com.iantapply.orchestra.administration.OrchestraAdministrationService: Atomically replaces definitions only when the complete validation succeeds.
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.
require(String, String, String, String, String) - Method in class com.iantapply.orchestra.configuration.ConfigurationValueResolver: Resolves a required value or reports its configuration label.
requireTransition(EventStatus, EventStatus) - Method in class com.iantapply.orchestra.engine.EventStateMachine: Rejects a transition that is not present in the transition graph.
resolve(String, String, String) - Method in class com.iantapply.orchestra.configuration.ConfigurationValueResolver: Resolves environment, file, then inline precedence without a system-property override.
resolve(String, String, String, String) - Method in class com.iantapply.orchestra.configuration.ConfigurationValueResolver: Resolves the first nonblank value using system property, environment, file, then inline precedence.
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.administration.DefaultOrchestraService
resume(UUID) - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Resumes an execution.
retry(UUID) - Method in class com.iantapply.orchestra.administration.DefaultOrchestraService
retry(UUID) - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Reschedules a failed execution from its first stage.
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.

S

schedule(String, Instant, Map) - Method in class com.iantapply.orchestra.administration.DefaultOrchestraService
schedule(String, Instant, Map) - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Creates a durable execution for a known definition.
setGroupJoins(String, boolean) - Method in interface com.iantapply.orchestra.velocity.ProxyFacade: Publishes or applies the requested join state for a server group.
setGroupJoins(String, String, boolean) - Method in class com.iantapply.orchestra.velocity.ProxyCommandPublisher: Requests that a proxy update the advertised join state for a server group.
setVariable(UUID, String, Object) - Method in class com.iantapply.orchestra.administration.DefaultOrchestraService
setVariable(UUID, String, Object) - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Atomically sets or removes an execution variable.
shutdownTimeout() - Method in record class com.iantapply.orchestra.engine.EngineOptions: Returns the value of the shutdownTimeout 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 class com.iantapply.orchestra.administration.OrchestraAdministrationService: Starts one registered event immediately.
start(String) - Method in interface com.iantapply.orchestra.web.OrchestraHttpServer.EventTrigger: Starts a loaded event definition.
startNow(String) - Method in class com.iantapply.orchestra.administration.DefaultOrchestraService
startNow(String) - Method in class com.iantapply.orchestra.engine.OrchestratorEngine: Schedules an event immediately with no initial variables.
status() - Method in class com.iantapply.orchestra.administration.DefaultOrchestraService
status() - Method in class com.iantapply.orchestra.administration.OrchestraAdministrationService: Returns current operational status.
summary() - Method in record class com.iantapply.orchestra.administration.DefinitionValidationReport: Returns one consistent human-readable validation summary.

T

toString() - Method in record class com.iantapply.orchestra.administration.DefinitionValidationReport: 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.engine.EngineOptions: 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.

V

valid() - Method in record class com.iantapply.orchestra.administration.DefinitionValidationReport: Returns whether every inspected definition was valid.
validate() - Method in class com.iantapply.orchestra.administration.OrchestraAdministrationService: Validates definitions without modifying the running service.
validateSchedule(EventDefinition) - Static method in class com.iantapply.orchestra.schedule.RecurringEventScheduler: Parses a definition's cron expression so invalid schedules fail during definition loading.
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.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.
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.
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

workerCount() - Method in record class com.iantapply.orchestra.engine.EngineOptions: Returns the value of the workerCount record component.

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