import { AsyncEventEmitter, type EventListener } from '@prismamedia/async-event-emitter';
import * as core from '@prismamedia/graphql-platform';
import * as utils from '@prismamedia/graphql-platform-utils';
import type { JsonObject } from 'type-fest';
import { MariaDBSubscription, type MariaDBSubscriptionDiagnosis, type MariaDBSubscriptionEvents } from './broker/subscription.js';
import { MariaDBBrokerAssignmentsTable, MariaDBBrokerChangesTable, MariaDBBrokerMutationsTable, MariaDBBrokerSubscriptionsStateTable, type MariaDBBrokerAssignmentsTableOptions, type MariaDBBrokerChangesTableOptions, type MariaDBBrokerMutationsTableOptions } from './broker/table.js';
import type { MariaDBConnector, PoolConnection } from './index.js';
import { StatementKind } from './statement.js';
export * from './broker/error.js';
export { MariaDBSubscription, MariaDBSubscriptionDiagnosis, type MariaDBSubscriptionEvents, } from './broker/subscription.js';
export * from './broker/table.js';
export type MariaDBBrokerEvents = {
    subscription: MariaDBSubscription;
    unsubscription: MariaDBSubscription;
    idle: undefined;
};
export interface MariaDBBrokerOptions<TRequestContext extends object = any> {
    enabled?: utils.OptionalFlag;
    mutationsTable?: MariaDBBrokerMutationsTableOptions;
    changesTable?: MariaDBBrokerChangesTableOptions;
    assignmentsTable?: MariaDBBrokerAssignmentsTableOptions;
    /**
     * The number of seconds to wait before polling for new assignments.
     *
     * @default 5
     */
    assignerInterval?: number;
    /**
     * The number of seconds to wait between heartbeats.
     *
     * @default 60 * 5 (5 minutes)
     */
    heartbeatInterval?: number;
    /**
     * The number of missed heartbeats allowed before assignments and subscriptions' state are considered stale.
     *
     * @default 2
     */
    allowedHeartbeatMisses?: number;
    /**
     * The number of seconds to keep the unassigned mutations in the database.
     *
     * @default 60 * 15 (15 minutes)
     */
    retention?: number;
    /**
     * Optional, a function to serialize the request-context as a JSON object
     */
    serializeRequestContext?: (requestContext: TRequestContext) => JsonObject;
    /**
     * Optional, a function to unserialize the request-context from a JSON object
     */
    unserializeRequestContext?: (requestContext: JsonObject) => TRequestContext;
}
export declare class MariaDBBroker<TRequestContext extends object = any> extends AsyncEventEmitter<MariaDBBrokerEvents> implements core.BrokerInterface {
    #private;
    readonly connector: MariaDBConnector<TRequestContext>;
    readonly options?: MariaDBBrokerOptions<TRequestContext> | undefined;
    readonly assignerIntervalInSeconds: number;
    readonly heartbeatIntervalInSeconds: number;
    readonly heartbeatMaxAgeInSeconds: number;
    readonly retentionInSeconds: number;
    readonly mutationsTable: MariaDBBrokerMutationsTable;
    readonly changesTable: MariaDBBrokerChangesTable;
    readonly assignmentsTable: MariaDBBrokerAssignmentsTable;
    readonly subscriptions: Map<core.ChangesSubscriptionStream<any, any, any>, MariaDBSubscription>;
    constructor(connector: MariaDBConnector<TRequestContext>, options?: MariaDBBrokerOptions<TRequestContext> | undefined);
    get subscriptionsStateTables(): ReadonlyArray<MariaDBBrokerSubscriptionsStateTable>;
    setup(connection?: PoolConnection<StatementKind.DATA_DEFINITION>): Promise<void>;
    publish(changes: core.MutationContextChanges): Promise<void>;
    heartbeat(): Promise<void>;
    subscribe(subscription: core.ChangesSubscriptionStream): Promise<MariaDBSubscription>;
    onIdle(subscription: core.ChangesSubscriptionStream, listener: EventListener<MariaDBSubscriptionEvents, 'idle'>): void;
    waitForIdle(subscription: core.ChangesSubscriptionStream): Promise<void>;
    unsubscribe(subscription: core.ChangesSubscriptionStream): Promise<void>;
    assign(): Promise<void>;
    diagnose(): Promise<MariaDBSubscriptionDiagnosis[]>;
}
//# sourceMappingURL=broker.d.ts.map