类 MemorySaver

继承关系 (查看完整)

构造函数

构造函数

属性

serde storage writes

方法

_getPendingSends get getNextVersion getTuple list put putWrites

构造函数

构造函数

属性

serde

serde: SerializerProtocol

storage

storage: Record<string, Record<string, Record<string, [Uint8Array<ArrayBufferLike>, Uint8Array<ArrayBufferLike>, undefined | string]>>>

writes

writes: Record<string, Record<string, [string, string, Uint8Array<ArrayBufferLike>]>>

方法

_getPendingSends

  • _getPendingSends(threadId, checkpointNs, parentCheckpointId?): Promise<SendProtocol[]>

  • 参数

    • threadId: string
    • checkpointNs: string
    • 可选 parentCheckpointId: string

    返回 Promise<SendProtocol[]>

get

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

  • 参数

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

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

getNextVersion

  • getNextVersion(current, _channel): number

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

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

    参数

    • current: undefined | number
    • _channel: ChannelProtocol<unknown, unknown, unknown>

    返回 number

getTuple

list

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>

设置

成员可见性

主题

本页目录

constructorserdestoragewrites_getPendingSendsgetgetNextVersiongetTuplelistputputWrites