Class MemorySaver

Hierarchy (view full)

Constructors

constructor

Properties

serde storage writes

Methods

_getPendingSends get getNextVersion getTuple list put putWrites

Constructors

constructor

Properties

serde

serde: SerializerProtocol

storage

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

writes

writes: Record<string, [string, string, unknown][]>

Methods

_getPendingSends

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

  • Parameters

    • threadId: string
    • checkpointNs: string
    • Optional parentCheckpointId: string

    Returns Promise<SendProtocol[]>

get

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

  • Parameters

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

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

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

getTuple

list

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<string>[]
    • taskId: string

    Returns Promise<void>

Settings

Member Visibility

Theme

On This Page

constructorserdestoragewrites_getPendingSendsgetgetNextVersiongetTuplelistputputWrites