tailtriage-core 0.3.0

Framework-agnostic request instrumentation and run schema for tailtriage triage artifacts
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
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

use crate::{
    CaptureLimits, InFlightSnapshot, QueueEvent, RequestEvent, Run, RuntimeSnapshot, StageEvent,
};

pub(crate) fn push_request_bounded(
    run: &mut Run,
    limits: CaptureLimits,
    event: RequestEvent,
) -> bool {
    if run.requests.len() < limits.max_requests {
        run.requests.push(event);
        return false;
    }

    run.truncation.limits_hit = true;
    run.truncation.dropped_requests = run.truncation.dropped_requests.saturating_add(1);
    true
}

pub(crate) fn push_stage_bounded(run: &mut Run, limits: CaptureLimits, event: StageEvent) -> bool {
    if run.stages.len() < limits.max_stages {
        run.stages.push(event);
        return false;
    }

    run.truncation.limits_hit = true;
    run.truncation.dropped_stages = run.truncation.dropped_stages.saturating_add(1);
    true
}

pub(crate) fn push_queue_bounded(run: &mut Run, limits: CaptureLimits, event: QueueEvent) -> bool {
    if run.queues.len() < limits.max_queues {
        run.queues.push(event);
        return false;
    }

    run.truncation.limits_hit = true;
    run.truncation.dropped_queues = run.truncation.dropped_queues.saturating_add(1);
    true
}

pub(crate) fn push_inflight_snapshot_bounded(
    run: &mut Run,
    limits: CaptureLimits,
    snapshot: InFlightSnapshot,
) -> bool {
    if run.inflight.len() < limits.max_inflight_snapshots {
        run.inflight.push(snapshot);
        return false;
    }

    run.truncation.limits_hit = true;
    run.truncation.dropped_inflight_snapshots =
        run.truncation.dropped_inflight_snapshots.saturating_add(1);
    true
}

pub(crate) fn push_runtime_snapshot_bounded(
    run: &mut Run,
    limits: CaptureLimits,
    snapshot: RuntimeSnapshot,
) -> bool {
    if run.runtime_snapshots.len() < limits.max_runtime_snapshots {
        run.runtime_snapshots.push(snapshot);
        return false;
    }

    run.truncation.limits_hit = true;
    run.truncation.dropped_runtime_snapshots =
        run.truncation.dropped_runtime_snapshots.saturating_add(1);
    true
}