Graphorin API reference v0.7.0

---

Graphorin API reference / @graphorin/memory / / ConsolidatorMemoryStoreExt

Interface: ConsolidatorMemoryStoreExt

Defined in: packages/memory/src/internal/storage-adapter.ts:502

Optional consolidator-state surface every storage adapter exposes for Phase 10c. Mirrors the consolidator_state, consolidator_runs, and consolidator_failed_batches tables shipped in Phase 05's migration 009. Adapters that do not implement the surface degrade gracefully - the consolidator runs in stateless mode (no DLQ, no cursor persistence) and emits a one-shot WARN.

Stable

Methods

acquireLock()

acquireLock(
   scope, 
   runId, 
   now, 
maxAgeMs): Promise<boolean>;

Defined in: packages/memory/src/internal/storage-adapter.ts:512

Atomically claim the per-scope lock. Returns true when the row was either unlocked, owned by runId, or stale (the held timestamp is older than maxAgeMs); false otherwise. The now argument allows the lock manager to inject a deterministic clock during tests.

Parameters

Parameter	Type
scope	SessionScope
runId	string
now	number
maxAgeMs	number

Returns

Promise<boolean>

---

claimReadyBatches()

claimReadyBatches(
   scope, 
   now, 
limit?): Promise<readonly DlqBatchRow[]>;

Defined in: packages/memory/src/internal/storage-adapter.ts:540

Claim every DLQ row whose nextRetryAt is at or before now, up to limit. Returns the rows in failed-at order so the oldest backlog drains first.

Parameters

Parameter	Type
scope	SessionScope
now	number
limit?	number

Returns

Promise<readonly DlqBatchRow[]>

---

enqueueFailedBatch()

enqueueFailedBatch(input): Promise<void>;

Defined in: packages/memory/src/internal/storage-adapter.ts:534

Parameters

Parameter	Type
input	DlqBatchInput

Returns

Promise<void>

---

getState()

getState(scope): Promise<
  | ConsolidatorStateRow
| null>;

Defined in: packages/memory/src/internal/storage-adapter.ts:503

Parameters

Parameter	Type
scope	SessionScope

Returns

Promise< | ConsolidatorStateRow | null>

---

listFailedBatches()

listFailedBatches(scope, limit?): Promise<readonly DlqBatchRow[]>;

Defined in: packages/memory/src/internal/storage-adapter.ts:563

Parameters

Parameter	Type
scope	SessionScope
limit?	number

Returns

Promise&lt;readonly DlqBatchRow[]&gt;

---

listRecentRuns()

listRecentRuns(scope, limit?): Promise<readonly {
  factsCreated: number;
  factsUpdated: number;
  finishedAt: number | null;
  id: string;
  llmCostUsd: number | null;
  llmTokensUsed: number;
  phase: "light" | "standard" | "deep";
  startedAt: number;
  status: string;
}[]>;

Defined in: packages/memory/src/internal/storage-adapter.ts:517

Parameters

Parameter	Type
scope	SessionScope
limit?	number

Returns

Promise<readonly { factsCreated: number; factsUpdated: number; finishedAt: number | null; id: string; llmCostUsd: number | null; llmTokensUsed: number; phase: "light" | "standard" | "deep"; startedAt: number; status: string; }[]>

---

markBatchExhausted()

markBatchExhausted(
   id, 
   errorMessage, 
retryCount?): Promise<void>;

Defined in: packages/memory/src/internal/storage-adapter.ts:562

Mark the row exhausted (retryCount exceeded the configured cap). The row stays in the DLQ for operator inspection. Implementations MUST clear nextRetryAt so the row is no longer eligible for claimReadyBatches. The optional retryCount argument is recorded against the row so the persisted count reflects the final attempt that triggered the exhaustion.

Parameters

Parameter	Type
id	string
errorMessage	string
retryCount?	number

Returns

Promise&lt;void&gt;

---

markBatchSucceeded()

markBatchSucceeded(id): Promise<void>;

Defined in: packages/memory/src/internal/storage-adapter.ts:546

Mark the row succeeded - removes it from the DLQ.

Parameters

Parameter	Type
id	string

Returns

Promise&lt;void&gt;

---

recordRunFinish()

recordRunFinish(finish): Promise<void>;

Defined in: packages/memory/src/internal/storage-adapter.ts:516

Parameters

Parameter	Type
finish	ConsolidatorRunFinish

Returns

Promise&lt;void&gt;

---

recordRunStart()

recordRunStart(input): Promise<void>;

Defined in: packages/memory/src/internal/storage-adapter.ts:515

Parameters

Parameter	Type
input	ConsolidatorRunInput

Returns

Promise&lt;void&gt;

---

releaseLock()

releaseLock(scope, runId): Promise<void>;

Defined in: packages/memory/src/internal/storage-adapter.ts:513

Parameters

Parameter	Type
scope	SessionScope
runId	string

Returns

Promise&lt;void&gt;

---

rescheduleBatch()

rescheduleBatch(
   id, 
   retryCount, 
nextRetryAt): Promise<void>;

Defined in: packages/memory/src/internal/storage-adapter.ts:552

Schedule the next retry attempt. The caller computes nextRetryAt so the backoff schedule is centralized in the consolidator.

Parameters

Parameter	Type
id	string
retryCount	number
nextRetryAt	number

Returns

Promise&lt;void&gt;

---

upsertState()

upsertState(scope, patch): Promise<ConsolidatorStateRow>;

Defined in: packages/memory/src/internal/storage-adapter.ts:504

Parameters

Parameter	Type
scope	SessionScope
patch	ConsolidatorStatePatch

Returns

Promise&lt;ConsolidatorStateRow&gt;