import { type ActivationRef, type EntryOptions, type MessageToken, type Participant } from '@pkishorez/flow';
import { Effect } from 'effect';
import { type PartitionValue } from '../../domain/identity/index.js';
export type ActivationOutcome = Parameters<ActivationRef['end']>[0];
export type FlowEntryOptions = EntryOptions;
/** What a Strategy or a narrator may record: Events and named spans. */
export type StrategyFlow = {
    event: (name: string, options?: FlowEntryOptions) => Effect.Effect<void>;
    withSpan: (name: string, options?: {
        readonly attributes?: Readonly<Record<string, unknown>>;
    }) => <A, E, R>(effect: Effect.Effect<A, E, R>) => Effect.Effect<A, E, R>;
};
/** One Sync lane: a Flow Participant plus a span helper that names the lane. */
export type FlowParticipant = StrategyFlow & {
    readonly name: string;
    send: (participantName: string, name: string, options?: FlowEntryOptions) => Effect.Effect<MessageToken>;
    reply: (token: MessageToken, name: string, options?: FlowEntryOptions) => Effect.Effect<void>;
    activation: {
        start: (name: string, options?: FlowEntryOptions) => Effect.Effect<ActivationRef>;
    };
    activated: (name: string) => <A, E, R>(effect: Effect.Effect<A, E, R>) => Effect.Effect<A, E, R>;
};
export type OutboxFlow = {
    readonly collection: FlowParticipant;
    readonly outbox: FlowParticipant;
    readonly drainer: FlowParticipant;
};
export type CollectionFlow = {
    readonly id: string;
    readonly collection: FlowParticipant;
    readonly outbox: OutboxFlow;
    participant: (name: string) => FlowParticipant;
};
export type FlowPlacement = {
    readonly id: string;
    readonly participantPrefix: string;
};
export type FlowLane = Participant;
export type SyncFlow = {
    readonly id: string;
    readonly sync: FlowParticipant;
    readonly outbox: FlowParticipant;
    readonly drainer: FlowParticipant;
    collection: (localName: string) => CollectionFlow;
    action: (name: string) => CollectionFlow;
    participant: (name: string) => FlowLane;
};
export declare const makeSyncFlow: (placement: FlowPlacement) => SyncFlow;
export declare const narrateHydration: (narrator: StrategyFlow | undefined, collection: string) => {
    load: <A extends {
        readonly rows: number;
    }, E, R>(from: string | null, effect: Effect.Effect<A, E, R>) => Effect.Effect<A, E, R>;
    project: <A, E, R>(rows: number, effect: Effect.Effect<A, E, R>) => Effect.Effect<A, E, R>;
};
export declare const narrateReplicaWrite: (narrator: StrategyFlow | undefined, collection: string) => {
    write: <A extends readonly unknown[], E, R>(received: number, effect: Effect.Effect<A, E, R>) => Effect.Effect<A, E, R>;
    broadcast: <A, E, R>(rows: number, effect: Effect.Effect<A, E, R>) => Effect.Effect<A, E, R>;
};
export declare const globalParticipantName: (strategyName: string) => import("../../domain/identity/sync-address.js").SyncAddress;
export declare const partitionParticipantName: (partition: {
    field: string;
    value: PartitionValue;
}, strategyName: string) => import("../../domain/identity/sync-address.js").SyncAddress;
export declare const cadenceParticipantName: (strategyParticipantName: string) => string;
//# sourceMappingURL=sync-flow.d.ts.map