Graphorin API reference v0.4.0

---

Graphorin API reference / @graphorin/store-sqlite / / SqliteConsolidatorStateStore

Class: SqliteConsolidatorStateStore

Defined in: packages/store-sqlite/src/consolidator-store.ts:137

SQLite-backed consolidator state store. Constructed by SqliteMemoryStore; never instantiated directly by application code.

Stable

Constructors

Constructor

new SqliteConsolidatorStateStore(conn): SqliteConsolidatorStateStore;

Defined in: packages/store-sqlite/src/consolidator-store.ts:140

Parameters

Parameter	Type
conn	SqliteConnection

Returns

SqliteConsolidatorStateStore

Methods

acquireLock()

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

Defined in: packages/store-sqlite/src/consolidator-store.ts:216

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/store-sqlite/src/consolidator-store.ts:357

Parameters

Parameter	Type	Default value
scope	SessionScope	undefined
now	number	undefined
limit	number	50

Returns

Promise<readonly DlqBatchRow[]>

---

enqueueFailedBatch()

enqueueFailedBatch(input): Promise<void>;

Defined in: packages/store-sqlite/src/consolidator-store.ts:336

Parameters

Parameter	Type
input	DlqBatchInput

Returns

Promise<void>

---

getState()

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

Defined in: packages/store-sqlite/src/consolidator-store.ts:144

Parameters

Parameter	Type
scope	SessionScope

Returns

Promise< | ConsolidatorStateRow | null>

---

listFailedBatches()

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

Defined in: packages/store-sqlite/src/consolidator-store.ts:405

Parameters

Parameter	Type	Default value
scope	SessionScope	undefined
limit	number	100

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/store-sqlite/src/consolidator-store.ts:298

Parameters

Parameter	Type	Default value
scope	SessionScope	undefined
limit	number	50

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/store-sqlite/src/consolidator-store.ts:387

Parameters

Parameter	Type
id	string
errorMessage	string
retryCount?	number

Returns

Promise&lt;void&gt;

---

markBatchSucceeded()

markBatchSucceeded(id): Promise<void>;

Defined in: packages/store-sqlite/src/consolidator-store.ts:374

Parameters

Parameter	Type
id	string

Returns

Promise&lt;void&gt;

---

recordRunFinish()

recordRunFinish(finish): Promise<void>;

Defined in: packages/store-sqlite/src/consolidator-store.ts:272

Parameters

Parameter	Type
finish	ConsolidatorRunFinish

Returns

Promise&lt;void&gt;

---

recordRunStart()

recordRunStart(input): Promise<void>;

Defined in: packages/store-sqlite/src/consolidator-store.ts:255

Parameters

Parameter	Type
input	ConsolidatorRunInput

Returns

Promise&lt;void&gt;

---

releaseLock()

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

Defined in: packages/store-sqlite/src/consolidator-store.ts:245

Parameters

Parameter	Type
scope	SessionScope
runId	string

Returns

Promise&lt;void&gt;

---

rescheduleBatch()

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

Defined in: packages/store-sqlite/src/consolidator-store.ts:378

Parameters

Parameter	Type
id	string
retryCount	number
nextRetryAt	number

Returns

Promise&lt;void&gt;

---

upsertState()

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

Defined in: packages/store-sqlite/src/consolidator-store.ts:155

Parameters

Parameter	Type
scope	SessionScope
patch	ConsolidatorStatePatch

Returns

Promise&lt;ConsolidatorStateRow&gt;