Index

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

A

at.aimon.memory.postgres - package at.aimon.memory.postgres

PostgreSQL-backed implementations of the memory-layer storage interfaces defined in at.aimon.core.memory.

at.aimon.memory.postgres.internal - package at.aimon.memory.postgres.internal

Internal codecs, row mappers, and helpers used by the public Postgres store implementations in at.aimon.memory.postgres.

B

build() - Method in class at.aimon.memory.postgres.RelayOptions.Builder

builder() - Static method in class at.aimon.memory.postgres.RelayOptions

Returns a fresh builder pre-populated with default values.

C

claimDurationSeconds(int) - Method in class at.aimon.memory.postgres.RelayOptions.Builder

close() - Method in class at.aimon.memory.postgres.internal.OutboxStagingFileSystem

close() - Method in class at.aimon.memory.postgres.KnowledgeStoreOutboxRelay

copy(String, String, boolean) - Method in class at.aimon.memory.postgres.internal.OutboxStagingFileSystem

count(PeerView) - Method in class at.aimon.memory.postgres.PostgresObservationStore

create(Workspace) - Method in class at.aimon.memory.postgres.PostgresWorkspaceStore

D

decode(String) - Method in class at.aimon.memory.postgres.internal.RepresentationRowCodec

DEFAULT_CLAIM_DURATION_SECONDS - Static variable in class at.aimon.memory.postgres.RelayOptions

Default claim duration in seconds.

DEFAULT_MAX_ATTEMPTS - Static variable in class at.aimon.memory.postgres.RelayOptions

Default maximum dispatch attempts before poison-pilling a row.

DEFAULT_POLL_BATCH_SIZE - Static variable in class at.aimon.memory.postgres.RelayOptions

Default batch size per drain pass.

DEFAULT_POLL_INTERVAL_MILLIS - Static variable in class at.aimon.memory.postgres.RelayOptions

Default poll interval in milliseconds.

defaults() - Static method in class at.aimon.memory.postgres.RelayOptions

Returns options with documented defaults.

delete(ObservationId) - Method in class at.aimon.memory.postgres.PostgresObservationStore

delete(Workspace) - Method in class at.aimon.memory.postgres.PostgresWorkspaceStore

delete(String) - Method in class at.aimon.memory.postgres.internal.OutboxStagingFileSystem

deleteOlderThan(Workspace, Instant) - Method in class at.aimon.memory.postgres.PostgresRepresentationStore

drainOnce() - Method in class at.aimon.memory.postgres.KnowledgeStoreOutboxRelay

Runs a single drain pass: claims a batch, dispatches each row, then settles them (success → delete, failure → backoff or poison).

DrainResult - Class in at.aimon.memory.postgres

Outcome of one KnowledgeStoreOutboxRelay.drainOnce() pass.

DrainResult(int, int, int) - Constructor for class at.aimon.memory.postgres.DrainResult

E

encode(Representation) - Method in class at.aimon.memory.postgres.internal.RepresentationRowCodec

enqueue(DerivationTask) - Method in class at.aimon.memory.postgres.PostgresDerivationQueueManager

exists(String) - Method in class at.aimon.memory.postgres.internal.OutboxStagingFileSystem

F

findAll(Principal) - Method in class at.aimon.memory.postgres.PostgresWorkspaceStore

findByConfidenceBelow(PeerView, double, int) - Method in class at.aimon.memory.postgres.PostgresObservationStore

findById(ObservationId) - Method in class at.aimon.memory.postgres.PostgresObservationStore

findById(String) - Method in class at.aimon.memory.postgres.PostgresWorkspaceStore

findBySubject(PeerView, int) - Method in class at.aimon.memory.postgres.PostgresObservationStore

findLatestGlobal(PeerView) - Method in class at.aimon.memory.postgres.PostgresRepresentationStore

findLatestLocal(PeerView, PeerView, String) - Method in class at.aimon.memory.postgres.PostgresRepresentationStore

findSubjects(Workspace, int) - Method in class at.aimon.memory.postgres.PostgresObservationStore

G

getClaimDurationSeconds() - Method in class at.aimon.memory.postgres.RelayOptions

getClaimed() - Method in class at.aimon.memory.postgres.DrainResult

Total rows claimed in the batch (sum of all three buckets).

getFailed() - Method in class at.aimon.memory.postgres.DrainResult

getHolderId() - Method in class at.aimon.memory.postgres.PostgresDerivationQueueManager

Returns the per-instance holder id used for claim ownership in mem_active_work_unit.

getMaxAttempts() - Method in class at.aimon.memory.postgres.RelayOptions

getMetadata(String) - Method in class at.aimon.memory.postgres.internal.OutboxStagingFileSystem

getNodeId() - Method in class at.aimon.memory.postgres.RelayOptions

getPoisoned() - Method in class at.aimon.memory.postgres.DrainResult

getPollBatchSize() - Method in class at.aimon.memory.postgres.RelayOptions

getPollIntervalMillis() - Method in class at.aimon.memory.postgres.RelayOptions

getProcessed() - Method in class at.aimon.memory.postgres.DrainResult

getStatus() - Method in class at.aimon.memory.postgres.internal.OutboxStagingFileSystem

getWorkingDirectory() - Method in class at.aimon.memory.postgres.internal.OutboxStagingFileSystem

I

initialize() - Method in class at.aimon.memory.postgres.internal.OutboxStagingFileSystem

isDirectory(String) - Method in class at.aimon.memory.postgres.internal.OutboxStagingFileSystem

K

KnowledgeStoreOutboxRelay - Class in at.aimon.memory.postgres

Polling worker that drains mem_outbox and dispatches each claimed row to a KnowledgeStore — the read side of the outbox pattern from design doc §5.2.

KnowledgeStoreOutboxRelay(DataSource, KnowledgeStore) - Constructor for class at.aimon.memory.postgres.KnowledgeStoreOutboxRelay

Convenience constructor — uses KnowledgeStoreObservationIndex.DEFAULT_AGENT_NAME as the agent name segment of the KnowledgeScope and RelayOptions.defaults().

KnowledgeStoreOutboxRelay(DataSource, KnowledgeStore, String, RelayOptions) - Constructor for class at.aimon.memory.postgres.KnowledgeStoreOutboxRelay

Full constructor.

L

list(String) - Method in class at.aimon.memory.postgres.internal.OutboxStagingFileSystem

listRecursive(String) - Method in class at.aimon.memory.postgres.internal.OutboxStagingFileSystem

M

maxAttempts(int) - Method in class at.aimon.memory.postgres.RelayOptions.Builder

merge(ObservationId, ObservationId, Observation) - Method in class at.aimon.memory.postgres.PostgresObservationStore

move(String, String, boolean) - Method in class at.aimon.memory.postgres.internal.OutboxStagingFileSystem

N

nodeId(String) - Method in class at.aimon.memory.postgres.RelayOptions.Builder

O

openInputStream(String) - Method in class at.aimon.memory.postgres.internal.OutboxStagingFileSystem

openOutputStream(String) - Method in class at.aimon.memory.postgres.internal.OutboxStagingFileSystem

OutboxStagingFileSystem - Class in at.aimon.memory.postgres.internal

Internal in-memory VirtualFileSystem used by KnowledgeStoreOutboxRelay to ferry outbox payloads into KnowledgeStore.reindex(at.aimon.core.knowledge.KnowledgeScope, at.aimon.core.knowledge.KnowledgeSource, at.aimon.core.knowledge.IndexOptions) calls.

OutboxStagingFileSystem() - Constructor for class at.aimon.memory.postgres.internal.OutboxStagingFileSystem

P

POISON_CLAIM - Static variable in class at.aimon.memory.postgres.KnowledgeStoreOutboxRelay

Sentinel value written to claimed_by for rows that have exceeded RelayOptions.getMaxAttempts() so they are visibly distinct from a regular in-flight claim.

pollBatchSize(int) - Method in class at.aimon.memory.postgres.RelayOptions.Builder

pollIntervalMillis(long) - Method in class at.aimon.memory.postgres.RelayOptions.Builder

PostgresDerivationQueueManager - Class in at.aimon.memory.postgres

Postgres-coordinated DerivationQueueManager.

PostgresDerivationQueueManager(DataSource, Deriver, RedactionPolicy, MemoryProperties.DeriverProperties) - Constructor for class at.aimon.memory.postgres.PostgresDerivationQueueManager

Creates a new Postgres-backed queue manager.

PostgresDerivationQueueManager(DataSource, Deriver, RedactionPolicy, MemoryProperties.DeriverProperties, Duration) - Constructor for class at.aimon.memory.postgres.PostgresDerivationQueueManager

Test-friendly constructor that lets callers shorten the claim lease so concurrent-claim tests don't have to wait minutes for an expired lease to be stealable.

PostgresObservationStore - Class in at.aimon.memory.postgres

Postgres-backed ObservationStore implementing the metadata side of the C3 split (design doc §5.2).

PostgresObservationStore(DataSource, ObjectMapper) - Constructor for class at.aimon.memory.postgres.PostgresObservationStore

Creates a new store.

PostgresRepresentationStore - Class in at.aimon.memory.postgres

Postgres-backed RepresentationStore per design §5.3 / §5.5.

PostgresRepresentationStore(DataSource, ObjectMapper) - Constructor for class at.aimon.memory.postgres.PostgresRepresentationStore

PostgresWorkspaceStore - Class in at.aimon.memory.postgres

Postgres-backed WorkspaceStore per design §5.1 / §5.5.

PostgresWorkspaceStore(DataSource, ObjectMapper) - Constructor for class at.aimon.memory.postgres.PostgresWorkspaceStore

put(String, String) - Method in class at.aimon.memory.postgres.internal.OutboxStagingFileSystem

Stages a UTF-8 encoded payload at the given path.

R

read(String) - Method in class at.aimon.memory.postgres.internal.OutboxStagingFileSystem

RelayOptions - Class in at.aimon.memory.postgres

Immutable configuration for KnowledgeStoreOutboxRelay.

RelayOptions.Builder - Class in at.aimon.memory.postgres

Builder for RelayOptions.

RepresentationRowCodec - Class in at.aimon.memory.postgres.internal

Jackson codec for the mem_representation.payload_blob JSONB column.

RepresentationRowCodec(ObjectMapper) - Constructor for class at.aimon.memory.postgres.internal.RepresentationRowCodec

S

save(Observation) - Method in class at.aimon.memory.postgres.PostgresObservationStore

save(Representation) - Method in class at.aimon.memory.postgres.PostgresRepresentationStore

SCHEMA_VERSION - Static variable in class at.aimon.memory.postgres.internal.RepresentationRowCodec

Current payload schema version.

semanticSearch(PeerView, String, int) - Method in class at.aimon.memory.postgres.PostgresObservationStore

Always throws UnsupportedOperationException.

start() - Method in class at.aimon.memory.postgres.KnowledgeStoreOutboxRelay

Spawns the daemon poller.

start() - Method in class at.aimon.memory.postgres.PostgresDerivationQueueManager

stats() - Method in class at.aimon.memory.postgres.PostgresDerivationQueueManager

stop() - Method in class at.aimon.memory.postgres.KnowledgeStoreOutboxRelay

Signals the daemon to stop and joins it (best-effort, with a short timeout so callers don't hang on a stuck dispatch).

stop() - Method in class at.aimon.memory.postgres.PostgresDerivationQueueManager

T

toString() - Method in class at.aimon.memory.postgres.DrainResult

toString() - Method in class at.aimon.memory.postgres.RelayOptions

W

write(String, InputStream, long) - Method in class at.aimon.memory.postgres.internal.OutboxStagingFileSystem

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