SqliteSaver 类

层级结构 (查看完整)

构造函数

构造函数

属性

db isSetup serde withCheckpoint withoutCheckpoint

方法

deleteThread get getNextVersion getTuple list migratePendingSends put putWrites setup fromConnString

构造函数

构造函数

属性

db

db: Database

受保护 isSetup

isSetup: boolean

serde

serde: SerializerProtocol

受保护 withCheckpoint

withCheckpoint: Statement<unknown[], unknown>

受保护 withoutCheckpoint

withoutCheckpoint: Statement<unknown[], unknown>

方法

deleteThread

  • deleteThread(threadId): Promise<void>

  • 删除与特定线程 ID 关联的所有检查点和写入。

    参数

    • threadId: string

      应删除其检查点的线程 ID。

    返回 Promise<void>

获取

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

  • 参数

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

    返回 Promise<undefined | Checkpoint<string, string>>

getNextVersion

  • getNextVersion(current): number

  • 为通道生成下一个版本 ID。

    默认为使用整数版本，每次递增 1。如果你重写此方法，可以使用字符串/整数/浮点数版本，只要它们是单调递增的即可。

    参数

    • current: undefined | number

    返回 number

getTuple

列出

受保护 migratePendingSends

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

  • 参数

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

    返回 Promise<void>

put

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

  • 参数

    返回 Promise<RunnableConfig<Record<string, any>>>

putWrites

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

  • 存储链接到检查点的中间写入。

    参数

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

    返回 Promise<void>

受保护 setup

  • setup(): void

  • 返回 void

静态 fromConnString

  • fromConnString(connStringOrLocalPath): SqliteSaver

  • 参数

    • connStringOrLocalPath: string

    返回 SqliteSaver

设置

成员可见性

主题

本页内容

构造函数dbisSetupserdewithCheckpointwithoutCheckpointdeleteThreadgetgetNextVersiongetTuplelistmigratePendingSendsputputWritessetupfromConnString