Struct MetricsBuilder 

pub struct MetricsBuilder {

    m_id: UInt32Builder,
    m_name: DictColumn,
    m_description: StringBuilder,
    m_unit: DictColumn,
    m_kind: UInt8Builder,
    m_temporality: UInt8Builder,
    m_monotonic: BooleanBuilder,
    m_resource_id: UInt16Builder,
    m_scope_id: UInt16Builder,
    metric_attrs: AttrsBuilder,
    next_metric_id: u32,
    num: DpHead,
    num_int: Int64Builder,
    num_double: Float64Builder,
    hist: DpHead,
    hist_stats: Stats,
    hist_counts: ListBuilder<UInt64Builder>,
    hist_bounds_id: UInt32Builder,
    bounds_index: HashMap<Vec<u64>, u32>,
    bounds_id: UInt32Builder,
    bounds_values: ListBuilder<Float64Builder>,
    next_bounds_id: u32,
    exp: DpHead,
    exp_stats: Stats,
    exp_scale: Int32Builder,
    exp_zero_count: UInt64Builder,
    exp_zero_threshold: Float64Builder,
    exp_pos_offset: Int32Builder,
    exp_pos_counts: ListBuilder<UInt64Builder>,
    exp_neg_offset: Int32Builder,
    exp_neg_counts: ListBuilder<UInt64Builder>,
    summ: DpHead,
    summ_count: UInt64Builder,
    summ_sum: Float64Builder,
    summ_quantile: ListBuilder<Float64Builder>,
    summ_value: ListBuilder<Float64Builder>,
    dp_attrs: AttrsBuilder,
    next_dp_id: u32,
    ex_id: UInt32Builder,
    ex_parent: UInt32Builder,
    ex_time: TimestampNanosecondBuilder,
    ex_int: Int64Builder,
    ex_double: Float64Builder,
    ex_trace_id: FixedSizeBinaryBuilder,
    ex_span_id: FixedSizeBinaryBuilder,
    exemplar_attrs: AttrsBuilder,
    next_exemplar_id: u32,
    rs: ResourceScope,
    list_values: usize,
    min_ts: i64,
    max_ts: i64,
}

Fields

m_id: UInt32Builder

m_name: DictColumn

m_description: StringBuilder

m_unit: DictColumn

m_kind: UInt8Builder

m_temporality: UInt8Builder

m_monotonic: BooleanBuilder

m_resource_id: UInt16Builder

m_scope_id: UInt16Builder

metric_attrs: AttrsBuilder

next_metric_id: u32

num: DpHead

num_int: Int64Builder

num_double: Float64Builder

hist: DpHead

hist_stats: Stats

hist_counts: ListBuilder<UInt64Builder>

hist_bounds_id: UInt32Builder

bounds_index: HashMap<Vec<u64>, u32>

explicit_bounds interned by their bit patterns. f64 has no Hash and -0.0 == 0.0 while their bits differ, so the key is the raw bits: two bound arrays share a row only if they are byte-identical, which is the conservative direction (a missed intern costs space, a wrong one would mislabel every bucket).

bounds_id: UInt32Builder

bounds_values: ListBuilder<Float64Builder>

next_bounds_id: u32

exp: DpHead

exp_stats: Stats

exp_scale: Int32Builder

exp_zero_count: UInt64Builder

exp_zero_threshold: Float64Builder

exp_pos_offset: Int32Builder

exp_pos_counts: ListBuilder<UInt64Builder>

exp_neg_offset: Int32Builder

exp_neg_counts: ListBuilder<UInt64Builder>

summ: DpHead

summ_count: UInt64Builder

summ_sum: Float64Builder

summ_quantile: ListBuilder<Float64Builder>

summ_value: ListBuilder<Float64Builder>

dp_attrs: AttrsBuilder

next_dp_id: u32

One counter across all four point tables — see the module header.

ex_id: UInt32Builder

ex_parent: UInt32Builder

ex_time: TimestampNanosecondBuilder

ex_int: Int64Builder

ex_double: Float64Builder

ex_trace_id: FixedSizeBinaryBuilder

ex_span_id: FixedSizeBinaryBuilder

exemplar_attrs: AttrsBuilder

next_exemplar_id: u32

rs: ResourceScope

list_values: usize

List elements written so far, for approx_bytes. Tracked rather than measured because ListBuilder::values needs &mut self.

min_ts: i64

max_ts: i64

Implementations

impl MetricsBuilder

pub fn new() -> Self

pub fn num_rows(&self) -> usize

Data points, across all four tables. This is the row count the flusher reports and the number that matters — descriptors are a rounding error.

pub fn is_empty(&self) -> bool

pub fn approx_bytes(&self) -> usize

pub fn has_headroom_for(&self, req: &ExportMetricsServiceRequest) -> bool

pub fn append_request( &mut self, req: &ExportMetricsServiceRequest, ) -> Result<usize>

fn append_metric(&mut self, m: &Metric, rid: u16, sid: u16) -> Result<usize>

fn next_point(&mut self, time: u64) -> u32

Claim the next point id and fold its timestamp into the block’s range.

Only time_unix_nano widens the range. See crate::schema::NUMBER_DP for why start_time_unix_nano must not.

fn append_number(&mut self, p: &NumberDataPoint, mid: u32) -> Result<()>

fn append_hist(&mut self, p: &HistogramDataPoint, mid: u32) -> Result<()>

fn append_exp_hist( &mut self, p: &ExponentialHistogramDataPoint, mid: u32, ) -> Result<()>

fn append_summary(&mut self, p: &SummaryDataPoint, mid: u32) -> Result<()>

fn append_exemplars(&mut self, dp_id: u32, exemplars: &[Exemplar]) -> Result<()>

pub fn finish(&mut self) -> Result<Sealed>

Seal and reset, including on the error path — see SignalBuilder::finish.

fn seal(&self, sidecars: Sidecars) -> Result<Sealed>

Trait Implementations

impl Default for MetricsBuilder

fn default() -> Self

Returns the “default value” for a type.

impl SignalBuilder for MetricsBuilder

const SIGNAL: &'static str = "metrics"

Directory component under the data dir. Also the block name prefix, so changing it is an on-disk format change.

type Request = ExportMetricsServiceRequest

The decoded OTLP export request this signal accepts.

fn has_headroom_for(&self, req: &Self::Request) -> bool

Whether req is guaranteed to fit without overflowing a UInt16 dictionary or id space.

fn append_request(&mut self, req: &Self::Request) -> Result<usize>

Absorb one export request, returning the number of root-table rows added.

fn approx_bytes(&self) -> usize

Rough resident cost, with variable-width heaps measured rather than estimated from row counts — a 32 KB GenAI prompt must not weigh the same as a 20-byte one.

fn is_empty(&self) -> bool

fn finish(&mut self) -> Result<Sealed>

Seal and reset. After this returns, self is a fresh builder — including on the error path, where the caller has no way to know how far through the column-by-column finish it got.

fn snapshot(&self) -> Result<Sealed>

Materialise the rows accumulated so far without resetting, for Open. Sidecar-free; see Sealed::with.