import * as Cause from "effect/Cause";
import * as Context from "effect/Context";
import * as Effect from "effect/Effect";
import * as Option from "effect/Option";
import * as Schema from "effect/Schema";
import * as Stream from "effect/Stream";
/**
 * @experimental
 */
export interface QueryStreamReadBudget {
    readonly isUnlimited: Effect.Effect<boolean>;
    readonly isStopped: Effect.Effect<boolean>;
    readonly isExhausted: Effect.Effect<boolean>;
    readonly getReadCounts: Effect.Effect<ReadCounts>;
    /**
     * Returns a stream that records reads against this budget and stops
     * requesting further batches once exhausted. Apply directly to the document
     * source before buffering, filtering, or combining its output.
     */
    readonly accountFor: (encodedDocuments: Stream.Stream<unknown>) => Stream.Stream<unknown>;
}
/**
 * @experimental
 */
export declare const Limits: Schema.Struct<{
    readonly maximumRowsRead: Schema.OptionFromOptionalKey<Schema.brand<Schema.Natural, "~@confect/server/QueryStreamReadBudget/ReadLimit">>;
    readonly maximumBytesRead: Schema.OptionFromOptionalKey<Schema.brand<Schema.Natural, "~@confect/server/QueryStreamReadBudget/ReadLimit">>;
}>;
/**
 * @experimental
 */
export type Limits = typeof Limits.Type;
declare const InvalidReadLimitError_base: new <A extends Record<string, any> = {}>(args: import("effect/Types").VoidIfEmpty<{ readonly [P in keyof A as P extends "_tag" ? never : P]: A[P]; }>) => Cause.YieldableError & {
    readonly _tag: "InvalidReadLimitError";
} & Readonly<A>;
/**
 * @experimental
 */
export declare class InvalidReadLimitError extends InvalidReadLimitError_base<{
    readonly cause: Schema.SchemaError;
}> {
    get message(): string;
}
/**
 * @experimental
 */
export interface ReadCounts {
    readonly rowsRead: number;
    readonly bytesRead: number;
}
/**
 * @experimental
 */
export declare const QueryStreamReadBudget: Context.Service<QueryStreamReadBudget, QueryStreamReadBudget>;
/**
 * @experimental
 */
export declare const make: (limits: {
    readonly maximumRowsRead: Option.Option<number & import("effect/Brand").Brand<"~@confect/server/QueryStreamReadBudget/ReadLimit">>;
    readonly maximumBytesRead: Option.Option<number & import("effect/Brand").Brand<"~@confect/server/QueryStreamReadBudget/ReadLimit">>;
}) => Effect.Effect<QueryStreamReadBudget, never, never>;
export {};
//# sourceMappingURL=QueryStreamReadBudget.d.ts.map