import type { ChronicleTelemetryOptions } from './telemetry/ChronicleTelemetryOptions.js'; import { ChronicleConnection } from './connection/index.js'; import type { IEventSources } from './eventSources/IEventSources.js'; import { ConnectionLifecycle } from './connection/ConnectionLifecycle.js'; import { EventSequenceId } from './eventSequences/EventSequenceId.js'; import { IEventLog } from './eventSequences/IEventLog.js'; import { IEventSequence } from './eventSequences/IEventSequence.js'; import { EventStoreName } from './EventStoreName.js'; import { EventStoreNamespaceName } from './EventStoreNamespaceName.js'; import { IEventStore } from './IEventStore.js'; import { IEventTypes } from './events/IEventTypes.js'; import { IConstraints } from './events/constraints/IConstraints.js'; import { IProjections } from './projections/IProjections.js'; import type { ReactorResultHandler } from './reactors/ReactorResultHandler.js'; import type { ClientArtifactsActivator } from './artifacts/ClientArtifactsActivator.js'; import type { ReadModelNamingPolicy } from './readModels/ReadModelNamingPolicy.js'; import { IReactors } from './reactors/IReactors.js'; import { IReducers } from './reducers/IReducers.js'; import { IReadModels } from './readModels/IReadModels.js'; import { IEventSeeding } from './seeding/IEventSeeding.js'; import type { IClientArtifactsProvider } from './artifacts/IClientArtifactsProvider.js'; import { IUnitOfWorkManager } from './transactions/IUnitOfWorkManager.js'; import { IJobs } from './jobs/IJobs.js'; import { type IPatterns } from './patterns/index.js'; import { IWebhooks } from './webhooks/IWebhooks.js'; import { IEventStoreSubscriptions } from './eventStoreSubscriptions/IEventStoreSubscriptions.js'; import { IExternalServices } from './externalServices/IExternalServices.js'; import { IIdentityManager } from './identities/IIdentityManager.js'; import { IPIIManager } from './compliance/IPIIManager.js'; import { IFailedPartitions } from './observation/IFailedPartitions.js'; import { IObservers } from './observation/IObservers.js'; /** * Implements {@link IEventStore} by communicating with the Chronicle Kernel * via gRPC using the provided {@link ChronicleConnection}. */ export declare class EventStore implements IEventStore { readonly name: EventStoreName; readonly namespace: EventStoreNamespaceName; private readonly _connection; private readonly _artifacts; private readonly _telemetry?; private readonly _logger; readonly eventLog: IEventLog; readonly eventTypes: IEventTypes; readonly eventSources: IEventSources; readonly constraints: IConstraints; readonly projections: IProjections; readonly reactors: IReactors; readonly reducers: IReducers; readonly readModels: IReadModels; readonly unitOfWorkManager: IUnitOfWorkManager; readonly jobs: IJobs; readonly patterns: IPatterns; readonly webhooks: IWebhooks; readonly subscriptions: IEventStoreSubscriptions; readonly seeding: IEventSeeding; readonly externalServices: IExternalServices; readonly identities: IIdentityManager; readonly pii: IPIIManager; readonly failedPartitions: IFailedPartitions; readonly observers: IObservers; private readonly _sequences; private readonly _constraints; constructor(name: EventStoreName, namespace: EventStoreNamespaceName, _connection: ChronicleConnection, lifecycle: ConnectionLifecycle, defaultSinkTypeId: string, _artifacts?: IClientArtifactsProvider, reactorResultHandler?: ReactorResultHandler, artifactActivator?: ClientArtifactsActivator, readModelNamingPolicy?: ReadModelNamingPolicy, _telemetry?: ChronicleTelemetryOptions | undefined); /** * Registers all discovered artifacts with the Chronicle Kernel. * Called on initial connect and on reconnect. * @returns A promise that resolves when all registrations are complete. */ registerArtifacts(): Promise; /** Stops the store's long-lived observations when the client is disposed. */ disposeObservations(): void; /** @inheritdoc */ getEventSequence(id: EventSequenceId): IEventSequence; /** @inheritdoc */ getNamespaces(): Promise; } //# sourceMappingURL=EventStore.d.ts.map