PtcRunner.Kernel.InspectionArtifact.Assembler (PtcRunner v0.15.0)

Copy Markdown View Source

Builds ETS indexes from one streaming evidence record at a time.

Collection order, filter postings, turn projections, and relationship rows are inserted after the last frame, once joins and conversation facts are closed.

Summary

Functions

finish(state, trace_facts)
ingest(state, record, offset, length, digest)
new(indexes, limits, identity \\ nil)

Functions

finish(state, trace_facts)

@spec finish(map(), map()) :: {:ok, map()} | {:error, atom()}

ingest(state, record, offset, length, digest)

@spec ingest(map(), map(), non_neg_integer(), non_neg_integer(), binary()) ::
  {:ok, map()} | {:error, atom()}

new(indexes, limits, identity \\ nil)

@spec new(
  PtcRunner.Kernel.InspectionArtifact.Indexes.t(),
  map(),
  nil | %{run_id: binary(), trace_id: binary()}
) :: map()