import { Request } from "./requests/request";
import { Producer } from "./producer";
import { CreateStreamArguments } from "./requests/create_stream_request";
export declare class Connection {
    private readonly socket;
    private readonly logger;
    private correlationId;
    private decoder;
    private receivedResponses;
    private waitingResponses;
    private publisherId;
    private heartbeat;
    constructor();
    static connect(params: ConnectionParams): Promise<Connection>;
    start(params: ConnectionParams): Promise<Connection>;
    close(params?: {
        closingCode: number;
        closingReason: string;
    }): Promise<void>;
    declarePublisher(params: DeclarePublisherParams): Promise<Producer>;
    send(cmd: Request): Promise<void>;
    createStream(params: {
        stream: string;
        arguments: CreateStreamArguments;
    }): Promise<true>;
    deleteStream(params: {
        stream: string;
    }): Promise<true>;
    queryPublisherSequence(params: {
        stream: string;
        publisherRef: string;
    }): Promise<bigint>;
    private responseReceived;
    private received;
    private tune;
    private exchangeProperties;
    private auth;
    private open;
    private sendAndWait;
    private waitResponse;
    private incCorrelationId;
    private incPublisherId;
}
export interface ConnectionParams {
    hostname: string;
    port: number;
    username: string;
    password: string;
    vhost: string;
    frameMax?: number;
    heartbeat?: number;
}
export interface DeclarePublisherParams {
    stream: string;
    publisherRef: string;
}
export declare function connect(params: ConnectionParams): Promise<Connection>;