Index (j7m-distributed-core 0.1.0-SNAPSHOT API)

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

A

abort(String, Instant) - Method in class org.j7m.middleware.distributed.RecoverableTransactions: Durably aborts only before a committed decision; committed transactions are completed instead.
ack(String, String, String, String, long, String, long, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Acknowledges only the exact live delivery receipt and current member generation.
ack(String, String, EventJournal.Cursor, long, long) - Method in class org.j7m.middleware.distributed.EventJournal: Advances the durable cursor monotonically and renews its committed-time lease.
ack(String, String, EventJournal.Cursor, long, Instant) - Method in class org.j7m.middleware.distributed.EventSubscriptions: Commits processed progress and renews the subscription lease.
ack(String, String, EventJournal.Cursor, long, Instant) - Method in class org.j7m.middleware.distributed.ExecutionEvents: Commits consumer progress and lease renewal.
acquire(String, String, String, long, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedResourceClient: Acquires a coordination/member/leader lease through quorum; keys distinguish these uses.
activate(long, String, String, byte[], Instant) - Method in class org.j7m.middleware.distributed.PartitionAdminClient: Activates the staged target only with a valid committed topology proof.
activationProof(String, long) - Method in class org.j7m.middleware.distributed.PartitionTopology: Issues a target activation proof only after a durable ownership cutover.
actor() - Method in record class org.j7m.middleware.distributed.DeadLetter: Returns the value of the actor record component.
address() - Method in class org.j7m.middleware.distributed.PartitionServer: Returns bound service address.
address() - Method in class org.j7m.middleware.distributed.RemoteResourceServer: Returns the listening address.
administrative() - Method in record class org.j7m.middleware.distributed.PartitionServer.Binding: Returns the value of the administrative record component.
advanceTime(String, Instant) - Method in class org.j7m.middleware.distributed.PartitionResourceEndpoint: Commits host-generated measured logical time using an explicitly authorized time-service identity.
advanceTime(String, Instant) - Method in class org.j7m.middleware.distributed.RemoteResourceClient: Commits host-generated measured logical time using an explicitly authorized time-service identity.
advanceTime(String, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedResourceClient: Commits measured logical time; an unsafe or uncertain clock never advances it.
advanceTime(String, Instant) - Method in interface org.j7m.middleware.distributed.ResourceEndpoint: Commits host-generated measured logical time using an explicitly authorized time-service identity.
append(String, long, String, String, byte[]) - Method in class org.j7m.middleware.distributed.EventJournal: Appends a change inside the source's committed atomic batch and evicts bounded oldest history.
appliedThrough(long) - Method in class org.j7m.middleware.distributed.ExecutionStateMachine
appliedThrough(long) - Method in class org.j7m.middleware.distributed.PartitionStateMachine
appliedThrough(long) - Method in class org.j7m.middleware.distributed.PartitionTopology
appliedThrough(long) - Method in class org.j7m.middleware.distributed.QueueStateMachine
appliedThrough(long) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Advances the applied watermark across log entries that carry no resource mutation.
apply(long, byte[]) - Method in class org.j7m.middleware.distributed.ExecutionStateMachine
apply(long, byte[]) - Method in class org.j7m.middleware.distributed.PartitionStateMachine
apply(long, byte[]) - Method in class org.j7m.middleware.distributed.PartitionTopology
apply(long, byte[]) - Method in class org.j7m.middleware.distributed.QueueStateMachine
apply(long, byte[]) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Applies a committed resource command at a strictly advancing log index without term metadata.
apply(long, long, byte[]) - Method in class org.j7m.middleware.distributed.PartitionStateMachine
apply(long, long, byte[]) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Applies a validated committed command with the consensus term needed by resource fencing.
arguments() - Method in record class org.j7m.middleware.distributed.ResourceCommand: Returns the value of the arguments record component.
asMap() - Method in record class org.j7m.middleware.distributed.TraceCarrier: Exposes an immutable propagation map.
assignment(String, String, String, long) - Method in class org.j7m.middleware.distributed.QueueStateMachine: Returns current group generation and assigned queues for a live member.
assignment(String, String, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Reads a member's durable generation and assigned queue names through quorum.
attempt() - Method in record class org.j7m.middleware.distributed.QueueDelivery: Returns the value of the attempt record component.
attempts() - Method in record class org.j7m.middleware.distributed.DeadLetter: Returns the value of the attempts record component.
authenticationKey() - Method in record class org.j7m.middleware.distributed.RemoteResourceServer.Binding: Returns a defensive copy of the principal secret.

B

batch(String, List, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedResourceClient: Atomically applies CAS triples (key, expectedVersion, newValue).
begin(String) - Method in interface org.j7m.middleware.distributed.ExecutionClient.Observer: Opens one operation observation on the calling thread.
begin(String, Instant) - Method in class org.j7m.middleware.distributed.RecoverableTransactions: Begins a transaction with a durable PREPARING record.
beginHandoff(String, String, String, long, Instant) - Method in class org.j7m.middleware.distributed.PartitionAdminClient: Persists a handoff intent using an ownership epoch CAS.
Binding(String, byte[], boolean, boolean) - Constructor for record class org.j7m.middleware.distributed.PartitionServer.Binding: Validates and copies authentication material.
Binding(ResourceEndpoint, byte[], boolean) - Constructor for record class org.j7m.middleware.distributed.RemoteResourceServer.Binding: Validates and copies the secret; no request may override this binding.
bootstrapTime(long) - Method in class org.j7m.middleware.distributed.EventJournal: Moves pre-clock subscription expirations into the first committed wall-time epoch.

C

cancel(String, String, long, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedResourceClient: Cancels the exact lease version.
cancel(String, String, Instant) - Method in class org.j7m.middleware.distributed.DurableJobs: Cancels pending/running work and fences its previous owner.
catchUp(String, List, Instant) - Method in class org.j7m.middleware.distributed.PartitionAdminClient: Commits a verified consecutive suffix on a staged target.
changes() - Method in record class org.j7m.middleware.distributed.ResourceEvent: Returns effective upserts for a map projection.
checkpoint(String, String, String, long, String, Instant) - Method in class org.j7m.middleware.distributed.DurableJobs: Persists progress only for the exact live owner and fence.
child() - Method in record class org.j7m.middleware.distributed.DeadLetter: Returns the value of the child record component.
claim() - Method in record class org.j7m.middleware.distributed.ExecutionDelivery: Returns the value of the claim record component.
claim(String, String, String, long, boolean, Instant) - Method in class org.j7m.middleware.distributed.DeduplicatedRpc: Records an in-progress invocation before any non-atomic computation or external call.
claim(String, String, String, long, Instant) - Method in class org.j7m.middleware.distributed.DurableJobs: Claims unowned or expired work, issuing a globally increasing ownership fence.
claim(String, String, String, long, Instant) - Method in class org.j7m.middleware.distributed.DurableSagas: Claims a saga after prior ownership expires; unresolved non-idempotent intent yields UNKNOWN.
claim(String, String, String, String, long, long, boolean, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Claims with explicit EMPTY-result persistence; successful grants are always durable.
claim(String, String, String, String, long, long, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Claims the oldest unacknowledged eligible message for an assigned live member.
claims() - Method in record class org.j7m.middleware.distributed.PartitionServer.QueuePushStatistics: Returns the value of the claims record component.
ClockMeasurement(long, long, long, boolean) - Constructor for record class org.j7m.middleware.distributed.ReplicatedResourceClient.ClockMeasurement: Creates an instance of a ClockMeasurement record class.
close() - Method in interface org.j7m.middleware.distributed.ExecutionClient.Observation: Closes the observation and its calling-thread context.
close() - Method in class org.j7m.middleware.distributed.ExecutionSession: Closes future network delivery; native claims expire or complete through their own fence.
close() - Method in class org.j7m.middleware.distributed.LeaseTimeMaintenance
close() - Method in class org.j7m.middleware.distributed.PartitionServer
close() - Method in class org.j7m.middleware.distributed.QueueSession: Idempotently closes the socket without interrupting an actual subscriber callback.
close() - Method in class org.j7m.middleware.distributed.RemoteResourceServer: Stops accepting work and closes queued/active sockets; committed commands remain committed.
command() - Method in record class org.j7m.middleware.distributed.PartitionStateMachine.TailEntry: Returns independent command bytes.
command() - Method in record class org.j7m.middleware.distributed.ResourceEvent: Returns the value of the command record component.
commit(String, Instant) - Method in class org.j7m.middleware.distributed.RecoverableTransactions: Writes COMMIT only after all durably enlisted participants report PREPARED, then delivers it.
committedTicks() - Method in class org.j7m.middleware.distributed.LeaseTimeMaintenance: Returns committed maintenance ticks.
compareAndSet(String, String, long, String, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedCoordination: Performs a versioned CAS; missing keys have version zero.
compensate(String, String, String, long, String, boolean, Instant) - Method in class org.j7m.middleware.distributed.DurableSagas: Records a compensation attempt in reverse completed-step order before the external handler.
compensationResult(String, String, String, long, String, boolean, String, Instant) - Method in class org.j7m.middleware.distributed.DurableSagas: Records compensation success or schedules bounded exponential retry.
complete(String, String, String, long, String, String, List, Instant) - Method in class org.j7m.middleware.distributed.DeduplicatedRpc: Finishes a claim atomically with its protected CAS effects.
complete(String, String, String, long, String, List, Instant) - Method in class org.j7m.middleware.distributed.DurableJobs: Atomically completes work, result and protected-map CAS effects under its live fence.
complete(String, Instant) - Method in class org.j7m.middleware.distributed.PartitionAdminClient: Persists completed recovery state after target activation.
completed(ExecutionResult) - Method in interface org.j7m.middleware.distributed.ExecutionClient.Observation: Records the returned protocol outcome.
completeStep(String, String, String, long, String, String, List, Instant) - Method in class org.j7m.middleware.distributed.DurableSagas: Completes a step and optional protected-map effects atomically under the live owner fence.
context() - Method in record class org.j7m.middleware.distributed.ExecutionResult: Extracts the persisted W3C carrier for background worker context attachment.
continuation() - Method in record class org.j7m.middleware.distributed.DeadLetterPage: Returns the value of the continuation record component.
coordinator() - Method in record class org.j7m.middleware.distributed.RemoteResourceServer.Binding: Returns the value of the coordinator record component.
copy() - Method in class org.j7m.middleware.distributed.EventJournal: Copies state for an owning resource's copy-and-publish atomic mutation.
copyForTransfer() - Method in class org.j7m.middleware.distributed.ExecutionStateMachine: Creates a fully independent candidate with the same configuration and complete current state.
copyForTransfer() - Method in class org.j7m.middleware.distributed.QueueStateMachine: Creates a fully independent candidate with the same configuration and complete current state.
copyForTransfer() - Method in class org.j7m.middleware.distributed.ReplicatedResources: Creates a fully independent candidate with the same configuration and complete current state.
copyForTransfer() - Method in interface org.j7m.middleware.distributed.TransferableResource: Creates a fully independent candidate with the same configuration and complete current state.
cursor() - Method in record class org.j7m.middleware.distributed.EventJournal.Event: Returns the value of the cursor record component.
cursor() - Method in class org.j7m.middleware.distributed.ExecutionEvents.RunScan: Returns the event head captured atomically with the first page and upper identity.
cursor() - Method in record class org.j7m.middleware.distributed.ExecutionEvents.View: Returns the value of the cursor record component.
cursor() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.SnapshotTail: Returns the value of the cursor record component.
Cursor(String, long, long) - Constructor for record class org.j7m.middleware.distributed.EventJournal.Cursor: Validates the cursor.
cutover(String, long, String, Instant) - Method in class org.j7m.middleware.distributed.PartitionAdminClient: Atomically changes authoritative owner after caller verified the frozen source and target images.

D

DeadLetter - Record Class in org.j7m.middleware.distributed: Immutable dead-letter content and redrive audit lineage.
DeadLetter(String, byte[], long, long, int, int, String, String, String, int) - Constructor for record class org.j7m.middleware.distributed.DeadLetter: Validates finite metadata and copies content.
deadLetterPage(String, long, long, int, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Reads one bounded DLQ page within an initial high-water; zero requests the initial high-water.
deadLetterPage(String, DeadLetterPage, int, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Reads the next bounded page using its server-authenticated scope/partition-bound continuation.
DeadLetterPage - Record Class in org.j7m.middleware.distributed: One bounded page within a fixed initial sequence high-water.
DeadLetterPage(List, long, long) - Constructor for record class org.j7m.middleware.distributed.DeadLetterPage: Creates a trusted local page without a remote authentication token.
DeadLetterPage(List, long, long, String) - Constructor for record class org.j7m.middleware.distributed.DeadLetterPage: Validates monotonic bounded page metadata.
deadLetters(String, String, long) - Method in class org.j7m.middleware.distributed.QueueStateMachine: Returns the first 256 stable ordered dead-letter identities of a queue.
deadLetters(String, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Reads the first 256 ordered dead-letter identities, retained across ownership changes and restarts.
deadLetterSession(long, String, String, Instant) - Method in class org.j7m.middleware.distributed.PartitionClient: Observes retained dead letters through the same bounded credit protocol, without claiming a new receipt.
deadLetterStream(String, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Lazily traverses all initial DLQ entries with one page in memory and one original deadline.
decode(byte[]) - Static method in record class org.j7m.middleware.distributed.ExecutionResult: Decodes a full result without object deserialization.
decode(byte[]) - Static method in record class org.j7m.middleware.distributed.ResourceCommand: Validates an entire command before returning it; trailing bytes are rejected.
decode(byte[]) - Static method in record class org.j7m.middleware.distributed.ResourceEvent: Decodes and validates a full source event before returning any command.
DeduplicatedRpc - Class in org.j7m.middleware.distributed: Durable RPC invocation journal.
DeduplicatedRpc(ExecutionClient) - Constructor for class org.j7m.middleware.distributed.DeduplicatedRpc: Binds a scope-authorized execution transport.
depth() - Method in record class org.j7m.middleware.distributed.DeadLetter: Returns the value of the depth record component.
dispatchedRequests() - Method in class org.j7m.middleware.distributed.RemoteResourceServer: Counts dispatched authorized requests.
DurableJobs - Class in org.j7m.middleware.distributed: Durable scheduler operations over an ownership-fenced execution partition; no executor is hidden.
DurableJobs(ExecutionClient) - Constructor for class org.j7m.middleware.distributed.DurableJobs: Binds a scope-authorized execution client.
DurableSagas - Class in org.j7m.middleware.distributed: Durable saga protocol with explicit external-step intents, owner fences and bounded compensation retries.
DurableSagas(ExecutionClient) - Constructor for class org.j7m.middleware.distributed.DurableSagas: Binds a scope-authorized execution transport.
DurableSagas.StepResolution - Enum Class in org.j7m.middleware.distributed: Established no-effect failure versus an uncertain external outcome.

E

empty() - Static method in record class org.j7m.middleware.distributed.TraceCarrier: Returns a context-free carrier.
encode() - Method in record class org.j7m.middleware.distributed.ExecutionResult: Encodes a versioned bounded result.
encode() - Method in record class org.j7m.middleware.distributed.ResourceCommand: Encodes this immutable command in the version-one wire format.
encode() - Method in record class org.j7m.middleware.distributed.ResourceEvent: Encodes the source result and command without Java object serialization.
encodedBytes() - Method in record class org.j7m.middleware.distributed.ExecutionDelivery: Reports the actual owned encoded claim/input/checkpoint frame size for hosted admission.
encodedSize() - Method in class org.j7m.middleware.distributed.EventJournal: Computes the exact current snapshot byte count without serializing payloads.
endpoint() - Method in record class org.j7m.middleware.distributed.RemoteResourceServer.Binding: Returns the value of the endpoint record component.
endpoint() - Method in record class org.j7m.middleware.distributed.ReplicatedQueue.Route: Returns the value of the endpoint record component.
enlist(String, String, Instant) - Method in class org.j7m.middleware.distributed.RecoverableTransactions: Durably enlists a participant before any prepare is sent.
entries() - Method in record class org.j7m.middleware.distributed.DeadLetterPage: Returns the value of the entries record component.
epoch() - Method in record class org.j7m.middleware.distributed.EventJournal.Cursor: Returns the value of the epoch record component.
epoch() - Method in record class org.j7m.middleware.distributed.PartitionReply: Returns the value of the epoch record component.
epoch() - Method in record class org.j7m.middleware.distributed.PartitionStateMachine.Status: Returns the value of the epoch record component.
epoch() - Method in record class org.j7m.middleware.distributed.PartitionTopology.Route: Returns the value of the epoch record component.
epoch() - Method in record class org.j7m.middleware.distributed.ReplicatedQueue.Route: Returns the value of the epoch record component.
equals(Object) - Method in record class org.j7m.middleware.distributed.DeadLetter: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.DeadLetterPage: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.EventJournal.Cursor: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.EventJournal.Event: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.EventJournal.Page: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.ExecutionDelivery: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.ExecutionEvents.View: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.ExecutionResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.PartitionReply: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.PartitionServer.Binding: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.PartitionServer.QueuePushStatistics: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.PartitionStateMachine.Status: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.PartitionStateMachine.TailEntry: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.PartitionTopology.Handoff: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.PartitionTopology.Route: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.QueueDelivery: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.QueueStateMachine.Reply: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.RemoteResourceServer.Binding: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.ReplicatedQueue.Route: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.ReplicatedResourceClient.ClockMeasurement: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Event: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Lease: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Result: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.ReplicatedResources.SnapshotTail: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Value: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.ResourceCommand: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.ResourceEvent: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.j7m.middleware.distributed.TraceCarrier: Indicates whether some other object is "equal to" this one.
Event(long, String, String) - Constructor for record class org.j7m.middleware.distributed.ReplicatedResources.Event: Creates an instance of a Event record class.
Event(EventJournal.Cursor, String, String, byte[]) - Constructor for record class org.j7m.middleware.distributed.EventJournal.Event: Validates and copies a bounded event.
EventJournal - Class in org.j7m.middleware.distributed: Deterministic bounded event/subscription state, embedded in an owning resource's atomic commit and snapshot.
EventJournal(int, long) - Constructor for class org.j7m.middleware.distributed.EventJournal: Creates a journal whose retention is bounded by both event count and payload bytes.
EventJournal.Cursor - Record Class in org.j7m.middleware.distributed: Stable per-partition event position.
EventJournal.Event - Record Class in org.j7m.middleware.distributed: Immutable durable change; payload is copied on construction and access.
EventJournal.Page - Record Class in org.j7m.middleware.distributed: Bounded result page.
events() - Method in record class org.j7m.middleware.distributed.EventJournal.Page: Returns the value of the events record component.
events(String, long) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Returns an immutable event history for validation and future journal integration.
EventSubscriptions - Class in org.j7m.middleware.distributed: Typed subscription facade over an authorized map resource endpoint.
EventSubscriptions(ResourceEndpoint) - Constructor for class org.j7m.middleware.distributed.EventSubscriptions: Binds an authorized endpoint, local or remote.
execute(long, String, byte[], byte[], Instant) - Method in class org.j7m.middleware.distributed.LocalPartitionEndpoint: Commits a nested resource command under an ownership epoch.
execute(long, String, byte[], byte[], Instant) - Method in class org.j7m.middleware.distributed.PartitionClient: Commits a nested resource command under an ownership epoch.
execute(long, String, byte[], byte[], Instant) - Method in interface org.j7m.middleware.distributed.PartitionEndpoint: Commits a nested resource command under an ownership epoch.
execute(long, String, byte[], byte[], Instant) - Method in class org.j7m.middleware.distributed.RoutedPartitionEndpoint: Commits a nested resource command under an ownership epoch.
execute(String, String, List, Instant) - Method in class org.j7m.middleware.distributed.ExecutionClient: Submits an execution operation through the authoritative partition.
execute(String, String, List, Instant) - Method in class org.j7m.middleware.distributed.PartitionResourceEndpoint: Submits a version-one operation through the authoritative group's durable log.
execute(String, String, List, Instant) - Method in class org.j7m.middleware.distributed.RemoteResourceClient: Submits a version-one operation through the authoritative group's durable log.
execute(String, String, List, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedResourceClient: Submits a version-one operation through the authoritative group's durable log.
execute(String, String, List, Instant) - Method in interface org.j7m.middleware.distributed.ResourceEndpoint: Submits a version-one operation through the authoritative group's durable log.
ExecutionClient - Class in org.j7m.middleware.distributed: Scope-bound reusable execution transport using authenticated topology routes and stable request IDs.
ExecutionClient(String, String, ReplicatedQueue.RouteResolver) - Constructor for class org.j7m.middleware.distributed.ExecutionClient: Creates a client without trace context.
ExecutionClient(String, String, ReplicatedQueue.RouteResolver, Supplier) - Constructor for class org.j7m.middleware.distributed.ExecutionClient: Creates a context-propagating client without depending on an observability vendor.
ExecutionClient(String, String, ReplicatedQueue.RouteResolver, Supplier, ExecutionClient.Observer) - Constructor for class org.j7m.middleware.distributed.ExecutionClient: Creates an automatically instrumented client, persisting the first submission's trace carrier.
ExecutionClient.Observation - Interface in org.j7m.middleware.distributed: An observation owns its span/scope; completion is delivered only for an actual result.
ExecutionClient.Observer - Interface in org.j7m.middleware.distributed: Vendor-neutral lifecycle instrumentation; implementations must not throw or block delivery.
ExecutionDelivery - Record Class in org.j7m.middleware.distributed: Complete committed native job/saga claim delivered by an authenticated execution session.
ExecutionDelivery(String, String, long, ExecutionResult) - Constructor for record class org.j7m.middleware.distributed.ExecutionDelivery: Validates finite claim metadata without granting new authority.
ExecutionEvents - Class in org.j7m.middleware.distributed: Durable job/saga view subscription facade.
ExecutionEvents(ExecutionClient) - Constructor for class org.j7m.middleware.distributed.ExecutionEvents: Binds an authorized execution client.
ExecutionEvents.RunScan - Class in org.j7m.middleware.distributed: Finite automatically paged run enumeration with a captured tail bootstrap cursor.
ExecutionEvents.View - Record Class in org.j7m.middleware.distributed: Immutable public execution projection at an exact cursor.
ExecutionResult - Record Class in org.j7m.middleware.distributed: Immutable durable execution result and bounded metadata, independent of transport lifecycle.
ExecutionResult(String, Map) - Constructor for record class org.j7m.middleware.distributed.ExecutionResult: Copies metadata and rejects aggregates exceeding the one MiB encoded wire limit.
executionSession(long, String, String, String, long, Instant) - Method in class org.j7m.middleware.distributed.PartitionClient: Opens the same authenticated bounded-credit transport for complete native execution claims.
ExecutionSession - Class in org.j7m.middleware.distributed: Authenticated native execution push publisher, with no client-side poll/claim RPC loop.
ExecutionStateMachine - Class in org.j7m.middleware.distributed: Reusable deterministic execution partition: durable jobs, saga intents/compensations and RPC claims share atomic protected-map effects, durable results and events.
ExecutionStateMachine(String) - Constructor for class org.j7m.middleware.distributed.ExecutionStateMachine: Creates an empty execution partition with bounded retained identities.
expectedEpoch() - Method in record class org.j7m.middleware.distributed.PartitionTopology.Handoff: Returns the value of the expectedEpoch record component.
expire(String, String, long, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedResourceClient: Expires a version only when committed time already reached its expiration.
expiresAt() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Lease: Returns the value of the expiresAt record component.

F

FAILED_NO_EFFECT - Enum constant in enum class org.j7m.middleware.distributed.DurableSagas.StepResolution: Independently established failure with no external effect; not an arbitrary exception.
failedTicks() - Method in class org.j7m.middleware.distributed.LeaseTimeMaintenance: Returns rejected/failed maintenance ticks, including follower and clock-health failures.
fence() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Lease: Returns the value of the fence record component.
fenced(String, String, long, long, String, String, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedResourceClient: Mutates a protected key only with the exact active lease fence and leadership epoch.
fields() - Method in record class org.j7m.middleware.distributed.ExecutionResult: Returns the value of the fields record component.
finalHash(String, Instant) - Method in class org.j7m.middleware.distributed.PartitionAdminClient: Reads the full frozen image digest for final catch-up verification.
finalImageHash(String) - Method in class org.j7m.middleware.distributed.PartitionStateMachine: Returns the final frozen resource image digest used to prove catch-up completeness.
freeze(long, String, Instant) - Method in class org.j7m.middleware.distributed.PartitionAdminClient: Briefly freezes source writes after background catch-up; prepared work blocks this transition.
fromMap(Map) - Static method in record class org.j7m.middleware.distributed.TraceCarrier: Reads only allowed W3C fields, rejecting unknown metadata.

G

generation() - Method in record class org.j7m.middleware.distributed.QueueDelivery: Returns the value of the generation record component.
group() - Method in record class org.j7m.middleware.distributed.PartitionStateMachine.Status: Returns the value of the group record component.
group() - Method in record class org.j7m.middleware.distributed.QueueDelivery: Returns the value of the group record component.

H

handoff() - Method in record class org.j7m.middleware.distributed.PartitionStateMachine.Status: Returns the value of the handoff record component.
handoff(String, long) - Method in class org.j7m.middleware.distributed.PartitionTopology: Returns durable migration progress after a quorum barrier.
handoff(String, Instant) - Method in class org.j7m.middleware.distributed.PartitionAdminClient: Reads durable handoff progress.
Handoff(String, String, String, String, long, String, String) - Constructor for record class org.j7m.middleware.distributed.PartitionTopology.Handoff: Creates an instance of a Handoff record class.
hashCode() - Method in record class org.j7m.middleware.distributed.DeadLetter: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.DeadLetterPage: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.EventJournal.Cursor: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.EventJournal.Event: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.EventJournal.Page: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.ExecutionDelivery: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.ExecutionEvents.View: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.ExecutionResult: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.PartitionReply: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.PartitionServer.Binding: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.PartitionServer.QueuePushStatistics: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.PartitionStateMachine.Status: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.PartitionStateMachine.TailEntry: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.PartitionTopology.Handoff: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.PartitionTopology.Route: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.QueueDelivery: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.QueueStateMachine.Reply: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.RemoteResourceServer.Binding: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.ReplicatedQueue.Route: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.ReplicatedResourceClient.ClockMeasurement: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Event: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Lease: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Result: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.SnapshotTail: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Value: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.ResourceCommand: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.ResourceEvent: Returns a hash code value for this object.
hashCode() - Method in record class org.j7m.middleware.distributed.TraceCarrier: Returns a hash code value for this object.
heartbeat(String, String, long, long, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedCoordination: Renews only a member's expected live version.
heartbeat(String, String, String, long, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Renews an existing member without renewing any message visibility lease.
highWater() - Method in record class org.j7m.middleware.distributed.DeadLetterPage: Returns the value of the highWater record component.

I

id() - Method in record class org.j7m.middleware.distributed.PartitionTopology.Handoff: Returns the value of the id record component.
identityConflict(byte[]) - Method in class org.j7m.middleware.distributed.ExecutionStateMachine: Rechecks durable identity conflicts under serialized committed application.
identityConflict(byte[]) - Method in class org.j7m.middleware.distributed.QueueStateMachine: Rechecks durable identity conflicts under serialized committed application.
identityConflict(byte[]) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Rechecks durable identity conflicts under serialized committed application.
identityConflict(byte[]) - Method in interface org.j7m.middleware.distributed.TransferableResource: Rechecks durable identity conflicts under serialized committed application.
image(String, Instant) - Method in class org.j7m.middleware.distributed.PartitionAdminClient: Downloads the immutable pinned image in authenticated bounded chunks.
imageHash() - Method in record class org.j7m.middleware.distributed.PartitionStateMachine.Status: Returns the value of the imageHash record component.
imageHash() - Method in record class org.j7m.middleware.distributed.PartitionTopology.Handoff: Returns the value of the imageHash record component.
index() - Method in record class org.j7m.middleware.distributed.ExecutionEvents.View: Returns the value of the index record component.
index() - Method in record class org.j7m.middleware.distributed.PartitionStateMachine.TailEntry: Returns the value of the index record component.
index() - Method in record class org.j7m.middleware.distributed.QueueStateMachine.Reply: Returns the value of the index record component.
index() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Event: Returns the value of the index record component.
index() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Result: Returns the value of the index record component.
index() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.SnapshotTail: Returns the value of the index record component.
index() - Method in record class org.j7m.middleware.distributed.ResourceEvent: Returns the value of the index record component.
install(String, long, byte[], Instant) - Method in class org.j7m.middleware.distributed.PartitionAdminClient: Resumes a quorum-durable streamed installation at its stored byte offset.
invoke(String, String, String, long, String, String, List, Instant) - Method in class org.j7m.middleware.distributed.DeduplicatedRpc: Atomically records one invocation's outcome and protected CAS effects.
isClosed() - Method in class org.j7m.middleware.distributed.ExecutionSession: Reports transport closure without asserting that application work has stopped.
isClosed() - Method in class org.j7m.middleware.distributed.QueueSession: Returns transport closure, never physical handler completion.
iterator() - Method in class org.j7m.middleware.distributed.ExecutionEvents.RunScan: Returns a lazy iterator with a fixed initial upper ID and the original deadline.

J

join(String, String, long, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedCoordination: Joins membership with a leased unique member identity.
join(String, String, String, long, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Joins or renews a member; a new member advances the durable group generation.

K

key() - Method in record class org.j7m.middleware.distributed.PartitionServer.Binding: Returns independent key bytes.
kind() - Method in record class org.j7m.middleware.distributed.ExecutionDelivery: Returns the value of the kind record component.

L

latest(String) - Method in class org.j7m.middleware.distributed.EventJournal: Returns the current end, captured atomically alongside a source snapshot by its owning lock.
lead(String, String, String, long, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedCoordination: Attempts exclusive leased leadership of a named activity.
leader(String, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedCoordination: Reads live activity leadership through quorum.
leadershipEpoch() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Lease: Returns the value of the leadershipEpoch record component.
lease(String, String, long) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Reads an authoritative lease; committed expiration makes it absent.
lease(String, Instant) - Method in class org.j7m.middleware.distributed.PartitionResourceEndpoint: Reads a live lease only after healthy committed time and a fresh quorum barrier.
lease(String, Instant) - Method in class org.j7m.middleware.distributed.RemoteResourceClient: Reads a live lease only after healthy committed time and a fresh quorum barrier.
lease(String, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedResourceClient: Returns an active authoritative lease.
lease(String, Instant) - Method in interface org.j7m.middleware.distributed.ResourceEndpoint: Reads a live lease only after healthy committed time and a fresh quorum barrier.
Lease(String, long, long, long, long) - Constructor for record class org.j7m.middleware.distributed.ReplicatedResources.Lease: Creates an instance of a Lease record class.
LeaseTimeMaintenance - Class in org.j7m.middleware.distributed: Bounded automatic logical-time maintenance for a hosted resource group.
LeaseTimeMaintenance(ReplicatedResourceClient, Duration) - Constructor for class org.j7m.middleware.distributed.LeaseTimeMaintenance: Starts one daemon maintenance thread.
LeaseTimeMaintenance(ResourceEndpoint, Duration) - Constructor for class org.j7m.middleware.distributed.LeaseTimeMaintenance: Starts bounded measured-time maintenance over any authorized endpoint implementation.
leave(String, String, long, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedCoordination: Removes exactly one member lease version.
LocalPartitionEndpoint - Class in org.j7m.middleware.distributed: Server-bound local adapter; every mutation is epoch-fenced in the hosted state machine.
LocalPartitionEndpoint(NetworkConsensusNode, PartitionStateMachine, String, boolean, ReplicatedResourceClient.ClockHealth) - Constructor for class org.j7m.middleware.distributed.LocalPartitionEndpoint: Creates an immutable principal binding.
lockRange(String, String, String, String, Instant) - Method in class org.j7m.middleware.distributed.RecoverableTransactions: Acquires a durable conservative tenant-wide range lock before any range query.
logicalIndex() - Method in record class org.j7m.middleware.distributed.PartitionStateMachine.Status: Returns the value of the logicalIndex record component.

M

maintenance() - Method in record class org.j7m.middleware.distributed.PartitionServer.Binding: Returns the value of the maintenance record component.
MAX_BYTES - Static variable in record class org.j7m.middleware.distributed.ResourceCommand: Maximum encoded command size in bytes.
MAX_ENTRIES - Static variable in class org.j7m.middleware.distributed.QueueStateMachine: Maximum retained messages and requests; no silent identity eviction occurs.
maximumAttempts() - Method in record class org.j7m.middleware.distributed.DeadLetter: Returns the value of the maximumAttempts record component.
MeasuredClockHealth - Class in org.j7m.middleware.distributed: Fail-closed wall/monotonic/reference clock monitor.
MeasuredClockHealth(LongSupplier, LongSupplier, LongSupplier, LongSupplier) - Constructor for class org.j7m.middleware.distributed.MeasuredClockHealth: Constructs an initially unsafe monitor.
member() - Method in record class org.j7m.middleware.distributed.QueueDelivery: Returns the value of the member record component.
member(String, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedCoordination: Reads a live member through a quorum barrier.
messageId() - Method in record class org.j7m.middleware.distributed.DeadLetter: Returns the value of the messageId record component.
messageId() - Method in record class org.j7m.middleware.distributed.QueueDelivery: Returns the value of the messageId record component.
migrate(String, String, String, long, Instant) - Method in class org.j7m.middleware.distributed.PartitionMigration: Starts or resumes migration with live snapshot+tail catch-up followed by a brief final freeze.
monotonicStable() - Method in record class org.j7m.middleware.distributed.ReplicatedResourceClient.ClockMeasurement: Returns the value of the monotonicStable record component.
mutate(String, String, long, long, String, String, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedCoordination: Applies a mutation protected by the exact active leadership epoch and fence.

N

nack(String, String, String, String, long, String, long, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Rejects the exact delivery, making it eligible again or moving it to DLQ at maxAttempts.
nonceCapacityRejections() - Method in class org.j7m.middleware.distributed.RemoteResourceServer: Counts authenticated requests rejected because bounded nonce retention is full.

O

observational() - Method in record class org.j7m.middleware.distributed.QueueDelivery: Returns the value of the observational record component.
observeDeadLetters(String, String, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Observes complete retained poison records; callback success never ACKs or redrives them.
operation() - Method in record class org.j7m.middleware.distributed.EventJournal.Event: Returns the value of the operation record component.
operation() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Event: Returns the value of the operation record component.
operation() - Method in record class org.j7m.middleware.distributed.ResourceCommand: Returns the value of the operation record component.
org.j7m.distributed.core - module org.j7m.distributed.core: General quorum-backed resources, leases, and strict two-phase transactions.
org.j7m.middleware.distributed - package org.j7m.middleware.distributed
owner() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Lease: Returns the value of the owner record component.
ownerGroup() - Method in record class org.j7m.middleware.distributed.PartitionTopology.Route: Returns the value of the ownerGroup record component.
ownershipChanged(String, long) - Method in class org.j7m.middleware.distributed.ExecutionStateMachine: Binds event identity to the committed partition and ownership epoch.
ownershipChanged(String, long) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Binds event identity to the committed partition and ownership epoch.
ownershipChanged(String, long) - Method in interface org.j7m.middleware.distributed.TransferableResource: Binds event identity to the committed partition and ownership epoch.
ownershipEpoch(long) - Method in class org.j7m.middleware.distributed.QueueStateMachine: Applies an ownership epoch issued by the hosting committed topology wrapper.
ownershipEpoch(long) - Method in interface org.j7m.middleware.distributed.TransferableResource: Receives the committed ownership epoch before mutations are accepted.

P

Page(List, EventJournal.Cursor) - Constructor for record class org.j7m.middleware.distributed.EventJournal.Page: Copies event references; events are immutable.
parent() - Method in record class org.j7m.middleware.distributed.DeadLetter: Returns the value of the parent record component.
participants(String, String, long) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Reads the durable enlisted participant identifiers used by recovery.
participants(String, Instant) - Method in class org.j7m.middleware.distributed.PartitionResourceEndpoint: Lists durable coordinator participant enrollment.
participants(String, Instant) - Method in class org.j7m.middleware.distributed.RemoteResourceClient: Lists durable coordinator participant enrollment.
participants(String, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedResourceClient: Lists durable coordinator participant enrollment.
participants(String, Instant) - Method in interface org.j7m.middleware.distributed.ResourceEndpoint: Lists durable coordinator participant enrollment.
partition() - Method in record class org.j7m.middleware.distributed.EventJournal.Cursor: Returns the value of the partition record component.
partition() - Method in record class org.j7m.middleware.distributed.PartitionStateMachine.Status: Returns the value of the partition record component.
partition() - Method in record class org.j7m.middleware.distributed.PartitionTopology.Handoff: Returns the value of the partition record component.
partition() - Method in record class org.j7m.middleware.distributed.PartitionTopology.Route: Returns the value of the partition record component.
PartitionAdminClient - Class in org.j7m.middleware.distributed: Privileged topology and transfer API.
PartitionAdminClient(PartitionClient) - Constructor for class org.j7m.middleware.distributed.PartitionAdminClient: Creates an administration facade without changing its immutable principal.
PartitionClient - Class in org.j7m.middleware.distributed: Authenticated bounded partition client with endpoint failover.
PartitionClient(List, String, byte[]) - Constructor for class org.j7m.middleware.distributed.PartitionClient: Creates a loopback development client.
PartitionClient(List, String, byte[], SSLContext) - Constructor for class org.j7m.middleware.distributed.PartitionClient: Creates a secure partition client.
PartitionEndpoint - Interface in org.j7m.middleware.distributed: Authorized routed resource endpoint.
partitionEpoch() - Method in record class org.j7m.middleware.distributed.ExecutionDelivery: Returns the value of the partitionEpoch record component.
partitionId() - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Returns the configured stable logical resource identity, not an ownership attestation.
PartitionMigration - Class in org.j7m.middleware.distributed: Resumable cross-group migration coordinator.
PartitionMigration(PartitionAdminClient, Map) - Constructor for class org.j7m.middleware.distributed.PartitionMigration: Builds a coordinator over independently authenticated remote services.
PartitionReply - Record Class in org.j7m.middleware.distributed: Result of a routed operation.
PartitionReply(String, long, byte[]) - Constructor for record class org.j7m.middleware.distributed.PartitionReply: Copies the mutable payload.
PartitionResourceEndpoint - Class in org.j7m.middleware.distributed: Scope-bound map/transaction/journal bridge for a partition-wrapped resource.
PartitionResourceEndpoint(NetworkConsensusNode, PartitionStateMachine, ReplicatedResources, String, Predicate, boolean, ReplicatedResourceClient.ClockHealth) - Constructor for class org.j7m.middleware.distributed.PartitionResourceEndpoint: Binds one authenticated principal to the exact wrapped resource.
PartitionRouter - Class in org.j7m.middleware.distributed: Stable key routing over a configured partition set.
PartitionRouter(Collection, PartitionAdminClient) - Constructor for class org.j7m.middleware.distributed.PartitionRouter: Creates a deterministic router with lexically canonical partition identities.
PartitionServer - Class in org.j7m.middleware.distributed: Bounded authenticated partition and topology service.
PartitionServer(InetSocketAddress, NetworkConsensusNode, PartitionStateMachine, PartitionTopology, Map, ReplicatedResourceClient.ClockHealth, SSLContext) - Constructor for class org.j7m.middleware.distributed.PartitionServer: Hosts either a partition or the independent topology consensus group.
PartitionServer.Binding - Record Class in org.j7m.middleware.distributed: Immutable server-authorized principal.
PartitionServer.QueuePushStatistics - Record Class in org.j7m.middleware.distributed: Bounded aggregate queue transport metrics; no principal or message labels are exposed.
PartitionStateMachine - Class in org.j7m.middleware.distributed: Serialized ownership fence around one complete transferable resource partition.
PartitionStateMachine(String, String, long, TransferableResource, byte[]) - Constructor for class org.j7m.middleware.distributed.PartitionStateMachine: Creates a host for one partition; inactive targets start with epoch zero.
PartitionStateMachine.Status - Record Class in org.j7m.middleware.distributed: Ownership and migration state.
PartitionStateMachine.TailEntry - Record Class in org.j7m.middleware.distributed: Immutable logical command record for cross-group catch-up.
PartitionTopology - Class in org.j7m.middleware.distributed: Quorum-replicated topology authority.
PartitionTopology(byte[]) - Constructor for class org.j7m.middleware.distributed.PartitionTopology: Creates an empty topology authority.
PartitionTopology.Handoff - Record Class in org.j7m.middleware.distributed: Durable resumable handoff record.
PartitionTopology.Route - Record Class in org.j7m.middleware.distributed: Current ownership record.
payload() - Method in record class org.j7m.middleware.distributed.DeadLetter: Returns an independent content copy.
payload() - Method in record class org.j7m.middleware.distributed.EventJournal.Event: Returns an independent payload copy.
payload() - Method in record class org.j7m.middleware.distributed.PartitionReply: Returns independent payload bytes.
payload() - Method in record class org.j7m.middleware.distributed.QueueDelivery: Returns an independent payload copy.
phase() - Method in record class org.j7m.middleware.distributed.PartitionStateMachine.Status: Returns the value of the phase record component.
phase() - Method in record class org.j7m.middleware.distributed.PartitionTopology.Handoff: Returns the value of the phase record component.
poll(String, int, Instant) - Method in class org.j7m.middleware.distributed.EventSubscriptions: Polls without acknowledging; retries return the same unacknowledged identities.
poll(String, int, Instant) - Method in class org.j7m.middleware.distributed.ExecutionEvents: Polls durable progress without acknowledging delivery.
poll(String, int, Instant) - Method in class org.j7m.middleware.distributed.PartitionResourceEndpoint: Polls a previously committed leased subscription without acknowledging delivery.
poll(String, int, Instant) - Method in class org.j7m.middleware.distributed.RemoteResourceClient: Polls a previously committed leased subscription without acknowledging delivery.
poll(String, int, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedResourceClient: Polls a previously committed leased subscription without acknowledging delivery.
poll(String, int, Instant) - Method in interface org.j7m.middleware.distributed.ResourceEndpoint: Polls a previously committed leased subscription without acknowledging delivery.
poll(String, String, int, long) - Method in class org.j7m.middleware.distributed.EventJournal: Polls from the durable acknowledgement, so lost acknowledgements produce identifiable duplicates.
poll(String, String, int, long) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Reads a durable subscription after an applied quorum barrier; delivery does not acknowledge it.
prepare(String, String, List, Instant) - Method in class org.j7m.middleware.distributed.RecoverableTransactions: Prepares a participant using READ,key,version; WRITE,key,value; RANGE,prefix operations.
prepared(String, long) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Returns prepared transaction identities for recovery scanning.
prepared(Instant) - Method in class org.j7m.middleware.distributed.PartitionResourceEndpoint: Scans unfinished participant transactions holding durable locks.
prepared(Instant) - Method in class org.j7m.middleware.distributed.RemoteResourceClient: Scans unfinished participant transactions holding durable locks.
prepared(Instant) - Method in class org.j7m.middleware.distributed.ReplicatedResourceClient: Scans unfinished participant transactions holding durable locks.
prepared(Instant) - Method in interface org.j7m.middleware.distributed.ResourceEndpoint: Scans unfinished participant transactions holding durable locks.
proof(String, Instant) - Method in class org.j7m.middleware.distributed.PartitionAdminClient: Obtains a proof issued only after committed cutover.

Q

queries() - Method in record class org.j7m.middleware.distributed.PartitionServer.QueuePushStatistics: Returns the value of the queries record component.
query(byte[]) - Method in class org.j7m.middleware.distributed.ExecutionStateMachine: Executes an opaque resource-specific read after the partition host established a quorum barrier.
query(byte[]) - Method in class org.j7m.middleware.distributed.QueueStateMachine: Reads retained results, assignments, DLQ identities or journal counts through the partition host.
query(byte[]) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Executes an opaque resource-specific read after the partition host established a quorum barrier.
query(byte[]) - Method in interface org.j7m.middleware.distributed.TransferableResource: Executes an opaque resource-specific read after the partition host established a quorum barrier.
query(long, byte[], long) - Method in class org.j7m.middleware.distributed.PartitionStateMachine: Queries the resource only for its active ownership epoch after a fresh host barrier.
query(long, byte[], Instant) - Method in class org.j7m.middleware.distributed.LocalPartitionEndpoint: Reads under a fresh quorum and ownership barrier.
query(long, byte[], Instant) - Method in class org.j7m.middleware.distributed.PartitionClient: Reads under a fresh quorum and ownership barrier.
query(long, byte[], Instant) - Method in interface org.j7m.middleware.distributed.PartitionEndpoint: Reads under a fresh quorum and ownership barrier.
query(long, byte[], Instant) - Method in class org.j7m.middleware.distributed.RoutedPartitionEndpoint: Reads under a fresh quorum and ownership barrier.
query(String, String, Instant) - Method in class org.j7m.middleware.distributed.ExecutionClient: Queries durable execution state through a fresh quorum and ownership barrier.
queryAtReadIndex(String, String, long) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Queries a resource only after a quorum read barrier.
queryAtReadIndex(String, String, long) - Method in interface org.j7m.middleware.distributed.ResourceStateMachine: Queries a resource only after a quorum read barrier.
queryBytes(String, List, Instant) - Method in class org.j7m.middleware.distributed.ExecutionClient: Queries an execution capability using its documented bounded binary format.
queue() - Method in record class org.j7m.middleware.distributed.QueueDelivery: Returns the value of the queue record component.
QueueDelivery - Record Class in org.j7m.middleware.distributed: Complete immutable payload granted by one committed receipt, never an availability hint.
QueueDelivery(String, String, String, long, String, byte[], long, long, int) - Constructor for record class org.j7m.middleware.distributed.QueueDelivery: Creates an ordinary exclusive queue grant with the same validation and defensive copy.
QueueDelivery(String, String, String, long, String, byte[], long, long, int, boolean) - Constructor for record class org.j7m.middleware.distributed.QueueDelivery: Validates bounded identity and clones payload before publication.
queuePushStatistics() - Method in class org.j7m.middleware.distributed.PartitionServer: Reads local queue transport counters without quorum or durable mutation.
QueuePushStatistics(int, int, long, long) - Constructor for record class org.j7m.middleware.distributed.PartitionServer.QueuePushStatistics: Creates an instance of a QueuePushStatistics record class.
queueSession(long, String, String, String, long, Instant) - Method in class org.j7m.middleware.distributed.PartitionClient: Opens a bounded authenticated queue push session without sending a claim or consuming a credit.
QueueSession - Class in org.j7m.middleware.distributed: Authenticated queue delivery publisher sharing bounded credit/session machinery with execution.
QueueStateMachine - Class in org.j7m.middleware.distributed: Deterministic, tenant-scoped FIFO queues and consumer generations.
QueueStateMachine() - Constructor for class org.j7m.middleware.distributed.QueueStateMachine: Creates the default partition named queue.
QueueStateMachine(String) - Constructor for class org.j7m.middleware.distributed.QueueStateMachine: Creates an empty transferable queue partition.
QueueStateMachine.Reply - Record Class in org.j7m.middleware.distributed: Immutable operation response; payload is a versioned tab-separated status format.

R

read(String, String, String, String, Instant) - Method in class org.j7m.middleware.distributed.RecoverableTransactions: Acquires a durable read lock before returning a transaction's read value.
read(String, String, EventJournal.Cursor, int) - Method in class org.j7m.middleware.distributed.EventJournal: Reads a bounded page without advancing any subscription.
read(String, Instant) - Method in class org.j7m.middleware.distributed.PartitionResourceEndpoint: Reads a map value after a current leader quorum barrier.
read(String, Instant) - Method in class org.j7m.middleware.distributed.RemoteResourceClient: Reads a map value after a current leader quorum barrier.
read(String, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedResourceClient: Reads after a fresh quorum barrier, with no local-cache authorization.
read(String, Instant) - Method in interface org.j7m.middleware.distributed.ResourceEndpoint: Reads a map value after a current leader quorum barrier.
rebalance(String, String, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Explicitly fences previous assignments and deliveries with a new generation.
receipt() - Method in record class org.j7m.middleware.distributed.DeadLetter: Returns the value of the receipt record component.
receipt() - Method in record class org.j7m.middleware.distributed.QueueDelivery: Returns the value of the receipt record component.
receipt(long) - Method in class org.j7m.middleware.distributed.PartitionStateMachine: Obtains the outcome of a recently committed command; absence is an unknown outcome.
receipt(long) - Method in class org.j7m.middleware.distributed.PartitionTopology: Returns a bounded command receipt.
reconcile(String, String, String, long, boolean, String, Instant) - Method in class org.j7m.middleware.distributed.DurableSagas: Records an independently established UNKNOWN outcome.
reconcile(String, String, String, long, String, String, List, Instant) - Method in class org.j7m.middleware.distributed.DeduplicatedRpc: Privileged reconciliation records an externally established outcome; the hosting principal must have administrative capability, enforced before consensus admission.
recover(String, Instant) - Method in class org.j7m.middleware.distributed.RecoverableTransactions: Replays only an authoritative durable decision to prepared participants.
RecoverableTransactions - Class in org.j7m.middleware.distributed: Durable strict-2PL two-phase commit for participating replicated map resources only.
RecoverableTransactions(ResourceEndpoint, Map) - Constructor for class org.j7m.middleware.distributed.RecoverableTransactions: Constructs a coordinator over independent quorum-authoritative resource groups.
recoverPrepared(String, Instant) - Method in class org.j7m.middleware.distributed.RecoverableTransactions: Scans durable prepared locks and resolves them from the authoritative coordinator journal.
redrive(String, String, String, long, String, int, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Creates one audit-linked child from an exact DLQ receipt; requires real server administrative permission.
reference() - Method in record class org.j7m.middleware.distributed.ReplicatedResourceClient.ClockMeasurement: Returns the value of the reference record component.
register(String, String, Instant) - Method in class org.j7m.middleware.distributed.PartitionAdminClient: Registers an initial route idempotently.
rejectedRequests() - Method in class org.j7m.middleware.distributed.PartitionServer: Counts malformed, unauthorized transport, replayed and overloaded connections.
rejectedRequests() - Method in class org.j7m.middleware.distributed.RemoteResourceServer: Counts rejected connections.
RemoteResourceClient - Class in org.j7m.middleware.distributed: Bounded authenticated network resource endpoint.
RemoteResourceClient(List, String, byte[], SSLContext) - Constructor for class org.j7m.middleware.distributed.RemoteResourceClient: Creates an immutable remote endpoint; each operation owns its socket and is thread-safe.
RemoteResourceServer - Class in org.j7m.middleware.distributed: Bounded authenticated server for explicitly bound resource principals.
RemoteResourceServer(InetSocketAddress, Map, SSLContext) - Constructor for class org.j7m.middleware.distributed.RemoteResourceServer: Binds and starts a bounded server with four handlers and at most sixteen queued connections.
RemoteResourceServer(InetSocketAddress, Map, SSLContext, int) - Constructor for class org.j7m.middleware.distributed.RemoteResourceServer: Binds with an explicit authenticated anti-replay admission budget.
RemoteResourceServer.Binding - Record Class in org.j7m.middleware.distributed: Immutable authenticated service binding.
renew(String, String, long, String, long, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedResourceClient: Renews only the expected live version and owner, issuing a fresh epoch-aware fence.
renew(String, String, String, long, long, Instant) - Method in class org.j7m.middleware.distributed.DurableJobs: Renews a currently RUNNING unexpired claim without changing its fence.
renewVisibility(String, QueueDelivery, long, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Renews only the exact still-live delivery without resetting attempts or its finite renewal window.
ReplicatedCoordination - Class in org.j7m.middleware.distributed: Additive quorum-authoritative coordination API.
ReplicatedCoordination(ReplicatedResourceClient) - Constructor for class org.j7m.middleware.distributed.ReplicatedCoordination: Creates a coordination facade for one authorized resource scope.
ReplicatedCoordination(ResourceEndpoint) - Constructor for class org.j7m.middleware.distributed.ReplicatedCoordination: Creates a coordination facade over a raw, partition-wrapped or authenticated remote endpoint.
ReplicatedQueue - Class in org.j7m.middleware.distributed: Durable queue and consumer-group facade over authenticated, ownership-fenced partition endpoints.
ReplicatedQueue(String, String, ReplicatedQueue.RouteResolver) - Constructor for class org.j7m.middleware.distributed.ReplicatedQueue: Creates a scope-bound routed facade.
ReplicatedQueue.Route - Record Class in org.j7m.middleware.distributed: Immutable resolved route.
ReplicatedQueue.RouteResolver - Interface in org.j7m.middleware.distributed: Resolves authoritative partition ownership; implementations must be thread-safe.
ReplicatedResourceClient - Class in org.j7m.middleware.distributed: Quorum-authoritative resource operations.
ReplicatedResourceClient(NetworkConsensusNode, ReplicatedResources, String, Predicate, ReplicatedResourceClient.ClockHealth) - Constructor for class org.j7m.middleware.distributed.ReplicatedResourceClient: Builds a facade bound to the exact state machine hosted by the supplied node.
ReplicatedResourceClient.ClockHealth - Interface in org.j7m.middleware.distributed: Supplies measured, authenticated clock health.
ReplicatedResourceClient.ClockMeasurement - Record Class in org.j7m.middleware.distributed: Measured clock evidence; healthy profile permits at most 500 ms uncertainty and offset.
ReplicatedResources - Class in org.j7m.middleware.distributed: Synchronized deterministic map reference resource; not a tuple space.
ReplicatedResources() - Constructor for class org.j7m.middleware.distributed.ReplicatedResources: Creates an empty resource.
ReplicatedResources(int) - Constructor for class org.j7m.middleware.distributed.ReplicatedResources: Creates an empty resource with a bounded foreground fingerprint budget.
ReplicatedResources.Event - Record Class in org.j7m.middleware.distributed: Immutable event emitted in the same batch as state and result.
ReplicatedResources.Lease - Record Class in org.j7m.middleware.distributed: Persisted lease including leadership epoch and globally monotonic fence.
ReplicatedResources.Result - Record Class in org.j7m.middleware.distributed: Immutable operation result.
ReplicatedResources.SnapshotTail - Record Class in org.j7m.middleware.distributed: Atomic source image and tail starting position, captured under the same resource lock.
ReplicatedResources.Value - Record Class in org.j7m.middleware.distributed: Versioned map value.
Reply(String, long) - Constructor for record class org.j7m.middleware.distributed.QueueStateMachine.Reply: Creates an instance of a Reply record class.
requestCompensation(String, String, long, Instant) - Method in class org.j7m.middleware.distributed.DurableSagas: Atomically requests compensation and revokes the previous owner before any next forward step.
requestId() - Method in record class org.j7m.middleware.distributed.ResourceCommand: Returns the value of the requestId record component.
requestIdentity(byte[]) - Method in class org.j7m.middleware.distributed.ExecutionStateMachine: Extracts the durable business request identity from a validated nested command.
requestIdentity(byte[]) - Method in class org.j7m.middleware.distributed.QueueStateMachine: Extracts the durable business request identity from a validated nested command.
requestIdentity(byte[]) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Extracts the durable business request identity from a validated nested command.
requestIdentity(byte[]) - Method in interface org.j7m.middleware.distributed.TransferableResource: Extracts the durable business request identity from a validated nested command.
reservedBytes() - Method in record class org.j7m.middleware.distributed.PartitionServer.QueuePushStatistics: Returns the value of the reservedBytes record component.
resolve(String, Instant) - Method in interface org.j7m.middleware.distributed.ReplicatedQueue.RouteResolver: Supplies the latest committed ownership route after MOVED or FROZEN.
resolveStep(String, String, String, long, String, DurableSagas.StepResolution, String, Instant) - Method in class org.j7m.middleware.distributed.DurableSagas: Resolves an active forward/compensation intent under its current owner fence.
ResourceCommand - Record Class in org.j7m.middleware.distributed: Version-one deterministic command.
ResourceCommand(String, String, String, List) - Constructor for record class org.j7m.middleware.distributed.ResourceCommand: Validates and defensively copies a command.
ResourceEndpoint - Interface in org.j7m.middleware.distributed: Authorized resource-group endpoint, local or authenticated remote.
ResourceEvent - Record Class in org.j7m.middleware.distributed: Versioned map-source event payload.
ResourceEvent(long, String, ResourceCommand) - Constructor for record class org.j7m.middleware.distributed.ResourceEvent: Validates immutable source metadata.
ResourceStateMachine - Interface in org.j7m.middleware.distributed: Deterministic replicated resource SPI.
restartImage(String, Instant) - Method in class org.j7m.middleware.distributed.PartitionAdminClient: Resets an unactivated target or repins the source after bounded suffix retention expired.
restore(byte[]) - Static method in class org.j7m.middleware.distributed.EventJournal: Decodes a bounded snapshot completely before returning an independently installable journal.
restore(byte[]) - Method in class org.j7m.middleware.distributed.ExecutionStateMachine
restore(byte[]) - Method in class org.j7m.middleware.distributed.PartitionStateMachine
restore(byte[]) - Method in class org.j7m.middleware.distributed.PartitionTopology
restore(byte[]) - Method in class org.j7m.middleware.distributed.QueueStateMachine
restore(byte[]) - Method in class org.j7m.middleware.distributed.ReplicatedResources
result(String, String, long) - Method in class org.j7m.middleware.distributed.QueueStateMachine: Returns a retained committed result after the hosting read barrier.
result(String, String, long) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Returns a retained request result, including explicit expiry without re-execution.
result(String, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedResourceClient: Returns a recoverable retained request result.
Result(String, String, long) - Constructor for record class org.j7m.middleware.distributed.ReplicatedResources.Result: Creates an instance of a Result record class.
resume(String, String, long, long) - Method in class org.j7m.middleware.distributed.EventJournal: Resumes an existing subscription without resetting progress and renews its lease.
resume(String, String, long, Instant) - Method in class org.j7m.middleware.distributed.EventSubscriptions: Renews an existing subscription without resetting durable progress.
resume(String, String, long, Instant) - Method in class org.j7m.middleware.distributed.ExecutionEvents: Renews retained progress without resetting it.
retainedBytes() - Method in class org.j7m.middleware.distributed.EventJournal: Returns retained payload bytes for bounded-consumer telemetry.
retainedEvents() - Method in class org.j7m.middleware.distributed.EventJournal: Returns retained event count for bounded-consumer telemetry.
retainedSnapshotBytes() - Method in class org.j7m.middleware.distributed.QueueStateMachine: Measures the exact current queue image without serializing payloads or changing state.
route(String, long) - Method in class org.j7m.middleware.distributed.PartitionTopology: Returns an ownership route after the caller established a quorum barrier.
route(String, Instant) - Method in class org.j7m.middleware.distributed.PartitionAdminClient: Reads the authoritative route.
route(String, Instant) - Method in class org.j7m.middleware.distributed.PartitionRouter: Resolves a key through the authoritative owner epoch.
Route(String, String, long) - Constructor for record class org.j7m.middleware.distributed.PartitionTopology.Route: Creates an instance of a Route record class.
Route(PartitionEndpoint, long) - Constructor for record class org.j7m.middleware.distributed.ReplicatedQueue.Route: Validates the route.
RoutedPartitionEndpoint - Class in org.j7m.middleware.distributed: Refreshes authoritative ownership after MOVED/FROZEN and retries the exact business identity.
RoutedPartitionEndpoint(String, PartitionAdminClient, Map) - Constructor for class org.j7m.middleware.distributed.RoutedPartitionEndpoint: Binds a route to configured authorized group endpoints.
run() - Method in record class org.j7m.middleware.distributed.ExecutionDelivery: Returns the value of the run record component.
runs() - Method in record class org.j7m.middleware.distributed.ExecutionEvents.View: Returns the value of the runs record component.
runs(String, Instant) - Method in class org.j7m.middleware.distributed.ExecutionEvents: Starts a scan restricted to a stable run identity prefix.
runs(Instant) - Method in class org.j7m.middleware.distributed.ExecutionEvents: Starts an automatically paged bounded scan of all tenant job/saga IDs.

S

sample() - Method in class org.j7m.middleware.distributed.MeasuredClockHealth: Samples clock health for this operation.
sample() - Method in interface org.j7m.middleware.distributed.ReplicatedResourceClient.ClockHealth: Samples clock health for this operation.
scope() - Method in record class org.j7m.middleware.distributed.EventJournal.Event: Returns the value of the scope record component.
scope() - Method in record class org.j7m.middleware.distributed.PartitionServer.Binding: Returns the value of the scope record component.
scope() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Event: Returns the value of the scope record component.
scope() - Method in record class org.j7m.middleware.distributed.ResourceCommand: Returns the value of the scope record component.
scopeId() - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Returns the configured tenant scope, never credentials or permission to change it.
send(String, String, String, byte[], int, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Sends a stable message identity once.
sendBatch(String, String, Map, int, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Atomically sends up to 256 messages to one FIFO queue, retaining each stable identity.
sequence() - Method in record class org.j7m.middleware.distributed.DeadLetter: Returns the value of the sequence record component.
sequence() - Method in record class org.j7m.middleware.distributed.EventJournal.Cursor: Returns the value of the sequence record component.
sequence() - Method in record class org.j7m.middleware.distributed.QueueDelivery: Returns the value of the sequence record component.
sessions() - Method in record class org.j7m.middleware.distributed.PartitionServer.QueuePushStatistics: Returns the value of the sessions record component.
snapshot() - Method in class org.j7m.middleware.distributed.EventJournal: Serializes all retained events, floors and durable subscription progress without native serialization.
snapshot() - Method in class org.j7m.middleware.distributed.ExecutionStateMachine
snapshot() - Method in class org.j7m.middleware.distributed.PartitionStateMachine
snapshot() - Method in class org.j7m.middleware.distributed.PartitionTopology
snapshot() - Method in class org.j7m.middleware.distributed.QueueStateMachine
snapshot() - Method in class org.j7m.middleware.distributed.ReplicatedResources
snapshot() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.SnapshotTail: Returns an independent snapshot copy.
snapshotAndTail(long) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Captures source state and the exact starting cursor for subsequent subscriptions without a gap.
snapshotAndTail(String, long) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Captures an authenticated scope's map projection with the exact journal barrier.
snapshotAndTail(Instant) - Method in class org.j7m.middleware.distributed.EventSubscriptions: Captures the authorized map projection and exact source tail barrier atomically.
snapshotAndTail(Instant) - Method in class org.j7m.middleware.distributed.ExecutionEvents: Captures a bounded atomic job/saga projection and tail cursor.
snapshotAndTail(Instant) - Method in class org.j7m.middleware.distributed.PartitionResourceEndpoint: Atomically captures the scope's map projection and the starting cursor for its tail.
snapshotAndTail(Instant) - Method in class org.j7m.middleware.distributed.RemoteResourceClient: Atomically captures the scope's map projection and the starting cursor for its tail.
snapshotAndTail(Instant) - Method in class org.j7m.middleware.distributed.ReplicatedResourceClient: Atomically captures the scope's map projection and the starting cursor for its tail.
snapshotAndTail(Instant) - Method in interface org.j7m.middleware.distributed.ResourceEndpoint: Atomically captures the scope's map projection and the starting cursor for its tail.
snapshotAt(long, String, Instant) - Method in class org.j7m.middleware.distributed.PartitionAdminClient: Pins a snapshot barrier while permitting concurrent writes into the bounded tail.
snapshotAt(String) - Method in class org.j7m.middleware.distributed.PartitionStateMachine: Captures the exact frozen barrier, including the resource's complete journal and cursors.
SnapshotTail(byte[], EventJournal.Cursor, long) - Constructor for record class org.j7m.middleware.distributed.ReplicatedResources.SnapshotTail: Copies the snapshot.
source() - Method in record class org.j7m.middleware.distributed.PartitionTopology.Handoff: Returns the value of the source record component.
start(String, String, String, int, long, Instant) - Method in class org.j7m.middleware.distributed.DurableSagas: Starts durable saga state and captures trace context.
statistics(Instant) - Method in class org.j7m.middleware.distributed.ExecutionClient: Reads bounded authorized aggregate counters with no identity labels.
status() - Method in record class org.j7m.middleware.distributed.ExecutionResult: Returns the value of the status record component.
status() - Method in record class org.j7m.middleware.distributed.PartitionReply: Returns the value of the status record component.
status() - Method in class org.j7m.middleware.distributed.PartitionStateMachine: Returns durable ownership state.
status() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Result: Returns the value of the status record component.
status() - Method in record class org.j7m.middleware.distributed.ResourceEvent: Returns the value of the status record component.
status(String, Instant) - Method in class org.j7m.middleware.distributed.DeduplicatedRpc: Reads an invocation's persisted outcome or explicit retention expiry.
status(String, Instant) - Method in class org.j7m.middleware.distributed.DurableJobs: Reads persisted job input, progress, result and ownership.
status(String, Instant) - Method in class org.j7m.middleware.distributed.DurableSagas: Reads durable saga state and current step metadata.
status(String, Instant) - Method in class org.j7m.middleware.distributed.RecoverableTransactions: Reads authoritative coordinator status without interpreting a deadline as an abort.
status(Instant) - Method in class org.j7m.middleware.distributed.LocalPartitionEndpoint: Reads ownership status through quorum.
status(Instant) - Method in class org.j7m.middleware.distributed.PartitionAdminClient: Reads local durable partition status through quorum.
status(Instant) - Method in class org.j7m.middleware.distributed.PartitionClient: Reads ownership status through quorum.
status(Instant) - Method in interface org.j7m.middleware.distributed.PartitionEndpoint: Reads ownership status through quorum.
status(Instant) - Method in class org.j7m.middleware.distributed.RoutedPartitionEndpoint: Reads ownership status through quorum.
Status(String, String, long, String, String, String, long) - Constructor for record class org.j7m.middleware.distributed.PartitionStateMachine.Status: Creates an instance of a Status record class.
step(String, String, String, long, String, String, String, boolean, boolean, Instant) - Method in class org.j7m.middleware.distributed.DurableSagas: Records a step intent before invoking an external handler; its stable key belongs in that handler's idempotency protocol.
steps(String, Instant) - Method in class org.j7m.middleware.distributed.DurableSagas: Reads all persisted steps in original order using bounded eight-step pages from one stable saga version.
stepStatus(String, String, Instant) - Method in class org.j7m.middleware.distributed.DurableSagas: Reads one persisted step's exact protocol phase, stable external key and compensation input.
submit(String, String, String, String, Instant) - Method in class org.j7m.middleware.distributed.DurableJobs: Submits a durable occurrence whose live claim cannot overlap another run in this group.
submit(String, String, String, Instant) - Method in class org.j7m.middleware.distributed.DurableJobs: Submits a durable job with persisted input and trace context.
subscribe(String, String, String, long, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedQueue: Subscribes to complete durable grants with bounded demand and no client-side claim polling.
subscribe(String, String, String, EventJournal.Cursor, long, long) - Method in class org.j7m.middleware.distributed.EventJournal: Creates an idempotent leased subscription.
subscribe(String, String, String, EventJournal.Cursor, long, Instant) - Method in class org.j7m.middleware.distributed.EventSubscriptions: Creates a leased subscription from an exact source cursor.
subscribe(String, String, String, EventJournal.Cursor, long, Instant) - Method in class org.j7m.middleware.distributed.ExecutionEvents: Creates a committed leased subscription.
subscribe(Flow.Subscriber) - Method in class org.j7m.middleware.distributed.ExecutionSession: Installs the sole serialized subscriber.
subscribe(Flow.Subscriber) - Method in class org.j7m.middleware.distributed.QueueSession: Registers the sole subscriber with positive bounded server credit.
subscribeExecution(long, String, String, String, long, Instant) - Method in class org.j7m.middleware.distributed.PartitionClient: Opens complete native execution-claim push; unsupported backends fail closed without polling.
subscribeExecution(long, String, String, String, long, Instant) - Method in interface org.j7m.middleware.distributed.PartitionEndpoint: Opens complete native execution-claim push; unsupported backends fail closed without polling.
subscribeExecution(long, String, String, String, long, Instant) - Method in class org.j7m.middleware.distributed.RoutedPartitionEndpoint: Opens complete native execution-claim push; unsupported backends fail closed without polling.
subscribeQueue(long, String, String, String, long, boolean, Instant) - Method in class org.j7m.middleware.distributed.PartitionClient: Opens authenticated direct-payload push; unsupported backends fail closed without polling.
subscribeQueue(long, String, String, String, long, boolean, Instant) - Method in interface org.j7m.middleware.distributed.PartitionEndpoint: Opens authenticated direct-payload push; unsupported backends fail closed without polling.
subscribeQueue(long, String, String, String, long, boolean, Instant) - Method in class org.j7m.middleware.distributed.RoutedPartitionEndpoint: Opens authenticated direct-payload push; unsupported backends fail closed without polling.
subscriptions() - Method in class org.j7m.middleware.distributed.EventJournal: Returns leased subscription count.

T

tail(long, int) - Method in class org.j7m.middleware.distributed.PartitionStateMachine: Returns a bounded ordered suffix after a pinned image position.
tail(long, Instant) - Method in class org.j7m.middleware.distributed.PartitionAdminClient: Reads an ordered bounded command suffix.
TailEntry(long, long, byte[]) - Constructor for record class org.j7m.middleware.distributed.PartitionStateMachine.TailEntry: Copies mutable input bytes.
target() - Method in record class org.j7m.middleware.distributed.PartitionTopology.Handoff: Returns the value of the target record component.
term() - Method in record class org.j7m.middleware.distributed.PartitionStateMachine.TailEntry: Returns the value of the term record component.
through() - Method in record class org.j7m.middleware.distributed.DeadLetterPage: Returns the value of the through record component.
through() - Method in record class org.j7m.middleware.distributed.EventJournal.Page: Returns the value of the through record component.
time() - Method in record class org.j7m.middleware.distributed.ReplicatedResourceClient.ClockMeasurement: Returns the value of the time record component.
timeCommand(long) - Method in class org.j7m.middleware.distributed.ExecutionStateMachine: Encodes a deterministic trusted time control, never supplied by ordinary callers.
timeCommand(long) - Method in class org.j7m.middleware.distributed.QueueStateMachine: Encodes a deterministic trusted time control, never supplied by ordinary callers.
timeCommand(long) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Encodes a deterministic trusted time control, never supplied by ordinary callers.
timeCommand(long) - Method in interface org.j7m.middleware.distributed.TransferableResource: Encodes a deterministic trusted time control, never supplied by ordinary callers.
timeControl(byte[]) - Method in class org.j7m.middleware.distributed.ExecutionStateMachine: Identifies host-only logical-time controls, forbidden on ordinary network mutation paths.
timeControl(byte[]) - Method in class org.j7m.middleware.distributed.QueueStateMachine: Identifies host-only logical-time controls, forbidden on ordinary network mutation paths.
timeControl(byte[]) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Identifies host-only logical-time controls, forbidden on ordinary network mutation paths.
timeControl(byte[]) - Method in interface org.j7m.middleware.distributed.TransferableResource: Identifies host-only logical-time controls, forbidden on ordinary network mutation paths.
timeSensitive(byte[]) - Method in class org.j7m.middleware.distributed.ExecutionStateMachine: Identifies operations requiring fresh healthy committed time before admission.
timeSensitive(byte[]) - Method in class org.j7m.middleware.distributed.QueueStateMachine: Identifies operations requiring fresh healthy committed time before admission.
timeSensitive(byte[]) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Identifies operations requiring fresh healthy committed time before admission.
timeSensitive(byte[]) - Method in interface org.j7m.middleware.distributed.TransferableResource: Identifies operations requiring fresh healthy committed time before admission.
toString() - Method in record class org.j7m.middleware.distributed.DeadLetter: Returns payload-free diagnostic metadata.
toString() - Method in record class org.j7m.middleware.distributed.DeadLetterPage: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.EventJournal.Cursor: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.EventJournal.Event: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.EventJournal.Page: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.ExecutionDelivery: Returns bounded diagnostic identity without persisted input, result or trace carrier.
toString() - Method in record class org.j7m.middleware.distributed.ExecutionEvents.View: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.ExecutionResult: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.PartitionReply: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.PartitionServer.Binding: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.PartitionServer.QueuePushStatistics: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.PartitionStateMachine.Status: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.PartitionStateMachine.TailEntry: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.PartitionTopology.Handoff: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.PartitionTopology.Route: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.QueueDelivery: Returns receipt metadata without exposing payload.
toString() - Method in record class org.j7m.middleware.distributed.QueueStateMachine.Reply: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.RemoteResourceServer.Binding: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.ReplicatedQueue.Route: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.ReplicatedResourceClient.ClockMeasurement: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Event: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Lease: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Result: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.SnapshotTail: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Value: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.ResourceCommand: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.ResourceEvent: Returns a string representation of this record class.
toString() - Method in record class org.j7m.middleware.distributed.TraceCarrier: Returns a string representation of this record class.
TraceCarrier - Record Class in org.j7m.middleware.distributed: Bounded W3C trace context, suitable for persisted RPC, message and job metadata.
TraceCarrier(String, String) - Constructor for record class org.j7m.middleware.distributed.TraceCarrier: Validates context before it is admitted to durable storage.
traceparent() - Method in record class org.j7m.middleware.distributed.TraceCarrier: Returns the value of the traceparent record component.
tracestate() - Method in record class org.j7m.middleware.distributed.TraceCarrier: Returns the value of the tracestate record component.
transaction(String, String, long) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Reads transaction status and durable decision epoch.
transaction(String, Instant) - Method in class org.j7m.middleware.distributed.PartitionResourceEndpoint: Reads durable transaction state.
transaction(String, Instant) - Method in class org.j7m.middleware.distributed.RemoteResourceClient: Reads durable transaction state.
transaction(String, Instant) - Method in class org.j7m.middleware.distributed.ReplicatedResourceClient: Reads durable transaction state.
transaction(String, Instant) - Method in interface org.j7m.middleware.distributed.ResourceEndpoint: Reads durable transaction state.
TransferableResource - Interface in org.j7m.middleware.distributed: Deterministic resource whose complete snapshot can move between consensus groups.
transferReady() - Method in class org.j7m.middleware.distributed.ExecutionStateMachine: Reports whether migration can freeze this resource without stranding an unresolved transaction.
transferReady() - Method in class org.j7m.middleware.distributed.QueueStateMachine: Reports whether migration can freeze this resource without stranding an unresolved transaction.
transferReady() - Method in class org.j7m.middleware.distributed.ReplicatedResources: Returns whether no prepared transaction or durable lock blocks migration.
transferReady() - Method in interface org.j7m.middleware.distributed.TransferableResource: Reports whether migration can freeze this resource without stranding an unresolved transaction.

U

uncertainty() - Method in record class org.j7m.middleware.distributed.ReplicatedResourceClient.ClockMeasurement: Returns the value of the uncertainty record component.
unknown(String, String, String, long, Instant) - Method in class org.j7m.middleware.distributed.DeduplicatedRpc: Marks an ambiguous external effect without retrying it.
UNKNOWN - Enum constant in enum class org.j7m.middleware.distributed.DurableSagas.StepResolution: External effect may have happened; progression requires privileged reconciliation.
uploadOffset() - Method in class org.j7m.middleware.distributed.PartitionStateMachine: Returns durable streamed installation progress.

V

validate(byte[], String, boolean) - Method in class org.j7m.middleware.distributed.ExecutionStateMachine: Validates every untrusted command before consensus admission and binds its tenant to the principal.
validate(byte[], String, boolean) - Method in class org.j7m.middleware.distributed.QueueStateMachine: Validates every untrusted command before consensus admission and binds its tenant to the principal.
validate(byte[], String, boolean) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Validates every untrusted command before consensus admission and binds its tenant to the principal.
validate(byte[], String, boolean) - Method in interface org.j7m.middleware.distributed.TransferableResource: Validates every untrusted command before consensus admission and binds its tenant to the principal.
validate(ResourceCommand) - Static method in class org.j7m.middleware.distributed.ExecutionStateMachine: Validates a version-one execution command before admission.
validate(ResourceCommand) - Static method in class org.j7m.middleware.distributed.QueueStateMachine: Validates a bounded queue command before log admission.
validateAdmission(ResourceCommand, long) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Rejects malformed and currently impossible subscription cursors before consensus admission.
validateQuery(byte[], String) - Method in class org.j7m.middleware.distributed.ExecutionStateMachine: Validates tenant binding of a resource query before dispatch.
validateQuery(byte[], String) - Method in class org.j7m.middleware.distributed.QueueStateMachine: Validates tenant binding of a resource query before dispatch.
validateQuery(byte[], String) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Validates tenant binding of a resource query before dispatch.
validateQuery(byte[], String) - Method in interface org.j7m.middleware.distributed.TransferableResource: Validates tenant binding of a resource query before dispatch.
validateReplayCommand(byte[]) - Method in class org.j7m.middleware.distributed.ExecutionStateMachine: Validates syntax of a trusted source command without consulting current target state.
validateReplayCommand(byte[]) - Method in class org.j7m.middleware.distributed.QueueStateMachine: Validates syntax of a trusted source command without consulting current target state.
validateReplayCommand(byte[]) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Validates syntax of a trusted source command without consulting current target state.
validateReplayCommand(byte[]) - Method in interface org.j7m.middleware.distributed.TransferableResource: Validates syntax of a trusted source command without consulting current target state.
validateSnapshot(byte[]) - Method in class org.j7m.middleware.distributed.ExecutionStateMachine: Fully validates a transfer image without mutating this live resource.
validateSnapshot(byte[]) - Method in class org.j7m.middleware.distributed.QueueStateMachine: Fully validates a transfer image without mutating this live resource.
validateSnapshot(byte[]) - Method in class org.j7m.middleware.distributed.ReplicatedResources: Fully validates a transfer image without mutating this live resource.
validateSnapshot(byte[]) - Method in interface org.j7m.middleware.distributed.TransferableResource: Fully validates a transfer image without mutating this live resource.
value() - Method in record class org.j7m.middleware.distributed.QueueStateMachine.Reply: Returns the value of the value record component.
value() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Result: Returns the value of the value record component.
value() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Value: Returns the value of the value record component.
Value(String, long) - Constructor for record class org.j7m.middleware.distributed.ReplicatedResources.Value: Creates an instance of a Value record class.
valueOf(String) - Static method in enum class org.j7m.middleware.distributed.DurableSagas.StepResolution: Returns the enum constant of this class with the specified name.
values() - Static method in enum class org.j7m.middleware.distributed.DurableSagas.StepResolution: Returns an array containing the constants of this enum class, in the order they are declared.
verify(String, String, String, long, Instant) - Method in class org.j7m.middleware.distributed.DurableSagas: Checks the exact current live owner after host-generated measured time advancement.
version() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Lease: Returns the value of the version record component.
version() - Method in record class org.j7m.middleware.distributed.ReplicatedResources.Value: Returns the value of the version record component.
View(long, EventJournal.Cursor, Map) - Constructor for record class org.j7m.middleware.distributed.ExecutionEvents.View: Copies the projection map.

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