@codesoul-co/hypha-mcp / coordination

• 包索引: @codesoul-co/hypha-mcp
• 源码: packages/mcp/src/coordination.ts
• 导出数: 4

模块用法

用于使用该功能边界的公共契约与操作。Coordination 模块公开 1 类、3 接口。

从包入口导入

import {
  RedisMCPReconnectCoordinator,
} from '@codesoul-co/hypha-mcp';

import type {
  MCPReconnectCoordinator,
  MCPReconnectLease,
  RedisLikeMCPLeaseClient,
} from '@codesoul-co/hypha-mcp';

使用要点

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

公共导出

Symbol	种类	签名	说明
RedisMCPReconnectCoordinator	类	new RedisMCPReconnectCoordinator(client: RedisLikeMCPLeaseClient, namespace?: string, now?: () => number): RedisMCPReconnectCoordinator	A per-server Redis lease that prevents reconnect storms across workers.
MCPReconnectCoordinator	接口	interface MCPReconnectCoordinator	MCP Reconnect Coordinator 接口，共包含 1 个公开字段或方法。
MCPReconnectLease	接口	interface MCPReconnectLease	MCP Reconnect Lease 接口，共包含 6 个公开字段或方法。
RedisLikeMCPLeaseClient	接口	interface RedisLikeMCPLeaseClient	Redis Like MCP Lease Client 接口，共包含 2 个公开字段或方法。

RedisMCPReconnectCoordinator

A per-server Redis lease that prevents reconnect storms across workers.

• 种类: 类
• 导入: import { RedisMCPReconnectCoordinator } from '@codesoul-co/hypha-mcp';
• 源码模块: coordination

声明

export declare class RedisMCPReconnectCoordinator implements MCPReconnectCoordinator {
    constructor(client: RedisLikeMCPLeaseClient, namespace?: string, now?: () => number);
    acquire(input: {
            serverId: string;
            ownerId: string;
            ttlMs: number;
        }): Promise<MCPReconnectLease | null>;
}

公开成员

成员	种类	签名	说明
acquire	方法	acquire(input: { serverId: string; ownerId: string; ttlMs: number; }): Promise<MCPReconnectLease | null>	公开方法；参数与返回类型以签名列为准。
constructor	构造函数	(client: RedisLikeMCPLeaseClient, namespace?: string, now?: () => number): RedisMCPReconnectCoordinator	创建该类的实例。

MCPReconnectCoordinator

MCP Reconnect Coordinator 接口，共包含 1 个公开字段或方法。

• 种类: 接口
• 导入: import type { MCPReconnectCoordinator } from '@codesoul-co/hypha-mcp';
• 源码模块: coordination

声明

export interface MCPReconnectCoordinator {
    acquire(input: {
        serverId: string;
        ownerId: string;
        ttlMs: number;
    }): Promise<MCPReconnectLease | null>;
}

契约成员

成员	种类	签名	说明
acquire	方法	acquire(input: { serverId: string; ownerId: string; ttlMs: number; }): Promise<MCPReconnectLease | null>	公开方法；参数与返回类型以签名列为准。

MCPReconnectLease

MCP Reconnect Lease 接口，共包含 6 个公开字段或方法。

• 种类: 接口
• 导入: import type { MCPReconnectLease } from '@codesoul-co/hypha-mcp';
• 源码模块: coordination

声明

export interface MCPReconnectLease {
    serverId: string;
    ownerId: string;
    fencingToken: string;
    expiresAt: string;
    assertCurrent(): Promise<void>;
    release(): Promise<void>;
}

契约成员

成员	种类	签名	说明
assertCurrent	方法	assertCurrent(): Promise<void>	公开方法；参数与返回类型以签名列为准。
expiresAt	属性	expiresAt: string	公开属性；类型、只读和可选状态以签名列为准。
fencingToken	属性	fencingToken: string	公开属性；类型、只读和可选状态以签名列为准。
ownerId	属性	ownerId: string	公开属性；类型、只读和可选状态以签名列为准。
release	方法	release(): Promise<void>	公开方法；参数与返回类型以签名列为准。
serverId	属性	serverId: string	公开属性；类型、只读和可选状态以签名列为准。

RedisLikeMCPLeaseClient

Redis Like MCP Lease Client 接口，共包含 2 个公开字段或方法。

• 种类: 接口
• 导入: import type { RedisLikeMCPLeaseClient } from '@codesoul-co/hypha-mcp';
• 源码模块: coordination

声明

export interface RedisLikeMCPLeaseClient {
    set(key: string, value: string, mode: 'PX', ttlMs: number, condition: 'NX'): Promise<string | null>;
    eval(script: string, numberOfKeys: number, ...args: Array<string | number>): Promise<number | string | null>;
}

契约成员

成员	种类	签名	说明
eval	方法	eval(script: string, numberOfKeys: number, ...args: Array<string | number>): Promise<number | string | null>	公开方法；参数与返回类型以签名列为准。
set	方法	set(key: string, value: string, mode: "PX", ttlMs: number, condition: "NX"): Promise<string | null>	公开方法；参数与返回类型以签名列为准。