Class RedisSaver

Hierarchy (View Summary)

BaseDynamicToolInput
- RedisSaver

Index

Constructors

Methods

deleteThread end get getTuple list put putWrites fromCluster fromUrl

Constructors

constructor

new RedisSaver(client: RedisClientType, ttlConfig?: TTLConfig): RedisSaver
Parameters
- client: RedisClientType
- OptionalttlConfig: TTLConfig
Returns RedisSaver
Overrides BaseCheckpointSaver.constructor
- Defined in index.ts:90

Methods

deleteThread

deleteThread(threadId: string): Promise<void>
Parameters
- threadId: string
Returns Promise<void>
- Defined in index.ts:659

end

end(): Promise<void>
Returns Promise<void>
- Defined in index.ts:681

get

get(config: RunnableConfig): Promise<any>
Parameters
- config: RunnableConfig
Returns Promise<any>
- Defined in index.ts:118

getTuple

getTuple(config: RunnableConfig): Promise<any>
Parameters
- config: RunnableConfig
Returns Promise<any>
- Defined in index.ts:123

list

list(
config: null | RunnableConfig<Record<string, any>>,
options?: any,
): AsyncGenerator<CheckpointTuple>
Parameters
- config: null | RunnableConfig<Record<string, any>>
- Optionaloptions: any
Returns AsyncGenerator<CheckpointTuple>
- Defined in index.ts:248

put

put(
    config: RunnableConfig,
    checkpoint: Checkpoint,
    metadata: CheckpointMetadata,
    newVersions: ChannelVersions,
): Promise<RunnableConfig<Record<string, any>>>
Parameters
- config: RunnableConfig
- checkpoint: Checkpoint
- metadata: CheckpointMetadata
- newVersions: ChannelVersions
Returns Promise<RunnableConfig<Record<string, any>>>
- Defined in index.ts:172

putWrites

putWrites(
    config: RunnableConfig,
    writes: PendingWrite[],
    taskId: string,
): Promise<void>
Parameters
- config: RunnableConfig
- writes: PendingWrite[]
- taskId: string
Returns Promise<void>
- Defined in index.ts:580

`Static`fromCluster

fromCluster(
rootNodes: { url: string }[],
ttlConfig?: TTLConfig,
): Promise<RedisSaver>
Parameters
- rootNodes: { url: string }[]
- OptionalttlConfig: TTLConfig
Returns Promise<RedisSaver>
- Defined in index.ts:107

`Static`fromUrl

fromUrl(url: string, ttlConfig?: TTLConfig): Promise<RedisSaver>
Parameters
- url: string
- OptionalttlConfig: TTLConfig
Returns Promise<RedisSaver>
- Defined in index.ts:96