import { Effect } from 'effect';
import type { CadenceConfig } from '../../strategy/cadence-repair/index.js';
import { type CollectionName } from '../../domain/identity/index.js';
import type { CollectionConfig, Transaction } from '@tanstack/react-db';
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 { SyncReporter } from '../../domain/sync-event/index.js';
import type { CollectionItem, CollectionItemSchema, DeletePayload, UpdateChanges, UpdatePayload } from '../../domain/collection-item/index.js';
import type { Tracker } from '../registry/index.js';
import type { OutboxRuntime } from '../../outbox/outbox/index.js';
import type { PartitionEntry, PartitionMap } from '../../strategy/strategy/index.js';
import type { PaceStrategyFactory } from '../pacing/index.js';
import type { SyncStore } from '../../platform/sync-store/index.js';
import { type EffectRunner } from '../../platform/effect-runner/index.js';
import { type CollectionFlow } from '../../flow/sync-flow/index.js';
import { type PeerChannelFactory } from '../../platform/peer-sync/index.js';
import type { Leadership } from '../../platform/leadership/index.js';
export type KeyedCollectionUtils<S extends AnyEntityESchema> = {
    schema: () => S;
    flowId: () => string;
    applyToSyncReplica: (entities: DecodedEntity<S['Type']> | DecodedEntity<S['Type']>[]) => Effect.Effect<DecodedEntity<S['Type']>[], WriteError>;
    pacedUpdate: (key: string, changes: UpdateChanges<S['Type'], S>) => Transaction<Partial<S['Type']>>;
};
export declare const buildKeyedCollection: <S extends AnyEntityESchema, R = never>(tracker: Tracker, config: {
    schema: S;
    total?: PartitionEntry<S['Type'], R, any>;
    partitions?: PartitionMap<S, R>;
    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;
    store: SyncStore;
    leadership: Leadership;
    collectionName: CollectionName;
    assertActive: () => void;
    trackCleanup: (cleanup: () => Promise<void>) => () => Promise<void>;
    defaultCadence?: CadenceConfig;
    runner?: EffectRunner<R>;
    report: SyncReporter<R>;
    peerChannel?: PeerChannelFactory | null;
    flow: CollectionFlow;
}) => CollectionConfig<CollectionItem<S['Type']>, string, CollectionItemSchema<S>, KeyedCollectionUtils<S>> & {
    schema: CollectionItemSchema<S>;
    utils: KeyedCollectionUtils<S>;
};
//# sourceMappingURL=keyed-collection.d.ts.map