beamtrace/stats

Types

BranchSample

pub type BranchSample {
  BranchSample(signature: String, duration_ns: Int)
}

Constructors

BranchSample(signature: String, duration_ns: Int)

BranchStats

</>

pub type BranchStats {
  BranchStats(
    signature: String,
    p50_ns: Int,
    p95_ns: Int,
    occurrences: Int,
    total_runs: Int,
    occurrence_rate: Float,
  )
}

Constructors

BranchStats(
  signature: String,
  p50_ns: Int,
  p95_ns: Int,
  occurrences: Int,
  total_runs: Int,
  occurrence_rate: Float,
)

Values

from_traces

</>

pub fn from_traces(
  runs: List(List(types.TraceEvent)),
) -> List(BranchStats)

Summarise complete trace runs without depending on physical PIDs or each node’s wall-clock origin. Every event latency is measured from the earliest observed event in the same causal root.

summarize

</>

pub fn summarize(
  runs: List(List(BranchSample)),
) -> List(BranchStats)