Graphorin API reference v0.4.0

---

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

Class: SqliteCheckpointStore

Defined in: packages/store-sqlite/src/checkpoint-store.ts:18

Default CheckpointStore implementation. Workflow state is encoded as JSON blobs; per-task pending writes survive partial step failure.

Stable

Implements

• CheckpointStore

Constructors

Constructor

new SqliteCheckpointStore(conn): SqliteCheckpointStore;

Defined in: packages/store-sqlite/src/checkpoint-store.ts:20

Parameters

Parameter	Type
conn	SqliteConnection

Returns

SqliteCheckpointStore

Methods

deleteThread()

deleteThread(threadId): Promise<void>;

Defined in: packages/store-sqlite/src/checkpoint-store.ts:132

Parameters

Parameter	Type
threadId	string

Returns

Promise<void>

Implementation of

CheckpointStore.deleteThread

---

getTuple()

getTuple(
   threadId, 
   namespace, 
   checkpointId?): Promise<
  | CheckpointTuple
| null>;

Defined in: packages/store-sqlite/src/checkpoint-store.ts:74

Parameters

Parameter	Type
threadId	string
namespace	string
checkpointId?	string

Returns

Promise< | CheckpointTuple | null>

Implementation of

CheckpointStore.getTuple

---

list()

list(
   threadId, 
   namespace, 
opts?): AsyncIterable<CheckpointTuple>;

Defined in: packages/store-sqlite/src/checkpoint-store.ts:109

Parameters

Parameter	Type
threadId	string
namespace	string
opts?	ListOptions

Returns

AsyncIterable&lt;CheckpointTuple&gt;

Implementation of

CheckpointStore.list

---

put()

put(
   threadId, 
   namespace, 
   checkpoint, 
metadata): Promise<string>;

Defined in: packages/store-sqlite/src/checkpoint-store.ts:24

Parameters

Parameter	Type
threadId	string
namespace	string
checkpoint	Checkpoint
metadata	CheckpointMetadata

Returns

Promise&lt;string&gt;

Implementation of

CheckpointStore.put

---

putWrites()

putWrites(
   threadId, 
   namespace, 
   checkpointId, 
   writes, 
taskId): Promise<void>;

Defined in: packages/store-sqlite/src/checkpoint-store.ts:53

Parameters

Parameter	Type
threadId	string
namespace	string
checkpointId	string
writes	readonly PendingWrite[]
taskId	string

Returns

Promise&lt;void&gt;

Implementation of

CheckpointStore.putWrites