beamtrace/merge

Types

A display-only estimate. Causal edges must never be inferred from this offset; seq_trace serials and node-local process order remain authoritative.

pub type ClockEstimate {
  ClockEstimate(
    node: String,
    offset_ns: Int,
    uncertainty_ns: Int,
  )
}

ClockEstimate(node: String, offset_ns: Int, uncertainty_ns: Int)

</>

pub type MergeResult {
  MergeResult(
    events: List(PositionedEvent),
    completeness: types.Completeness,
  )
}

MergeResult(
  events: List(PositionedEvent),
  completeness: types.Completeness,
)

</>

pub type PositionedEvent {
  PositionedEvent(
    event: types.TraceEvent,
    estimated_global_ns: Int,
    uncertainty_ns: Int,
  )
}

PositionedEvent(
  event: types.TraceEvent,
  estimated_global_ns: Int,
  uncertainty_ns: Int,
)

</>

pub fn bounds(event: PositionedEvent) -> #(Int, Int)

</>

pub fn definitely_before(
  left: PositionedEvent,
  right: PositionedEvent,
) -> Bool

</>

pub fn merge(
  events: List(types.TraceEvent),
  clocks: List(ClockEstimate),
  expected_nodes: List(String),
) -> MergeResult