import { EngineService } from '../engine'; import { QuorumService } from '../quorum'; import { WorkerService } from '../worker'; import { QuorumMessage, QuorumMessageCallback, QuorumProfile, ThrottleOptions } from '../../types/quorum'; interface QuorumContext { engine: EngineService | null; quorum: QuorumService | null; workers: WorkerService[]; } /** * Broadcasts a roll call across the mesh and collects responses. */ export declare function rollCall(instance: QuorumContext, delay?: number): Promise; /** * Broadcasts a throttle command to the mesh via the quorum channel. */ export declare function throttle(instance: QuorumContext, options: ThrottleOptions): Promise; /** * Publishes a message to every mesh member via the quorum channel. */ export declare function pubQuorum(instance: QuorumContext, quorumMessage: QuorumMessage): Promise; /** * Subscribes to the quorum channel. */ export declare function subQuorum(instance: QuorumContext, callback: QuorumMessageCallback): Promise; /** * Unsubscribes a callback previously registered with `subQuorum()`. */ export declare function unsubQuorum(instance: QuorumContext, callback: QuorumMessageCallback): Promise; export {};