import type { google } from '@gcf/firestore-protos';
import { Firestore } from 'firebase-admin/firestore';
import { CallOptions } from 'google-gax';
import { Duplex } from 'stream';
import { DatabasePool } from '../database-pool.js';
import { GapicClient } from '../firestore/types.js';
import { GapicContext } from './gapic-context.js';
export declare class MockGapicClient implements GapicClient {
    private _terminated;
    readonly context: GapicContext;
    private readonly _transactionManager;
    private readonly _streams;
    constructor(firestore: Firestore, pool: DatabasePool);
    /**
     * Invoked directly from `Firestore.initializeIfNeeded()`
     */
    getProjectId(): Promise<string>;
    /**
     * Invoked via
     * - `WriteBatch._commit`
     */
    beginTransaction(request: google.firestore.v1.IBeginTransactionRequest, _options?: CallOptions): Promise<[
        google.firestore.v1.IBeginTransactionResponse,
        unknown,
        unknown
    ]>;
    /**
     * Invoked via:
     * - `WriteBatch._commit()`
     */
    commit(request: google.firestore.v1.ICommitRequest, _options?: CallOptions): Promise<[google.firestore.v1.ICommitResponse, unknown, unknown]>;
    /**
     * Invoked via
     * - `WriteBatch._commit`
     */
    batchWrite(request: google.firestore.v1.IBatchWriteRequest, _options?: CallOptions): Promise<[google.firestore.v1.IBatchWriteResponse, unknown, unknown]>;
    /**
     * Invoked via:
     * - `Transaction.rollback()`
     * - `WriteBatch._commit`
     */
    rollback(request: google.firestore.v1.IRollbackRequest, _options?: CallOptions): Promise<[google.protobuf.IEmpty, unknown, unknown]>;
    /**
     * Invoked via
     * - `DocumentReader.fetchDocuments()`
     */
    batchGetDocuments(request?: google.firestore.v1.IBatchGetDocumentsRequest, _options?: CallOptions): Duplex;
    /**
     * Invoked via `QueryUtil._stream()`
     */
    runQuery(request?: google.firestore.v1.IRunQueryRequest, _options?: CallOptions): Duplex;
    /**
     * Invoked via
     * - `AggregateQuery._stream()`
     *
     * Supports `.count()` aggregate queries over a base `StructuredQuery`.
     * Only `COUNT(*)` is supported; other aggregation types are not implemented.
     */
    runAggregationQuery(request?: google.firestore.v1.IRunAggregationQueryRequest, _options?: CallOptions): Duplex;
    /**
     * Invoked via
     * - `CollectionReference.listDocuments()`
     * - `WriteBatch._commit`
     */
    listDocuments(request: google.firestore.v1.IListDocumentsRequest, _options?: CallOptions): Promise<[google.firestore.v1.IDocument[], unknown, unknown]>;
    /**
     * Invoked via
     * - `DocumentReference.listCollections()`
     * - `WriteBatch._commit`
     */
    listCollectionIds(request: google.firestore.v1.IListCollectionIdsRequest, _options?: CallOptions): Promise<[string[], unknown, unknown]>;
    /**
     * Invoked via
     * - `Watch.initStream()`
     */
    listen(_options?: CallOptions): Duplex;
    /**
     * Invoked via
     * - `CollectionGroup.getPartitions()`
     *
     * Stub implementation for `partitionQueryStream`, which is used to return
     * query cursors for parallelized query execution (e.g. partitioned exports).
     *
     * This mock does not currently support query partitioning logic.
     * Returns an empty stream for compatibility with tests that call
     * `Query.getPartitions()` but do not rely on its results.
     *
     * Implementing true partitioning logic can be deferred unless required
     * for testing large-scale query batching or export pipelines.
     */
    partitionQueryStream(_request?: google.firestore.v1.IPartitionQueryRequest, _options?: CallOptions): Duplex;
    close(): Promise<void>;
    private assertNotClosed;
}
//# sourceMappingURL=mock-gapic-client.d.ts.map