obs-core 0.2.1

Runtime engine for the obs SDK: Observer, Sink, schema registry, sampling, config.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

//! `bench_encode_payload` — measures the buffa-encode hot path on a
//! representative typed event. Spec 71 § 4.

use buffa::Message as _;
use bytes::BytesMut;
use criterion::{Criterion, criterion_group, criterion_main};
use obs_proto::obs::v1::ObsHttpRequestCompleted;

fn bench_encode_payload(c: &mut Criterion) {
    let evt = ObsHttpRequestCompleted {
        method: "GET".to_string(),
        route: "/api/v1/users".to_string(),
        status_class: "2xx".to_string(),
        latency_ms: 42,
        bytes_out: 1024,
        __buffa_unknown_fields: Default::default(),
    };
    c.bench_function("encode_payload_obshttprequestcompleted", |b| {
        let mut cache = ::buffa::SizeCache::default();
        let mut buf = BytesMut::with_capacity(64);
        b.iter(|| {
            buf.clear();
            cache = ::buffa::SizeCache::default();
            let _ = evt.compute_size(&mut cache);
            evt.write_to(&mut cache, &mut buf);
            std::hint::black_box(&buf);
        });
    });
}

criterion_group!(benches, bench_encode_payload);
criterion_main!(benches);