import type { UUID } from 'node:crypto';
import type { MariaDBBroker } from '../../broker.js';
import type { PoolConnection } from '../../index.js';
import { Event } from '../../schema/event.js';
import type { StatementKind } from '../../statement.js';
import { AbstractTable } from '../abstract-table.js';
import type { MariaDBSubscription, MariaDBSubscriptionAssignmentDiagnosis } from '../subscription.js';
import type { MariaDBBrokerMutation } from './mutations.js';
export interface MariaDBBrokerAssignmentsTableOptions {
    name?: string;
    janitor?: string;
}
export declare class MariaDBBrokerAssignmentsTable extends AbstractTable {
    readonly options?: MariaDBBrokerAssignmentsTableOptions | undefined;
    constructor(broker: MariaDBBroker, options?: MariaDBBrokerAssignmentsTableOptions | undefined);
    get janitor(): Event;
    setup(connection: PoolConnection<StatementKind.DATA_DEFINITION>): Promise<void>;
    assign(subscriptionId: UUID, mutations: ReadonlyArray<MariaDBBrokerMutation>): Promise<void>;
    unassign(subscriptionId: UUID, mutationId?: bigint): Promise<void>;
    dequeue<TRequestContext extends object>(subscriptionId: UUID): AsyncGenerator<MariaDBBrokerMutation<TRequestContext>>;
    unsubscribe(subscriptionId: UUID): Promise<void>;
    heartbeat(subscriptionIds: Iterable<UUID>): Promise<void>;
    diagnose(worker: MariaDBSubscription): Promise<MariaDBSubscriptionAssignmentDiagnosis>;
}
//# sourceMappingURL=assignments.d.ts.map