import { Result } from "../common/result";
import { DomainEvent } from "../domain/domain-event";
export interface EventStore {
    appendEvents(aggregateId: string, expectedVersion: number, events: DomainEvent[]): Promise<Result<void>>;
    getEvents(aggregateId: string): Promise<Result<DomainEvent[]>>;
    getEventsFromVersion(aggregateId: string, fromVersion: number): Promise<Result<DomainEvent[]>>;
    getEventsByType(eventType: string): Promise<Result<DomainEvent[]>>;
    getEventsByCorrelationId(correlationId: string): Promise<Result<DomainEvent[]>>;
    getEventsInTimeRange(fromDate: Date, toDate: Date): Promise<Result<DomainEvent[]>>;
}
export interface EventStoreEntry {
    readonly id: string;
    readonly aggregateId: string;
    readonly aggregateVersion: number;
    readonly event: DomainEvent;
    readonly storedAt: Date;
    readonly streamName?: string;
}