Interface RetrieveFanoutInternals

Test/override seams; production callers pass nothing.

interface RetrieveFanoutInternals {
    execute?: (
        resolved: ResolvedRetrieveRequest,
    ) => Promise<RetrieveSuccessEnvelope>;
    expand?: (
        selection: TargetSelection,
        input: CdbSelectionResolveInput,
        env: Record<string, string | undefined>,
        config?: Record<string, string | undefined>,
    ) => Promise<CdbSelectionExpansion>;
    sleep?: (ms: number) => Promise<void>;
}

Properties

Per-target executor (attempts; throws on failure). Defaults to the live tail.

expand?: (
    selection: TargetSelection,
    input: CdbSelectionResolveInput,
    env: Record<string, string | undefined>,
    config?: Record<string, string | undefined>,
) => Promise<CdbSelectionExpansion>

Selection expansion. Defaults to the real CDB-backed expansion.

sleep?: (ms: number) => Promise<void>

Backoff sleeper. Defaults to a real timer; tests pass a no-op.