Index

A B C D E F G I L M P R S T U W
All Classes and Interfaces|All Packages|Constant Field Values

A

at.aimon.session.postgres - package at.aimon.session.postgres

Postgres-backed implementations of the aimon-session-base SPIs (ConversationLock, ConversationSignalBus, ConversationInbox, IdempotencyStore).

at.aimon.session.postgres.internal - package at.aimon.session.postgres.internal

Internal helpers for the Postgres-backed session SPI implementations.

B

build() - Method in class at.aimon.session.postgres.internal.StoredAgentExecutionResult.Builder

builder() - Static method in class at.aimon.session.postgres.internal.StoredAgentExecutionResult

C

CHANNEL - Static variable in class at.aimon.session.postgres.internal.ListenDispatcher

close() - Method in class at.aimon.session.postgres.internal.ListenDispatcher

close() - Method in class at.aimon.session.postgres.PostgresConversationSignalBus

collect(ConversationId, QueuedInputPriority) - Method in class at.aimon.session.postgres.PostgresConversationInbox

compareAndReset(String, String) - Method in class at.aimon.session.postgres.PostgresIdempotencyStore

completionReason(CompletionReason) - Method in class at.aimon.session.postgres.internal.StoredAgentExecutionResult.Builder

ConversationSignalRowCodec - Class in at.aimon.session.postgres.internal

Jackson codec for the payload JSONB column of conversation_signal.

ConversationSignalRowCodec(ObjectMapper) - Constructor for class at.aimon.session.postgres.internal.ConversationSignalRowCodec

D

decode(String, String) - Method in class at.aimon.session.postgres.internal.InboundMessageRowCodec

decodePayload(String) - Method in class at.aimon.session.postgres.internal.ConversationSignalRowCodec

decodeResult(String) - Method in class at.aimon.session.postgres.internal.IdempotencyEntryRowCodec

DEFAULT_COLLECT_LIMIT - Static variable in class at.aimon.session.postgres.PostgresConversationInbox

Maximum messages a single collect call removes; matches design §4.3.

DEFAULT_DONE_TTL - Static variable in class at.aimon.session.postgres.PostgresIdempotencyStore

Primary TTL applied when an entry transitions to IdempotencyEntry.Status.DONE.

deliver(InboundMessage) - Method in class at.aimon.session.postgres.PostgresConversationInbox

E

encode(InboundMessage) - Method in class at.aimon.session.postgres.internal.InboundMessageRowCodec

encodePayload(Map<String, Object>) - Method in class at.aimon.session.postgres.internal.ConversationSignalRowCodec

encodeResult(AgentExecutionResult) - Method in class at.aimon.session.postgres.internal.IdempotencyEntryRowCodec

errorMessage(String) - Method in class at.aimon.session.postgres.internal.StoredAgentExecutionResult.Builder

extend(ConversationLock.LockHandle, Duration) - Method in class at.aimon.session.postgres.PostgresConversationLock

F

finalAnswer(String) - Method in class at.aimon.session.postgres.internal.StoredAgentExecutionResult.Builder

find(String) - Method in class at.aimon.session.postgres.PostgresIdempotencyStore

findStaleInFlight(Instant) - Method in class at.aimon.session.postgres.PostgresIdempotencyStore

from(AgentExecutionResult) - Static method in class at.aimon.session.postgres.internal.StoredAgentExecutionResult

G

getCompletionReason() - Method in class at.aimon.session.postgres.internal.StoredAgentExecutionResult

getErrorMessage() - Method in class at.aimon.session.postgres.internal.StoredAgentExecutionResult

getFinalAnswer() - Method in class at.aimon.session.postgres.internal.StoredAgentExecutionResult

I

IdempotencyEntryRowCodec - Class in at.aimon.session.postgres.internal

Jackson codec for the idempotency_entry.result_blob JSONB column.

IdempotencyEntryRowCodec(ObjectMapper) - Constructor for class at.aimon.session.postgres.internal.IdempotencyEntryRowCodec

InboundMessageRowCodec - Class in at.aimon.session.postgres.internal

Jackson codec for the InboundMessage envelope persisted to conversation_inbox.payload (JSONB).

InboundMessageRowCodec(ObjectMapper) - Constructor for class at.aimon.session.postgres.internal.InboundMessageRowCodec

isEmpty(ConversationId) - Method in class at.aimon.session.postgres.PostgresConversationInbox

isSuccess() - Method in class at.aimon.session.postgres.internal.StoredAgentExecutionResult

L

ListenDispatcher - Class in at.aimon.session.postgres.internal

Owns the dedicated LISTEN connection for conversation_signal_doorbell.

ListenDispatcher(String, Properties, DataSource, ConversationSignalRowCodec) - Constructor for class at.aimon.session.postgres.internal.ListenDispatcher

ListenDispatcher(String, Properties, DataSource, ConversationSignalRowCodec, long, long, long) - Constructor for class at.aimon.session.postgres.internal.ListenDispatcher

M

markDone(String, AgentExecutionResult) - Method in class at.aimon.session.postgres.PostgresIdempotencyStore

P

PostgresConversationInbox - Class in at.aimon.session.postgres

Postgres-backed ConversationInbox per design §4.3.

PostgresConversationInbox(DataSource) - Constructor for class at.aimon.session.postgres.PostgresConversationInbox

PostgresConversationInbox(DataSource, ObjectMapper, int) - Constructor for class at.aimon.session.postgres.PostgresConversationInbox

PostgresConversationLock - Class in at.aimon.session.postgres

Postgres-backed ConversationLock per design §4.1.

PostgresConversationLock(DataSource) - Constructor for class at.aimon.session.postgres.PostgresConversationLock

PostgresConversationLock(DataSource, Clock) - Constructor for class at.aimon.session.postgres.PostgresConversationLock

PostgresConversationSignalBus - Class in at.aimon.session.postgres

Postgres-backed ConversationSignalBus per design §4.2.

PostgresConversationSignalBus(DataSource, DataSource, String, Properties, String) - Constructor for class at.aimon.session.postgres.PostgresConversationSignalBus

PostgresConversationSignalBus(DataSource, DataSource, String, Properties, String, ObjectMapper, boolean) - Constructor for class at.aimon.session.postgres.PostgresConversationSignalBus

PostgresIdempotencyStore - Class in at.aimon.session.postgres

Postgres-backed IdempotencyStore per design §4.4.

PostgresIdempotencyStore(DataSource) - Constructor for class at.aimon.session.postgres.PostgresIdempotencyStore

PostgresIdempotencyStore(DataSource, ObjectMapper, Duration, Clock) - Constructor for class at.aimon.session.postgres.PostgresIdempotencyStore

publish(ConversationSignal) - Method in class at.aimon.session.postgres.PostgresConversationSignalBus

purge(ConversationId) - Method in class at.aimon.session.postgres.PostgresConversationInbox

putIfAbsent(String, IdempotencyEntry, Duration) - Method in class at.aimon.session.postgres.PostgresIdempotencyStore

R

release(ConversationLock.LockHandle) - Method in class at.aimon.session.postgres.PostgresConversationLock

S

start() - Method in class at.aimon.session.postgres.internal.ListenDispatcher

Starts the listener thread.

StoredAgentExecutionResult - Class in at.aimon.session.postgres.internal

Minimal AgentExecutionResult projection used by PostgresIdempotencyStore for replay.

StoredAgentExecutionResult.Builder - Class in at.aimon.session.postgres.internal

Builder for StoredAgentExecutionResult.

subscribe(ConversationId, Consumer<ConversationSignal>) - Method in class at.aimon.session.postgres.PostgresConversationSignalBus

success(boolean) - Method in class at.aimon.session.postgres.internal.StoredAgentExecutionResult.Builder

sweepExpired(Instant) - Method in class at.aimon.session.postgres.PostgresIdempotencyStore

Reaps DONE rows whose primary TTL expired.

sweepOlderThan(Instant) - Method in class at.aimon.session.postgres.PostgresConversationSignalBus

Reaps conversation_signal rows older than cutoff.

T

touch(String, String) - Method in class at.aimon.session.postgres.PostgresIdempotencyStore

track(ConversationId, Consumer<ConversationSignal>) - Method in class at.aimon.session.postgres.internal.ListenDispatcher

tryAcquire(ConversationId, String, Duration) - Method in class at.aimon.session.postgres.PostgresConversationLock

U

untrack(ConversationId) - Method in class at.aimon.session.postgres.internal.ListenDispatcher

W

wasStreamed() - Method in class at.aimon.session.postgres.internal.StoredAgentExecutionResult

wasStreamed(boolean) - Method in class at.aimon.session.postgres.internal.StoredAgentExecutionResult.Builder

A B C D E F G I L M P R S T U W
All Classes and Interfaces|All Packages|Constant Field Values