/** Message sent from TestCluster to NodeWorker via IPC */ export interface NodeWorkerBootMessage { type: "boot"; config: { nodeId: string; port: number; seedNodes: string[]; cookie?: string; advertiseAddress?: string; actorModules?: string[]; /** Enable fault injection wrappers (FaultyTransport + FaultyGossipUDP) */ faultInjection?: boolean; }; } /** Message sent from NodeWorker to TestCluster via IPC */ export interface NodeWorkerReadyMessage { type: "ready"; nodeId: string; /** Internal actor ID of the NodeAgent (for direct ref construction) */ agentActorId: string; /** Registered name of the NodeAgent */ agentName: string; } /** Message sent from NodeWorker to TestCluster on boot failure */ export interface NodeWorkerErrorMessage { type: "error"; error: string; } /** Shutdown request from TestCluster */ export interface NodeWorkerShutdownMessage { type: "shutdown"; } /** Request from TestCluster to re-publish all registry entries */ export interface NodeWorkerResyncRegistryMessage { type: "resync-registry"; } /** Request from TestCluster to partition this node from specified peers */ export interface NodeWorkerPartitionMessage { type: "partition"; /** NodeIDs to partition from */ targetNodeIds: string[]; /** Gossip addresses to block (e.g., ["127.0.0.1:5002"]) */ targetGossipAddresses: string[]; } /** Request from TestCluster to heal partitions */ export interface NodeWorkerHealMessage { type: "heal"; /** NodeIDs to heal (empty = heal all) */ targetNodeIds: string[]; /** Gossip addresses to unblock */ targetGossipAddresses: string[]; } export type NodeWorkerMessage = NodeWorkerBootMessage | NodeWorkerShutdownMessage | NodeWorkerResyncRegistryMessage | NodeWorkerPartitionMessage | NodeWorkerHealMessage; export type NodeWorkerResponse = NodeWorkerReadyMessage | NodeWorkerErrorMessage; //# sourceMappingURL=node_worker.d.ts.map