Skip to content

@codesoul-co/hypha-memory / memory-server-consumer-migration

模块用法

用于使用该功能边界的公共契约与操作。Memory server consumer migration 模块公开 1 常量、3 函数、7 接口、2 类型。

从包入口导入

ts
import {
  allowedLegacyAdapterResponsibilities,
  assertCanonicalConsumerSet,
  createMemoryServerCanonicalMigrationState,
  transitionMemoryServerCanonicalMigration,
} from '@codesoul-co/hypha-memory';

import type {
  CanonicalProfileSwitchObservation,
  MemoryServerCanonicalMigrationState,
  MemoryServerMigrationReconciliation,
  MemoryServerMigrationRetirementEvidence,
  MemoryServerMigrationTransitionEvent,
  MemoryServerMigrationTransitionInput,
  MemoryServerMigrationTransitionResult,
  AllowedLegacyAdapterResponsibility,
} from '@codesoul-co/hypha-memory';

// 完整导出列表见下方。

使用要点

  • 9 个类型/接口用于应用代码、Adapter 或测试中的静态契约;请使用 import type,运行时不应依赖它们。
  • 3 个函数是该模块的直接操作入口;每个 overload 的必需/可选参数与返回类型均在下方列出。
  • 1 个常量/枚举提供稳定值、Schema、Definition 或默认配置;应复用这些导出,避免在应用中复制内部值。

公共导出

Symbol种类签名说明
allowedLegacyAdapterResponsibilities常量const allowedLegacyAdapterResponsibilities: readonly ["delegate", "scope_mapping", "error_mapping"]memory-server-consumer-migration 模块导出的 Allowed Legacy Adapter Responsibilities 常量。
assertCanonicalConsumerSet函数assertCanonicalConsumerSet(bindings: Partial<Record<MemoryServerConsumer, string>>, expectedServiceInstanceId: string, consumers: readonly MemoryServerConsumer[]): voidAssert Canonical Consumer Set 函数,提供 1 个公开调用签名;参数与返回类型见下表。
createMemoryServerCanonicalMigrationState函数createMemoryServerCanonicalMigrationState(input: { migrationId: string; revision: string; createdAt: string; }): MemoryServerCanonicalMigrationStateCreate Memory Server Canonical Migration State 函数,提供 1 个公开调用签名;参数与返回类型见下表。
transitionMemoryServerCanonicalMigration函数transitionMemoryServerCanonicalMigration(current: MemoryServerCanonicalMigrationState, input: MemoryServerMigrationTransitionInput): MemoryServerMigrationTransitionResultTransition Memory Server Canonical Migration 函数,提供 1 个公开调用签名;参数与返回类型见下表。
CanonicalProfileSwitchObservation接口interface CanonicalProfileSwitchObservationCanonical Profile Switch Observation 接口,共包含 4 个公开字段或方法。
MemoryServerCanonicalMigrationState接口interface MemoryServerCanonicalMigrationStateMemory Server Canonical Migration State 接口,共包含 8 个公开字段或方法。
MemoryServerMigrationReconciliation接口interface MemoryServerMigrationReconciliationMemory Server Migration Reconciliation 接口,共包含 4 个公开字段或方法。
MemoryServerMigrationRetirementEvidence接口interface MemoryServerMigrationRetirementEvidenceMemory Server Migration Retirement Evidence 接口,共包含 5 个公开字段或方法。
MemoryServerMigrationTransitionEvent接口interface MemoryServerMigrationTransitionEventMemory Server Migration Transition Event 接口,共包含 10 个公开字段或方法。
MemoryServerMigrationTransitionInput接口interface MemoryServerMigrationTransitionInputMemory Server Migration Transition Input 接口,共包含 7 个公开字段或方法。
MemoryServerMigrationTransitionResult接口interface MemoryServerMigrationTransitionResultMemory Server Migration Transition Result 接口,共包含 2 个公开字段或方法。
AllowedLegacyAdapterResponsibility类型type AllowedLegacyAdapterResponsibility = (typeof allowedLegacyAdapterResponsibilities)[number]Allowed Legacy Adapter Responsibility 公共类型别名;完整类型表达式见声明。
MemoryServerMigrationPhase类型type MemoryServerMigrationPhase = 'planned' | 'shadow_read' | 'bounded_dual_write' | 'verify' | 'cutover' | 'retire' | 'rollback'Memory Server Migration Phase 公共类型别名;完整类型表达式见声明。

allowedLegacyAdapterResponsibilities

memory-server-consumer-migration 模块导出的 Allowed Legacy Adapter Responsibilities 常量。

声明

text
export declare const allowedLegacyAdapterResponsibilities: readonly ["delegate", "scope_mapping", "error_mapping"];

assertCanonicalConsumerSet

Assert Canonical Consumer Set 函数,提供 1 个公开调用签名;参数与返回类型见下表。

声明

text
export declare function assertCanonicalConsumerSet(bindings: Partial<Record<MemoryServerConsumer, string>>, expectedServiceInstanceId: string, consumers: readonly MemoryServerConsumer[]): void;

调用签名

text
assertCanonicalConsumerSet(bindings: Partial<Record<MemoryServerConsumer, string>>, expectedServiceInstanceId: string, consumers: readonly MemoryServerConsumer[]): void

参数

参数类型必需说明
bindingsPartial<Record<MemoryServerConsumer, string>>必需参数;接受的值由类型列定义。
expectedServiceInstanceIdstring必需参数;接受的值由类型列定义。
consumersreadonly MemoryServerConsumer[]必需参数;接受的值由类型列定义。

返回值

  • 类型: void
  • 说明: 不返回值。

createMemoryServerCanonicalMigrationState

Create Memory Server Canonical Migration State 函数,提供 1 个公开调用签名;参数与返回类型见下表。

声明

text
export declare function createMemoryServerCanonicalMigrationState(input: {
    migrationId: string;
    revision: string;
    createdAt: string;
}): MemoryServerCanonicalMigrationState;

调用签名

text
createMemoryServerCanonicalMigrationState(input: { migrationId: string; revision: string; createdAt: string; }): MemoryServerCanonicalMigrationState

参数

参数类型必需说明
input{ migrationId: string; revision: string; createdAt: string; }必需参数;接受的值由类型列定义。

返回值

  • 类型: MemoryServerCanonicalMigrationState
  • 说明: 返回值契约由上述类型定义。

transitionMemoryServerCanonicalMigration

Transition Memory Server Canonical Migration 函数,提供 1 个公开调用签名;参数与返回类型见下表。

声明

text
export declare function transitionMemoryServerCanonicalMigration(current: MemoryServerCanonicalMigrationState, input: MemoryServerMigrationTransitionInput): MemoryServerMigrationTransitionResult;

调用签名

text
transitionMemoryServerCanonicalMigration(current: MemoryServerCanonicalMigrationState, input: MemoryServerMigrationTransitionInput): MemoryServerMigrationTransitionResult

参数

参数类型必需说明
currentMemoryServerCanonicalMigrationState必需参数;接受的值由类型列定义。
inputMemoryServerMigrationTransitionInput必需参数;接受的值由类型列定义。

返回值

  • 类型: MemoryServerMigrationTransitionResult
  • 说明: 返回值契约由上述类型定义。

CanonicalProfileSwitchObservation

Canonical Profile Switch Observation 接口,共包含 4 个公开字段或方法。

声明

text
export interface CanonicalProfileSwitchObservation {
    profileId: string;
    expectedProviderId: string;
    observedReadProviderId: string;
    observedWriteProviderId: string;
}

契约成员

成员种类签名说明
expectedProviderId属性expectedProviderId: string公开属性;类型、只读和可选状态以签名列为准。
observedReadProviderId属性observedReadProviderId: string公开属性;类型、只读和可选状态以签名列为准。
observedWriteProviderId属性observedWriteProviderId: string公开属性;类型、只读和可选状态以签名列为准。
profileId属性profileId: string公开属性;类型、只读和可选状态以签名列为准。

MemoryServerCanonicalMigrationState

Memory Server Canonical Migration State 接口,共包含 8 个公开字段或方法。

声明

text
export interface MemoryServerCanonicalMigrationState {
    migrationId: string;
    revision: string;
    phase: MemoryServerMigrationPhase;
    activePath: 'legacy' | 'dual' | 'canonical';
    updatedAt: string;
    dualWrite?: {
        deadlineAt: string;
        idempotencyKey: string;
        checkpointRef: string;
    };
    reconciliation: MemoryServerMigrationReconciliation;
    retirement?: MemoryServerMigrationRetirementEvidence;
}

契约成员

成员种类签名说明
activePath属性activePath: "legacy" | "dual" | "canonical"公开属性;类型、只读和可选状态以签名列为准。
dualWrite属性dualWrite?: { deadlineAt: string; idempotencyKey: string; checkpointRef: string; }公开属性;类型、只读和可选状态以签名列为准。
migrationId属性migrationId: string公开属性;类型、只读和可选状态以签名列为准。
phase属性phase: MemoryServerMigrationPhase公开属性;类型、只读和可选状态以签名列为准。
reconciliation属性reconciliation: MemoryServerMigrationReconciliation公开属性;类型、只读和可选状态以签名列为准。
retirement属性retirement?: MemoryServerMigrationRetirementEvidence公开属性;类型、只读和可选状态以签名列为准。
revision属性revision: string公开属性;类型、只读和可选状态以签名列为准。
updatedAt属性updatedAt: string公开属性;类型、只读和可选状态以签名列为准。

MemoryServerMigrationReconciliation

Memory Server Migration Reconciliation 接口,共包含 4 个公开字段或方法。

声明

text
export interface MemoryServerMigrationReconciliation {
    status: 'not_run' | 'passed' | 'failed';
    comparedRecords: number;
    mismatchCount: number;
    shadowResult: 'not_run' | 'matched' | 'mismatched';
}

契约成员

成员种类签名说明
comparedRecords属性comparedRecords: number公开属性;类型、只读和可选状态以签名列为准。
mismatchCount属性mismatchCount: number公开属性;类型、只读和可选状态以签名列为准。
shadowResult属性shadowResult: "not_run" | "matched" | "mismatched"公开属性;类型、只读和可选状态以签名列为准。
status属性status: "failed" | "not_run" | "passed"公开属性;类型、只读和可选状态以签名列为准。

MemoryServerMigrationRetirementEvidence

Memory Server Migration Retirement Evidence 接口,共包含 5 个公开字段或方法。

声明

text
export interface MemoryServerMigrationRetirementEvidence {
    legacyReadTraffic: number;
    legacyWriteTraffic: number;
    legacyImports: number;
    legacyRegistrations: number;
    rollbackWindowEndsAt: string;
}

契约成员

成员种类签名说明
legacyImports属性legacyImports: number公开属性;类型、只读和可选状态以签名列为准。
legacyReadTraffic属性legacyReadTraffic: number公开属性;类型、只读和可选状态以签名列为准。
legacyRegistrations属性legacyRegistrations: number公开属性;类型、只读和可选状态以签名列为准。
legacyWriteTraffic属性legacyWriteTraffic: number公开属性;类型、只读和可选状态以签名列为准。
rollbackWindowEndsAt属性rollbackWindowEndsAt: string公开属性;类型、只读和可选状态以签名列为准。

MemoryServerMigrationTransitionEvent

Memory Server Migration Transition Event 接口,共包含 10 个公开字段或方法。

声明

text
export interface MemoryServerMigrationTransitionEvent {
    type: 'memory.server_migration.transitioned';
    migrationId: string;
    migrationRevision: string;
    fromPhase: MemoryServerMigrationPhase;
    toPhase: MemoryServerMigrationPhase;
    activePath: 'legacy' | 'dual' | 'canonical';
    shadowResult: MemoryServerMigrationReconciliation['shadowResult'];
    checkpointRef?: string;
    reason: string;
    occurredAt: string;
}

契约成员

成员种类签名说明
activePath属性activePath: "legacy" | "dual" | "canonical"公开属性;类型、只读和可选状态以签名列为准。
checkpointRef属性checkpointRef?: string公开属性;类型、只读和可选状态以签名列为准。
fromPhase属性fromPhase: MemoryServerMigrationPhase公开属性;类型、只读和可选状态以签名列为准。
migrationId属性migrationId: string公开属性;类型、只读和可选状态以签名列为准。
migrationRevision属性migrationRevision: string公开属性;类型、只读和可选状态以签名列为准。
occurredAt属性occurredAt: string公开属性;类型、只读和可选状态以签名列为准。
reason属性reason: string公开属性;类型、只读和可选状态以签名列为准。
shadowResult属性shadowResult: "not_run" | "matched" | "mismatched"公开属性;类型、只读和可选状态以签名列为准。
toPhase属性toPhase: MemoryServerMigrationPhase公开属性;类型、只读和可选状态以签名列为准。
type属性type: "memory.server_migration.transitioned"公开属性;类型、只读和可选状态以签名列为准。

MemoryServerMigrationTransitionInput

Memory Server Migration Transition Input 接口,共包含 7 个公开字段或方法。

声明

text
export interface MemoryServerMigrationTransitionInput {
    targetPhase: Exclude<MemoryServerMigrationPhase, 'planned'>;
    expectedRevision: string;
    occurredAt: string;
    reason: string;
    dualWrite?: {
        deadlineAt: string;
        idempotencyKey: string;
        checkpointRef: string;
    };
    reconciliation?: MemoryServerMigrationReconciliation;
    retirement?: MemoryServerMigrationRetirementEvidence;
}

契约成员

成员种类签名说明
dualWrite属性dualWrite?: { deadlineAt: string; idempotencyKey: string; checkpointRef: string; }公开属性;类型、只读和可选状态以签名列为准。
expectedRevision属性expectedRevision: string公开属性;类型、只读和可选状态以签名列为准。
occurredAt属性occurredAt: string公开属性;类型、只读和可选状态以签名列为准。
reason属性reason: string公开属性;类型、只读和可选状态以签名列为准。
reconciliation属性reconciliation?: MemoryServerMigrationReconciliation公开属性;类型、只读和可选状态以签名列为准。
retirement属性retirement?: MemoryServerMigrationRetirementEvidence公开属性;类型、只读和可选状态以签名列为准。
targetPhase属性targetPhase: "verify" | "shadow_read" | "bounded_dual_write" | "cutover" | "retire" | "rollback"公开属性;类型、只读和可选状态以签名列为准。

MemoryServerMigrationTransitionResult

Memory Server Migration Transition Result 接口,共包含 2 个公开字段或方法。

声明

text
export interface MemoryServerMigrationTransitionResult {
    state: MemoryServerCanonicalMigrationState;
    event: MemoryServerMigrationTransitionEvent;
}

契约成员

成员种类签名说明
event属性event: MemoryServerMigrationTransitionEvent公开属性;类型、只读和可选状态以签名列为准。
state属性state: MemoryServerCanonicalMigrationState公开属性;类型、只读和可选状态以签名列为准。

AllowedLegacyAdapterResponsibility

Allowed Legacy Adapter Responsibility 公共类型别名;完整类型表达式见声明。

声明

text
export type AllowedLegacyAdapterResponsibility = (typeof allowedLegacyAdapterResponsibilities)[number];

MemoryServerMigrationPhase

Memory Server Migration Phase 公共类型别名;完整类型表达式见声明。

声明

text
export type MemoryServerMigrationPhase = 'planned' | 'shadow_read' | 'bounded_dual_write' | 'verify' | 'cutover' | 'retire' | 'rollback';