near-async 0.34.3

This crate contains the async helpers specific for nearcore
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

use near_time::Clock;

use crate::instrumentation::{data::ALL_ACTOR_INSTRUMENTATIONS, reader::InstrumentedThreadsView};

pub(crate) mod data;
mod instrumented_window;
mod metrics;
pub mod queue;
pub mod reader;
#[cfg(test)]
pub(crate) mod test_utils;
#[cfg(feature = "actor_instrumentation_testing")]
pub mod testing;
#[cfg(test)]
mod tests;
pub(crate) mod writer;

pub use data::InstrumentedThread;
pub use writer::InstrumentedThreadWriter;
pub use writer::InstrumentedThreadWriterSharedPart;

/// Window size. Windows are aligned to whole multiples of this size since UNIX epoch,
/// regardless of when the actor thread started.
pub const WINDOW_SIZE_NS: u64 = 500_000_000; // 500ms
/// Number of most recent windows to maintain stats for.
const NUM_WINDOWS: usize = 60; // keep stats for the last 30 seconds

pub fn all_actor_instrumentations_view(clock: &Clock) -> InstrumentedThreadsView {
    ALL_ACTOR_INSTRUMENTATIONS.to_view(clock)
}