Class SqliteSaver

Hierarchy (view full)

BaseCheckpointSaver
- SqliteSaver

Index

Constructors

Properties

db isSetup serde

Methods

get getNextVersion getTuple list put putWrites setup fromConnString

Constructors

constructor

new SqliteSaver(db, serde?): SqliteSaver
Parameters
- db: Database
- Optional serde: SerializerProtocol
Returns SqliteSaver
Overrides BaseCheckpointSaver.constructor
- Defined in libs/checkpoint-sqlite/dist/index.d.ts:7

Properties

db

db: Database

`Protected` isSetup

isSetup: boolean

serde

serde: SerializerProtocol

Methods

get

get(config): Promise<undefined | Checkpoint<string, string>>
Parameters
- config: RunnableConfig<Record<string, any>>
Returns Promise<undefined | Checkpoint<string, string>>
Inherited from BaseCheckpointSaver.get
- Defined in libs/checkpoint/dist/base.d.ts:63

getNextVersion

getNextVersion(current, _channel): number
Generate the next version ID for a channel.

Default is to use integer versions, incrementing by 1. If you override, you can use str/int/float versions, as long as they are monotonically increasing.
Parameters
- current: undefined | number
- _channel: ChannelProtocol<unknown, unknown, unknown>
Returns number
Inherited from BaseCheckpointSaver.getNextVersion
- Defined in libs/checkpoint/dist/base.d.ts:77

getTuple

getTuple(config): Promise<undefined | CheckpointTuple>
Parameters
- config: RunnableConfig<Record<string, any>>
Returns Promise<undefined | CheckpointTuple>
Overrides BaseCheckpointSaver.getTuple
- Defined in libs/checkpoint-sqlite/dist/index.d.ts:10

list

list(config, options?): AsyncGenerator<CheckpointTuple, any, unknown>
Parameters
- config: RunnableConfig<Record<string, any>>
- Optional options: CheckpointListOptions
Returns AsyncGenerator<CheckpointTuple, any, unknown>
Overrides BaseCheckpointSaver.list
- Defined in libs/checkpoint-sqlite/dist/index.d.ts:11

put

put(config, checkpoint, metadata): Promise<RunnableConfig<Record<string, any>>>
Parameters
- config: RunnableConfig<Record<string, any>>
- checkpoint: Checkpoint<string, string>
- metadata: CheckpointMetadata
Returns Promise<RunnableConfig<Record<string, any>>>
Overrides BaseCheckpointSaver.put
- Defined in libs/checkpoint-sqlite/dist/index.d.ts:12

putWrites

putWrites(config, writes, taskId): Promise<void>
Store intermediate writes linked to a checkpoint.
Parameters
- config: RunnableConfig<Record<string, any>>
- writes: PendingWrite<string>[]
- taskId: string
Returns Promise<void>
Overrides BaseCheckpointSaver.putWrites
- Defined in libs/checkpoint-sqlite/dist/index.d.ts:13

`Protected` setup

setup(): void
Returns void
- Defined in libs/checkpoint-sqlite/dist/index.d.ts:9

`Static` fromConnString

fromConnString(connStringOrLocalPath): SqliteSaver
Parameters
- connStringOrLocalPath: string
Returns SqliteSaver
- Defined in libs/checkpoint-sqlite/dist/index.d.ts:8