import type { Codec, MsgHdrs, NatsConnection, ReviverFn, WithRequired } from "@nats-io/nats-core/internal";
import { BaseApiClientImpl } from "./jsbaseclient_api";
import type { BoundPushConsumerOptions, Consumer, ConsumerAPI, Consumers, JetStreamOptions, Lister, OrderedConsumerOptions, OrderedPushConsumerOptions, PushConsumer, StoredMsg, Stream, StreamAPI, Streams } from "./types";
import type { ConsumerInfo, MsgRequest, PurgeOpts, PurgeResponse, StreamAlternate, StreamConfig, StreamInfo, StreamInfoRequestOptions, StreamMsgResponse, StreamSource, StreamUpdateConfig } from "./jsapi_types";
export declare function convertStreamSourceDomain(s?: StreamSource): StreamSource;
export declare class ConsumersImpl implements Consumers {
    api: ConsumerAPI;
    notified: boolean;
    constructor(api: ConsumerAPI);
    checkVersion(): Promise<void>;
    getPushConsumer(stream: string, name?: string | Partial<OrderedPushConsumerOptions>): Promise<PushConsumer>;
    getOrderedPushConsumer(stream: string, opts?: Partial<OrderedPushConsumerOptions>): Promise<PushConsumer>;
    getBoundPushConsumer(opts: BoundPushConsumerOptions): Promise<PushConsumer>;
    get(stream: string, name?: string | Partial<OrderedConsumerOptions>): Promise<Consumer>;
    getConsumerFromInfo(ci: ConsumerInfo): Consumer;
    ordered(stream: string, opts?: Partial<OrderedConsumerOptions>): Promise<Consumer>;
}
export declare class StreamImpl implements Stream {
    api: StreamAPIImpl;
    _info: StreamInfo;
    constructor(api: StreamAPI, info: StreamInfo);
    get name(): string;
    alternates(): Promise<StreamAlternate[]>;
    best(): Promise<Stream>;
    info(cached?: boolean, opts?: Partial<StreamInfoRequestOptions>): Promise<StreamInfo>;
    getConsumer(name?: string | Partial<OrderedConsumerOptions>): Promise<Consumer>;
    getPushConsumer(name?: string | Partial<OrderedPushConsumerOptions>): Promise<PushConsumer>;
    getMessage(query: MsgRequest): Promise<StoredMsg | null>;
    deleteMessage(seq: number, erase?: boolean): Promise<boolean>;
}
export declare class StreamAPIImpl extends BaseApiClientImpl implements StreamAPI {
    constructor(nc: NatsConnection, opts?: JetStreamOptions);
    checkStreamConfigVersions(cfg: Partial<StreamConfig>): void;
    add(cfg: WithRequired<Partial<StreamConfig>, "name">): Promise<StreamInfo>;
    delete(stream: string): Promise<boolean>;
    update(name: string, cfg?: Partial<StreamUpdateConfig>): Promise<StreamInfo>;
    info(name: string, data?: Partial<StreamInfoRequestOptions>): Promise<StreamInfo>;
    list(subject?: string): Lister<StreamInfo>;
    _fixInfo(si: StreamInfo): void;
    purge(name: string, opts?: PurgeOpts): Promise<PurgeResponse>;
    deleteMessage(stream: string, seq: number, erase?: boolean): Promise<boolean>;
    getMessage(stream: string, query: MsgRequest): Promise<StoredMsg | null>;
    find(subject: string): Promise<string>;
    names(subject?: string): Lister<string>;
    get(name: string): Promise<Stream>;
}
export declare class StoredMsgImpl implements StoredMsg {
    _header?: MsgHdrs;
    smr: StreamMsgResponse;
    static jc?: Codec<unknown>;
    constructor(smr: StreamMsgResponse);
    get pending(): number;
    get lastSequence(): number;
    get subject(): string;
    get seq(): number;
    get timestamp(): string;
    get time(): Date;
    get data(): Uint8Array;
    get header(): MsgHdrs;
    _parse(s: string): Uint8Array;
    json<T = unknown>(reviver?: ReviverFn): T;
    string(): string;
}
export declare class StreamsImpl implements Streams {
    api: StreamAPIImpl;
    constructor(api: StreamAPI);
    get(stream: string): Promise<Stream>;
}