import type { DeleteMutationFnParams, InsertMutationFnParams, Transaction, UpdateMutationFnParams } from '@tanstack/react-db';
import { Effect } from 'effect';
import { type DecodedEntity } from '../../../core/index.js';
import type { AnyEntityESchema } from '../../../eschema/index.js';
import type { WriteError } from '../../domain/sync-error/index.js';
import { type CollectionName } from '../../domain/identity/index.js';
import { type OutboxRuntime } from '../../outbox/outbox/index.js';
import type { CollectionItem, DeletePayload, UpdatePayload } from '../../domain/collection-item/index.js';
import { type PaceStrategyFactory } from '../pacing/index.js';
import type { EffectRunner } from '../../platform/effect-runner/index.js';
import type { CollectionFlow } from '../../flow/sync-flow/index.js';
export declare const buildKeyedMutations: <S extends AnyEntityESchema, R = never>(args: {
    schema: S;
    collectionName: CollectionName;
    applyToSyncReplica: (entities: DecodedEntity<S['Type']>[]) => Effect.Effect<void, WriteError>;
    onInsert?: (items: ReadonlyArray<S['Type']>) => Effect.Effect<ReadonlyArray<DecodedEntity<S['Type']>>, unknown, R>;
    onUpdate?: (payload: UpdatePayload<S['Type'], S>) => Effect.Effect<DecodedEntity<S['Type']>, unknown, R>;
    onDelete?: (payload: DeletePayload<S['Type']>) => Effect.Effect<DecodedEntity<S['Type']>, unknown, R>;
    pacing?: PaceStrategyFactory;
    outbox: OutboxRuntime | null;
    replayed: Effect.Effect<void>;
    runner: EffectRunner<R>;
    flow: () => CollectionFlow | null;
}) => {
    onInsert: (({ transaction, }: InsertMutationFnParams<CollectionItem<S["Type"]>, string>) => Promise<void>) | undefined;
    onUpdate: (({ transaction, }: UpdateMutationFnParams<CollectionItem<S["Type"]>, string>) => Promise<void>) | undefined;
    onDelete: (({ transaction, }: DeleteMutationFnParams<CollectionItem<S["Type"]>, string>) => Promise<void>) | undefined;
    pacedUpdate: (key: string, current: CollectionItem<S["Type"]>, changes: Partial<S["Type"]>, optimistic: (key: string, changes: Partial<S["Type"]>) => void) => Transaction<Partial<S["Type"]>>;
    decode: (value: unknown) => Effect.Effect<S["Type"], unknown>;
    pick: (after: S["Type"], changed: ReadonlyArray<string>) => Partial<S["Type"]>;
};
//# sourceMappingURL=keyed.d.ts.map