import type { Msg } from "@nats-io/nats-core"; import { type Heartbeat } from "./types"; import type { ApiError } from "./jsapi_types"; export declare class JetStreamNotEnabled extends Error { constructor(message: string, opts?: ErrorOptions); } export declare class JetStreamError extends Error { constructor(message: string, opts?: ErrorOptions); } export declare class JetStreamStatusError extends JetStreamError { code: number; constructor(message: string, code: number, opts?: ErrorOptions); } export declare class JetStreamStatus { msg: Msg; _description: string; constructor(msg: Msg); static maybeParseStatus(msg: Msg): JetStreamStatus | null; toError(): JetStreamStatusError; debug(): void; get code(): number; get description(): string; isIdleHeartbeat(): boolean; isFlowControlRequest(): boolean; parseHeartbeat(): Heartbeat | null; isRequestTimeout(): boolean; parseDiscard(): { msgsLeft: number; bytesLeft: number; }; isBadRequest(): boolean; isConsumerDeleted(): boolean; isStreamDeleted(): boolean; isIdleHeartbeatMissed(): boolean; isMaxWaitingExceeded(): boolean; isConsumerIsPushBased(): boolean; isExceededMaxWaiting(): boolean; isExceededMaxRequestBatch(): boolean; isExceededMaxExpires(): boolean; isExceededLimit(): boolean; isMessageNotFound(): boolean; isNoResults(): boolean; isMessageSizeExceedsMaxBytes(): boolean; isEndOfBatch(): boolean; } export declare const JetStreamApiCodes: { readonly ConsumerNotFound: 10014; readonly StreamNotFound: 10059; readonly JetStreamNotEnabledForAccount: 10039; readonly StreamWrongLastSequence: 10071; readonly StreamWrongLastSequenceUnknown: 10164; readonly NoMessageFound: 10037; }; export type JetStreamApiCodes = typeof JetStreamApiCodes[keyof typeof JetStreamApiCodes]; export declare function isMessageNotFound(err: Error): boolean; export declare class InvalidNameError extends Error { constructor(message?: string, opts?: ErrorOptions); } export declare class JetStreamApiError extends Error { #private; constructor(jsErr: ApiError, opts?: ErrorOptions); get code(): number; get status(): number; apiError(): ApiError; } export declare class ConsumerNotFoundError extends JetStreamApiError { constructor(jsErr: ApiError, opts?: ErrorOptions); } export declare class StreamNotFoundError extends JetStreamApiError { constructor(jsErr: ApiError, opts?: ErrorOptions); static fromMessage(message: string): JetStreamApiError; } export declare const jserrors: { InvalidNameError: typeof InvalidNameError; ConsumerNotFoundError: typeof ConsumerNotFoundError; StreamNotFoundError: typeof StreamNotFoundError; JetStreamError: typeof JetStreamError; JetStreamApiError: typeof JetStreamApiError; JetStreamNotEnabled: typeof JetStreamNotEnabled; };