import { Effect, Scope } from 'effect';
import type { DecodedEntity } from '../../../core/index.js';
import type { CollectionName, PartitionKey, PartitionValue } from '../../domain/identity/index.js';
import type { WriteError } from '../../domain/sync-error/index.js';
import type { SyncReporter } from '../../domain/sync-event/index.js';
import { type Leadership } from '../../platform/leadership/index.js';
import { type CadenceConfig, type SyncCollection } from '../../strategy/cadence-repair/index.js';
import type { PartitionedStrategy, PartitionEntry, StrategyContext } from '../../strategy/strategy/index.js';
import { type CollectionFlow, type StrategyFlow } from '../../flow/sync-flow/index.js';
export type Partition = {
    field: string;
    value: PartitionValue;
};
export type StrategySessions<TItem extends object, R> = {
    start: (partitionKey: PartitionKey, entry: PartitionEntry<TItem, R, any>, flow: CollectionFlow, partition?: Partition) => Effect.Effect<void, never, R>;
    stop: (partitionKey: PartitionKey) => Effect.Effect<void>;
    stopAll: Effect.Effect<void>;
};
export declare const makeStrategySessions: <TItem extends object, R>(args: {
    collectionName: CollectionName;
    leadership: Leadership;
    defaultCadence?: CadenceConfig;
    collection: () => SyncCollection<TItem> | null;
    makeContext: <TState>(partitionKey: PartitionKey, scope: Scope.Scope, strategy: PartitionedStrategy<TItem, TState, R>, flow: StrategyFlow) => StrategyContext<TItem, TState>;
    applyToSyncReplica: (entities: DecodedEntity<TItem>[], flow?: StrategyFlow) => Effect.Effect<void, WriteError>;
    report: SyncReporter<R>;
}) => Effect.Effect<StrategySessions<TItem, R>>;
//# sourceMappingURL=strategy-session.d.ts.map