import WebSocket from 'ws';
import { StateObserver } from '../state/NodeState.js';
export declare const stateStreaming: (node: string) => StateStreamer;
export declare class StateStreamer implements StateObserver {
    states: Map<string, string[]>;
    private index;
    private clients;
    constructor(node: string);
    clear(): void;
    update(status: string, state: {
        [key: string]: string;
    }, timestamp: number): void;
    subscribe(ws: WebSocket, job: string): void;
    unsubscribe(ws: WebSocket): void;
}