Graphorin API reference v0.1.0

---

Graphorin API reference / @graphorin/memory / / ConsolidatorMemoryStoreExt

Interface: ConsolidatorMemoryStoreExt

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

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:365

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:393

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:387

Parameters

Parameter	Type
input	DlqBatchInput

Returns

Promise<void>

---

getState()

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

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

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:416

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:370

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:415

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:399

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:369

Parameters

Parameter	Type
finish	ConsolidatorRunFinish

Returns

Promise&lt;void&gt;

---

recordRunStart()

recordRunStart(input): Promise<void>;

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

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:366

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:405

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:357

Parameters

Parameter	Type
scope	SessionScope
patch	ConsolidatorStatePatch

Returns

Promise&lt;ConsolidatorStateRow&gt;