declare const EventSourcingError_base: new = {}>(args: import("effect/Types").Equals extends true ? void : { readonly [P in keyof A as P extends "_tag" ? never : P]: A[P]; }) => import("effect/Cause").YieldableError & {
readonly _tag: "EventSourcingError";
} & Readonly;
export declare class EventSourcingError extends EventSourcingError_base> {
get errorMessage(): string;
}
declare const EventStoreError_base: new = {}>(args: import("effect/Types").Equals extends true ? void : { readonly [P in keyof A as P extends "_tag" ? never : P]: A[P]; }) => import("effect/Cause").YieldableError & {
readonly _tag: "EventStoreError";
} & Readonly;
export declare class EventStoreError extends EventStoreError_base> {
}
declare const EventStoreConnectionError_base: new = {}>(args: import("effect/Types").Equals extends true ? void : { readonly [P in keyof A as P extends "_tag" ? never : P]: A[P]; }) => import("effect/Cause").YieldableError & {
readonly _tag: "EventStoreConnectionError";
} & Readonly;
export declare class EventStoreConnectionError extends EventStoreConnectionError_base> {
}
declare const EventStoreResourceError_base: new = {}>(args: import("effect/Types").Equals extends true ? void : { readonly [P in keyof A as P extends "_tag" ? never : P]: A[P]; }) => import("effect/Cause").YieldableError & {
readonly _tag: "EventStoreResourceError";
} & Readonly;
export declare class EventStoreResourceError extends EventStoreResourceError_base> {
}
declare const ConcurrencyConflictError_base: new = {}>(args: import("effect/Types").Equals extends true ? void : { readonly [P in keyof A as P extends "_tag" ? never : P]: A[P]; }) => import("effect/Cause").YieldableError & {
readonly _tag: "ConcurrencyConflictError";
} & Readonly;
export declare class ConcurrencyConflictError extends ConcurrencyConflictError_base> {
}
declare const ProjectionError_base: new = {}>(args: import("effect/Types").Equals extends true ? void : { readonly [P in keyof A as P extends "_tag" ? never : P]: A[P]; }) => import("effect/Cause").YieldableError & {
readonly _tag: "ProjectionError";
} & Readonly;
export declare class ProjectionError extends ProjectionError_base> {
}
declare const ProjectionStateError_base: new = {}>(args: import("effect/Types").Equals extends true ? void : { readonly [P in keyof A as P extends "_tag" ? never : P]: A[P]; }) => import("effect/Cause").YieldableError & {
readonly _tag: "ProjectionStateError";
} & Readonly;
export declare class ProjectionStateError extends ProjectionStateError_base> {
}
declare const SnapshotError_base: new = {}>(args: import("effect/Types").Equals extends true ? void : { readonly [P in keyof A as P extends "_tag" ? never : P]: A[P]; }) => import("effect/Cause").YieldableError & {
readonly _tag: "SnapshotError";
} & Readonly;
export declare class SnapshotError extends SnapshotError_base> {
}
declare const SnapshotVersionError_base: new = {}>(args: import("effect/Types").Equals extends true ? void : { readonly [P in keyof A as P extends "_tag" ? never : P]: A[P]; }) => import("effect/Cause").YieldableError & {
readonly _tag: "SnapshotVersionError";
} & Readonly;
export declare class SnapshotVersionError extends SnapshotVersionError_base> {
}
declare const WebSocketError_base: new = {}>(args: import("effect/Types").Equals extends true ? void : { readonly [P in keyof A as P extends "_tag" ? never : P]: A[P]; }) => import("effect/Cause").YieldableError & {
readonly _tag: "WebSocketError";
} & Readonly;
export declare class WebSocketError extends WebSocketError_base> {
}
declare const WebSocketProtocolError_base: new = {}>(args: import("effect/Types").Equals extends true ? void : { readonly [P in keyof A as P extends "_tag" ? never : P]: A[P]; }) => import("effect/Cause").YieldableError & {
readonly _tag: "WebSocketProtocolError";
} & Readonly;
export declare class WebSocketProtocolError extends WebSocketProtocolError_base> {
}
export declare const isEventSourcingError: (u: unknown) => u is EventSourcingError | EventStoreError | EventStoreConnectionError | EventStoreResourceError | ConcurrencyConflictError | ProjectionError | ProjectionStateError | SnapshotError | SnapshotVersionError | WebSocketError | WebSocketProtocolError;
export declare const eventStoreError: {
read: (streamId: string | undefined, details: string) => (cause?: unknown) => EventStoreError;
write: (streamId: string | undefined, details: string) => (cause?: unknown) => EventStoreError;
subscribe: (streamId: string | undefined, details: string) => (cause?: unknown) => EventStoreError;
};
export declare const connectionError: {
retryable: (operation: string) => (cause: unknown, connectionString?: string) => EventStoreConnectionError;
fatal: (operation: string) => (cause: unknown, connectionString?: string) => EventStoreConnectionError;
};
export declare const projectionError: {
build: (projectionName: string, details: string, eventPosition?: number, cause?: unknown) => ProjectionError;
rebuild: (projectionName: string, details: string, eventPosition?: number, cause?: unknown) => ProjectionError;
update: (projectionName: string, details: string, eventPosition?: number, cause?: unknown) => ProjectionError;
query: (projectionName: string, details: string, cause?: unknown) => ProjectionError;
};
export declare const snapshotError: {
save: (aggregateId: string, details: string, version?: number, cause?: unknown) => SnapshotError;
load: (aggregateId: string, details: string, version?: number, cause?: unknown) => SnapshotError;
delete: (aggregateId: string, details: string, version?: number, cause?: unknown) => SnapshotError;
};
export declare const webSocketError: {
connect: (url: string | undefined, details: string, code?: number, cause?: unknown) => WebSocketError;
disconnect: (url: string | undefined, details: string, code?: number, cause?: unknown) => WebSocketError;
send: (details: string, cause?: unknown) => WebSocketError;
receive: (details: string, cause?: unknown) => WebSocketError;
};
export {};
//# sourceMappingURL=errors.d.ts.map