import { Transport, MessageHandler, RequestHandler, Subscription } from "../transport.js";
export declare class FaultyTransport implements Transport {
    private readonly inner;
    private readonly partitionedPeers;
    private readonly log;
    constructor(inner: Transport);
    /**
     * Block all outbound traffic to the given peer.
     * Requests will throw TransportError, sends will be silently dropped.
     */
    partition(nodeId: string): void;
    /**
     * Restore outbound traffic to the given peer.
     */
    heal(nodeId: string): void;
    /**
     * Restore all partitions.
     */
    healAll(): void;
    /**
     * Check if a peer is currently partitioned.
     */
    isPartitioned(nodeId: string): boolean;
    /**
     * Get all currently partitioned peer IDs.
     */
    getPartitionedPeers(): string[];
    getNodeId(): string;
    connect(): Promise<void>;
    disconnect(): Promise<void>;
    request(nodeId: string, message: any, timeout: number): Promise<any>;
    send(nodeId: string, message: any): Promise<void>;
    publish(topic: string, message: any): Promise<void>;
    subscribe(topic: string, handler: MessageHandler): Promise<Subscription>;
    onRequest(handler: RequestHandler): void;
    onMessage(handler: MessageHandler): void;
    updatePeers(peers: Array<[nodeId: string, address: string]>): void;
}
//# sourceMappingURL=faulty_transport.d.ts.map