import * as core from '@prismamedia/graphql-platform';
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';
export interface MariaDBBrokerMutationRow {
    id: bigint;
    requestContext: string;
    changeCount: number;
    changesByNode: string;
    committedAt: string;
}
export interface MariaDBBrokerMutation<TRequestContext extends object = any> {
    id: bigint;
    requestContext: TRequestContext;
    changeCount: number;
    changesByNode: Record<core.Node['name'], Partial<{
        creation: true;
        update: core.Component['name'][];
        deletion: true;
    }>>;
    committedAt: Date;
}
export type UnassignedMutationsBySubscription<TRequestContext extends object = any> = Map<MariaDBSubscription, Array<MariaDBBrokerMutation<TRequestContext>>>;
export interface MariaDBBrokerMutationsTableOptions {
    name?: string;
    janitor?: string;
}
/**
 * For every mutation, we store the request-context and the committed-at timestamp.
 *
 * The janitor is used to clean up the mutations that have been committed and whose assignments have been deleted.
 */
export declare class MariaDBBrokerMutationsTable extends AbstractTable {
    readonly options?: MariaDBBrokerMutationsTableOptions | undefined;
    constructor(broker: MariaDBBroker, options?: MariaDBBrokerMutationsTableOptions | undefined);
    get janitor(): Event;
    setup(connection: PoolConnection<StatementKind.DATA_DEFINITION>): Promise<void>;
    publish(changes: core.MutationContextChanges, connection: PoolConnection): Promise<bigint>;
    parseRow<TRequestContext extends object>(row: MariaDBBrokerMutationRow): MariaDBBrokerMutation<TRequestContext>;
    filterDependencies(worker: MariaDBSubscription, alias?: string): string;
    filterAssignables(worker: MariaDBSubscription, alias?: string): string;
    getAssignables<TRequestContext extends object>(worker: MariaDBSubscription, batchSize?: number): AsyncGenerator<MariaDBBrokerMutation<TRequestContext>[]>;
    diagnose(worker: MariaDBSubscription): Promise<MariaDBSubscriptionAssignmentDiagnosis>;
}
//# sourceMappingURL=mutations.d.ts.map