Class BaseCheckpointSaver<V>Abstract

constructor

• new BaseCheckpointSaver<V>(serde?): BaseCheckpointSaver<V>

• Type Parameters

  • V extends string | number = number

  Parameters

  • Optional serde: SerializerProtocol

  Returns BaseCheckpointSaver<V>

serde

Abstract deleteThread

• deleteThread(threadId): 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>

get

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

• Parameters

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

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

getNextVersion

• getNextVersion(current): V

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

  Returns V

Abstract getTuple

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

• Parameters

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

  Returns Promise<undefined | CheckpointTuple>

Abstract list

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

• Parameters

  • config: RunnableConfig<Record<string, any>>
  • Optional options: CheckpointListOptions

  Returns AsyncGenerator<CheckpointTuple, any, any>

Abstract put

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

• Parameters

  • config: RunnableConfig<Record<string, any>>
  • checkpoint: Checkpoint<string, string>
  • metadata: CheckpointMetadata
  • newVersions: ChannelVersions

  Returns Promise<RunnableConfig<Record<string, any>>>

Abstract putWrites

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

• Store intermediate writes linked to a checkpoint.

  Parameters

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

  Returns Promise<void>