import { Effect } from 'effect';
import type { DecodedEntity } from '../../../core/index.js';
import type { WriteError } from '../../domain/sync-error/index.js';
import type { EffectRunner } from '../../platform/effect-runner/index.js';
import type { SyncReporter } from '../../domain/sync-event/index.js';
import type { CollectionFlow } from '../../flow/sync-flow/index.js';
import type { CollectionName } from '../../domain/identity/index.js';
export type CollectionHandle = {
    schemaName: string;
    collectionName: CollectionName;
    applyToSyncReplica: (entities: DecodedEntity<unknown>[]) => Effect.Effect<void, WriteError>;
    projectOnly: (entities: DecodedEntity<unknown>[]) => Effect.Effect<void, WriteError>;
    flow: () => CollectionFlow | null;
    stop: Effect.Effect<void>;
    restart: Effect.Effect<void, WriteError>;
};
export type Tracker = {
    register: (handle: CollectionHandle) => void;
    lookup: (schemaName: string) => CollectionHandle | null;
    all: () => CollectionHandle[];
};
export declare const makeTracker: () => Tracker;
export declare const buildRegistry: <R>(tracker: Tracker, runner: EffectRunner<R>, report: SyncReporter<R>) => {
    process: (message: unknown) => void;
};
//# sourceMappingURL=registry.d.ts.map