import type { Constructor } from '@cratis/fundamentals';
import { IClientArtifactsProvider } from '../artifacts/index.js';
import { ChronicleConnection } from '../connection/index.js';
import type { ConnectionLifecycle } from '../connection/ConnectionLifecycle.js';
import type { IMaterializedReadModels } from './IMaterializedReadModels.js';
import type { ReadModelNamingPolicy } from './ReadModelNamingPolicy.js';
import type { IReadModels } from './IReadModels.js';
import type { IReadModelWatcher } from './IReadModelWatcher.js';
import type { ReadModelChangeset } from './ReadModelChangeset.js';
import type { ReadModelWatchOptions } from './ReadModelWatchOptions.js';
import type { ReadModelSnapshot } from './ReadModelSnapshot.js';
/**
 * Implements {@link IReadModels} by working with the Chronicle read-model gRPC service.
 */
export declare class ReadModels implements IReadModels {
    private readonly _eventStore;
    private readonly _namespace;
    private readonly _connection;
    private readonly _clientArtifacts;
    private readonly _defaultSinkTypeId;
    private readonly _isModelBoundProjectionRegistered?;
    private readonly _readModelNamingPolicy?;
    private readonly _lifecycle?;
    readonly materialized: IMaterializedReadModels;
    private readonly _watchCancellation;
    constructor(_eventStore: string, _namespace: string, _connection: ChronicleConnection, _clientArtifacts: IClientArtifactsProvider, _defaultSinkTypeId: string, _isModelBoundProjectionRegistered?: ((readModelType: Constructor) => boolean) | undefined, _readModelNamingPolicy?: ReadModelNamingPolicy | undefined, _lifecycle?: ConnectionLifecycle | undefined);
    /** @inheritdoc */
    register<TReadModel>(readModelType?: Constructor<TReadModel>): Promise<void>;
    /** @inheritdoc */
    getInstanceById<TReadModel>(readModelType: Constructor<TReadModel>, key: string, sessionId?: string): Promise<TReadModel>;
    /** @inheritdoc */
    findInstanceById<TReadModel>(readModelType: Constructor<TReadModel>, key: string, sessionId?: string): Promise<TReadModel | null>;
    /** @inheritdoc */
    getInstances<TReadModel>(readModelType: Constructor<TReadModel>, eventCount?: bigint): Promise<TReadModel[]>;
    /** @inheritdoc */
    getSnapshotsById<TReadModel>(readModelType: Constructor<TReadModel>, key: string): Promise<ReadModelSnapshot<TReadModel>[]>;
    /** @inheritdoc */
    watch<TReadModel>(readModelType: Constructor<TReadModel>): AsyncIterable<ReadModelChangeset<TReadModel>>;
    /** @inheritdoc */
    createWatcher<TReadModel>(readModelType: Constructor<TReadModel>, options?: ReadModelWatchOptions): IReadModelWatcher<TReadModel>;
    /** Stops all watchers created through createWatcher for this event store. */
    dispose(): void;
    /** @inheritdoc */
    dehydrateSession<TReadModel>(sessionId: string, readModelType: Constructor<TReadModel>, key: string): Promise<void>;
    /** @inheritdoc */
    release<TReadModel>(readModelType: Constructor<TReadModel>, instance: TReadModel): Promise<TReadModel>;
    /** @inheritdoc */
    releaseMany<TReadModel>(readModelType: Constructor<TReadModel>, instances: TReadModel[]): Promise<TReadModel[]>;
    /** @inheritdoc */
    releaseDocument<TReadModel>(readModelType: Constructor<TReadModel>, document: Readonly<Record<string, unknown>>): Promise<Record<string, unknown>>;
    private releaseDocumentProperties;
    private copyStoredDocument;
    private isDocumentObject;
    private isDocumentSubject;
    private toChangeset;
    private releaseSnapshotInstances;
    private resolveReadModels;
    private addResolved;
    private resolveReadModel;
    private toDefinition;
    private getReadModelSchema;
    private deserializeReadModel;
    private schemaHasComplianceMetadata;
    private extractSubject;
}
//# sourceMappingURL=ReadModels.d.ts.map