Skip to content

@codesoul-co/hypha-adapters-local / react-continuation-checkpoint-store

模块用法

用于持久化并读取该边界的数据。React continuation checkpoint store 模块公开 1 类、1 接口。

从包入口导入

ts
import {
  SQLiteReActContinuationCheckpointStore,
} from '@codesoul-co/hypha-adapters-local';

import type {
  SQLiteReActContinuationCheckpointStoreOptions,
} from '@codesoul-co/hypha-adapters-local';

使用要点

  • 1 个类型/接口用于应用代码、Adapter 或测试中的静态契约;请使用 import type,运行时不应依赖它们。
  • 1 个类提供可实例化的运行时实现;构造参数与公开方法在各自条目中完整列出。

公共导出

Symbol种类签名说明
SQLiteReActContinuationCheckpointStorenew SQLiteReActContinuationCheckpointStore(options: SQLiteReActContinuationCheckpointStoreOptions): SQLiteReActContinuationCheckpointStoreLocal durable materialization for resumable ReAct work. Runtime Events remain the execution truth. This store contains only bounded, schema-validated continuation material and rejects stale checkpoint writers.
SQLiteReActContinuationCheckpointStoreOptions接口interface SQLiteReActContinuationCheckpointStoreOptionsSQLite ReAct Continuation Checkpoint Store Options 接口,共包含 3 个公开字段或方法。

SQLiteReActContinuationCheckpointStore

Local durable materialization for resumable ReAct work. Runtime Events remain the execution truth. This store contains only bounded, schema-validated continuation material and rejects stale checkpoint writers.

声明

text
export declare class SQLiteReActContinuationCheckpointStore implements ReActContinuationCheckpointStore {
    constructor(options: SQLiteReActContinuationCheckpointStoreOptions);
    put(input: ReActContinuationCheckpoint, idempotencyKey: string): Promise<ReActContinuationCheckpointPutResult>;
    get(runId: string, stepId: string, expectedScopeHash: string): Promise<ReActContinuationCheckpoint | null>;
    delete(runId: string, stepId: string, expectedScopeHash: string, expectedStepSequence?: number): Promise<boolean>;
    close(): void;
}

公开成员

成员种类签名说明
close方法close(): void公开方法;参数与返回类型以签名列为准。
constructor构造函数(options: SQLiteReActContinuationCheckpointStoreOptions): SQLiteReActContinuationCheckpointStore创建该类的实例。
delete方法delete(runId: string, stepId: string, expectedScopeHash: string, expectedStepSequence?: number): Promise<boolean>公开方法;参数与返回类型以签名列为准。
get方法get(runId: string, stepId: string, expectedScopeHash: string): Promise<ReActContinuationCheckpoint | null>公开方法;参数与返回类型以签名列为准。
put方法put(input: ReActContinuationCheckpoint, idempotencyKey: string): Promise<ReActContinuationCheckpointPutResult>公开方法;参数与返回类型以签名列为准。

SQLiteReActContinuationCheckpointStoreOptions

SQLite ReAct Continuation Checkpoint Store Options 接口,共包含 3 个公开字段或方法。

声明

text
export interface SQLiteReActContinuationCheckpointStoreOptions {
    filename: string;
    maxIdempotencyRecordsPerCheckpoint?: number;
    maxCheckpointBytes?: number;
}

契约成员

成员种类签名说明
filename属性filename: string公开属性;类型、只读和可选状态以签名列为准。
maxCheckpointBytes属性maxCheckpointBytes?: number公开属性;类型、只读和可选状态以签名列为准。
maxIdempotencyRecordsPerCheckpoint属性maxIdempotencyRecordsPerCheckpoint?: number公开属性;类型、只读和可选状态以签名列为准。