Type Alias SearchStreamEvent

Type Declaration

• {
      durationMs: number;
      phase: "provider";
      providerName: string;
      results: SearchResultItem[];
  }

  • durationMs: number

    Provider wall-clock duration in ms.

  • phase: "provider"

  • providerName: string

    Friendly provider name that just returned (Vector / FullText / Entity / Storage / external).

  • results: SearchResultItem[]

    This provider's contribution before fusion.

• { phase: "fused"; results: SearchResultItem[] }

  • phase: "fused"

  • results: SearchResultItem[]

    RRF-fused list across providers (and across scopes when applicable).

• { phase: "reranked"; rerankerName: string; results: SearchResultItem[] }

  • phase: "reranked"

  • rerankerName: string

    Reranker class name (Cohere / Voyage / BGE / Noop / etc.)

  • results: SearchResultItem[]

    Reranker-permuted list. Same items as 'fused', new order.

• {
      elapsedMs: number;
      phase: "final";
      results: SearchResultItem[];
      sourceCounts: {
          Entity: number;
          FullText: number;
          Storage: number;
          Vector: number;
      };
  }

  • elapsedMs: number

    Total wall-clock duration of the stream.

  • phase: "final"

  • results: SearchResultItem[]

    Post-deduplication, post-permission, post-enrich result set — what Search() would have returned.

  • sourceCounts: { Entity: number; FullText: number; Storage: number; Vector: number }

    Same shape as the synchronous SearchResult.SourceCounts.

• { error: string; phase: "error"; providerName?: string }

  • error: string

    Human-readable error message (do NOT include stack traces).

  • phase: "error"

  • OptionalproviderName?: string

    Provider that failed, if scoped to one.