Class SqliteSaver

Hierarchy (view full)

Constructors

constructor

Properties

db isSetup serde withCheckpoint withoutCheckpoint

Methods

deleteThread get getNextVersion getTuple list migratePendingSends put putWrites setup fromConnString

Constructors

constructor

Properties

db

db: Database

Protected isSetup

isSetup: boolean

serde

serde: SerializerProtocol

Protected withCheckpoint

withCheckpoint: Statement<unknown[], unknown>

Protected withoutCheckpoint

withoutCheckpoint: Statement<unknown[], unknown>

Methods

deleteThread

  • deleteThread(threadId): Promise<void>

  • Delete all checkpoints and writes associated with a specific thread ID.

    Parameters

    • threadId: string

      The thread ID whose checkpoints should be deleted.

    Returns Promise<void>

get

  • get(config): Promise<undefined | Checkpoint<string, string>>

  • Parameters

    • config: RunnableConfig<Record<string, any>>

    Returns Promise<undefined | Checkpoint<string, string>>

getNextVersion

  • getNextVersion(current): 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

    Returns number

getTuple

list

Protected migratePendingSends

  • migratePendingSends(checkpoint, threadId, parentCheckpointId): Promise<void>

  • Parameters

    • checkpoint: Checkpoint<string, string>
    • threadId: string
    • parentCheckpointId: string

    Returns Promise<void>

put

  • put(config, checkpoint, metadata): Promise<RunnableConfig<Record<string, any>>>

  • Parameters

    Returns Promise<RunnableConfig<Record<string, any>>>

putWrites

  • putWrites(config, writes, taskId): Promise<void>

  • Store intermediate writes linked to a checkpoint.

    Parameters

    • config: RunnableConfig<Record<string, any>>
    • writes: PendingWrite[]
    • taskId: string

    Returns Promise<void>

Protected setup

  • setup(): void

  • Returns void

Static fromConnString

  • fromConnString(connStringOrLocalPath): SqliteSaver

  • Parameters

    • connStringOrLocalPath: string

    Returns SqliteSaver

Settings

Member Visibility

Theme

On This Page

constructordbisSetupserdewithCheckpointwithoutCheckpointdeleteThreadgetgetNextVersiongetTuplelistmigratePendingSendsputputWritessetupfromConnString