Interface PostgresReportingConsumerRuntimeV1

interface PostgresReportingConsumerRuntimeV1 {
    checkpointStore: ReportingCheckpointStore;
    pendingConsumerStatusStore: ReportingPendingConsumerStatusStore;
    changesCheckpointStore: ReportingChangesCheckpointStoreV1;
    workLeases: ReportingConsumerWorkLeaseStoreV1;
    notifications: ReportingConsumerNotificationStoreV1;
    migrations: { persistence: string; all: readonly [string] };
    probe(): Promise<void>;
}

Index

Properties

checkpointStore pendingConsumerStatusStore changesCheckpointStore workLeases notifications migrations

Methods

Properties

`Readonly`checkpointStore

checkpointStore: ReportingCheckpointStore

`Readonly`pendingConsumerStatusStore

pendingConsumerStatusStore: ReportingPendingConsumerStatusStore

`Readonly`changesCheckpointStore

changesCheckpointStore: ReportingChangesCheckpointStoreV1

`Readonly`workLeases

workLeases: ReportingConsumerWorkLeaseStoreV1

`Readonly`notifications

notifications: ReportingConsumerNotificationStoreV1

`Readonly`migrations

migrations: { persistence: string; all: readonly [string] }

Methods

probe

probe(): Promise<void>
Returns Promise<void>
- Defined in src/lib/reporting/consumer-postgres.ts:97