Class MemorySaver

Hierarchy (View Summary)

BaseCheckpointSaver
- MemorySaver

Index

Constructors

Properties

serde storage writes

Methods

deleteThread get getNextVersion getTuple list put putWrites

Constructors

constructor

new MemorySaver(serde?: SerializerProtocol): MemorySaver
Parameters
- Optionalserde: SerializerProtocol
Returns MemorySaver
Overrides BaseCheckpointSaver.constructor
- Defined in memory.ts:42

Properties

serde

serde: SerializerProtocol = ...

storage

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

writes

writes: Record<string, Record<string, [string, string, Uint8Array]>> = {}

Methods

deleteThread

deleteThread(threadId: string): 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>
Overrides BaseCheckpointSaver.deleteThread
- Defined in memory.ts:404

get

get(config: RunnableConfig): Promise<undefined | Checkpoint<string, string>>
Parameters
- config: RunnableConfig
Returns Promise<undefined | Checkpoint<string, string>>
Inherited from BaseCheckpointSaver.get
- Defined in base.ts:119

getNextVersion

getNextVersion(current: undefined | number): 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
Inherited from BaseCheckpointSaver.getNextVersion
- Defined in base.ts:161

getTuple

getTuple(config: RunnableConfig): Promise<undefined | CheckpointTuple>
Parameters
- config: RunnableConfig
Returns Promise<undefined | CheckpointTuple>
Overrides BaseCheckpointSaver.getTuple
- Defined in memory.ts:77

list

list(
config: RunnableConfig,
options?: CheckpointListOptions,
): AsyncGenerator<CheckpointTuple>
Parameters
- config: RunnableConfig
- Optionaloptions: CheckpointListOptions
Returns AsyncGenerator<CheckpointTuple>
Overrides BaseCheckpointSaver.list
- Defined in memory.ts:198

put

put(
    config: RunnableConfig,
    checkpoint: Checkpoint,
    metadata: CheckpointMetadata,
): Promise<RunnableConfig<Record<string, any>>>
Parameters
- config: RunnableConfig
- checkpoint: Checkpoint
- metadata: CheckpointMetadata
Returns Promise<RunnableConfig<Record<string, any>>>
Overrides BaseCheckpointSaver.put
- Defined in memory.ts:322

putWrites

putWrites(
    config: RunnableConfig,
    writes: PendingWrite[],
    taskId: string,
): Promise<void>
Store intermediate writes linked to a checkpoint.
Parameters
- config: RunnableConfig
- writes: PendingWrite[]
- taskId: string
Returns Promise<void>
Overrides BaseCheckpointSaver.putWrites
- Defined in memory.ts:364