Class MemorySaver

constructor

• new MemorySaver(serde?: SerializerProtocol): MemorySaver

  Parameters

  • Optionalserde: SerializerProtocol

  Returns MemorySaver

storage

writes

_getPendingSends

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

  Parameters

  • threadId: string
  • checkpointNs: string
  • OptionalparentCheckpointId: string

  Returns Promise<SendProtocol[]>

getTuple

• getTuple(config: RunnableConfig): Promise<undefined | CheckpointTuple>

  Parameters

  • config: RunnableConfig

  Returns Promise<undefined | CheckpointTuple>

list

• list(
      config: RunnableConfig,
      options?: CheckpointListOptions,
  ): AsyncGenerator<CheckpointTuple>

  Parameters

  • config: RunnableConfig
  • Optionaloptions: CheckpointListOptions

  Returns AsyncGenerator<CheckpointTuple>

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>>>

putWrites

• putWrites(
      config: RunnableConfig,
      writes: PendingWrite<string>[],
      taskId: string,
  ): Promise<void>

  Store intermediate writes linked to a checkpoint.

  Parameters

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

  Returns Promise<void>