Struct DataSinkHB 

pub struct DataSinkHB {
    pub met: u64,
    pub n_packets_sent: u64,
    pub n_packets_incoming: u64,
    pub n_bytes_written: u64,
    pub n_evid_missing: u64,
    pub n_evid_chunksize: u64,
    pub evid_missing: u64,
    pub evid_check_len: u64,
    pub n_pack_write_disk: u64,
    pub incoming_ch_len: u64,
    pub timestamp: u64,
}

Fields

met: u64

mission elapsed time in seconds

n_packets_sent: u64

n_packets_incoming: u64

n_bytes_written: u64

bytes written to disk

n_evid_missing: u64

event id check - missing event ids

n_evid_chunksize: u64

event id check - chunksize

evid_missing: u64

length of incoming buffer for the thread check for missing event ids

evid_check_len: u64

probe size for missing event id check

n_pack_write_disk: u64

number of packets written to disk

incoming_ch_len: u64

length of the incoming channel, which is basically packets queued to be sent

timestamp: u64

Implementations

impl DataSinkHB

pub fn new() -> Self

pub fn get_sent_packet_rate(&self) -> f64

pub fn get_mbytes_to_disk_per_sec(&self) -> f64

Trait Implementations

impl Clone for DataSinkHB

fn clone(&self) -> DataSinkHB

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DataSinkHB

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for DataSinkHB

fn default() -> Self

Returns the “default value” for a type.

impl Display for DataSinkHB

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl FromRandom for DataSinkHB

Available on crate feature random only.

fn from_random() -> Self

impl MoniData for DataSinkHB

fn get(&self, varname: &str) -> Option<f32>

Access the (data) members by name

fn keys() -> Vec<&'static str>

A list of the variables in this MoniData

fn get_board_id(&self) -> u8

Monitoring data is always tied to a specific board. This might not be its own board, but maybe the RB the data was gathered from This is an unique identifier for the monitoring data across the same type.

fn get_timestamp(&self) -> u64

fn set_timestamp(&mut self, ts: u64)

impl MoniSeries<DataSinkHB> for DataSinkHBSeries

fn get_first_ts(&self) -> u64

fn get_data(&self) -> &HashMap<u8, VecDeque<DataSinkHB>>

fn get_data_mut(&mut self) -> &mut HashMap<u8, VecDeque<DataSinkHB>>

fn get_max_size(&self) -> usize

fn set_max_size(&mut self, size: usize)

fn add_timestamp(&mut self, ts: u64)

fn get_timestamps(&self) -> &Vec<u64>

fn get_var(&self, varname: &str) -> HashMap<u8, Vec<f32>>

A HashMap of -> rbid, Vec<var>

fn get_var_for_board(&self, varname: &str, rb_id: &u8) -> Option<Vec<f32>>

Get a certain variable, but only for a single board

fn keys() -> Vec<&'static str>

A list of the variables in this MoniSeries

fn get_board_ids(&self) -> Vec<u8>

A list of boards in this series

fn add(&mut self, data: T)

Add another instance of the data container to the series

fn get_last_moni(&self, board_id: u8) -> Option<T>

impl PartialEq for DataSinkHB

fn eq(&self, other: &DataSinkHB) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialization for DataSinkHB

const HEAD: u16 = 0xAAAA

Byte marker to mark beginning of payload

const TAIL: u16 = 0x5555

Byte marker to mark end of payload

const SIZE: usize = 84

The SIZE is the size of the serialized bytestream INCLUDING 4 bytes for head and tail bytes. In case the struct does NOT HAVE a fixed size, SIZE will be 0 (so default value of the trait

fn from_bytestream( stream: &Vec<u8>, pos: &mut usize, ) -> Result<Self, SerializationError>

Decode a serializable from a bytestream

fn to_bytestream(&self) -> Vec<u8>

Encode a serializable to a bytestream

fn guess_size( stream: &Vec<u8>, pos: usize, offset: usize, ) -> Result<(usize, usize, usize), SerializationError>

Guess the size of te packet. This can be a preformance issue if te offset position is far off

fn verify_fixed( stream: &Vec<u8>, pos: &mut usize, ) -> Result<(), SerializationError>

Verify that the serialized representation of the struct has the correct size, including header + footer.

fn from_bytestream_alt( bytestream: &Vec<u8>, pos: &mut usize, ) -> Result<Self, SerializationError>

where Self: Sized,

Decode a serializable from a bytestream. This provides an alternative method to get the packet. If not implemented, it will be the same as from_bytestream.

impl TofPackable for DataSinkHB

const TOF_PACKET_TYPE: TofPacketType = TofPacketType::DataSinkHB

const TOF_PACKET_TYPE_ALT: TofPacketType = TofPacketType::Unknown

fn pack(&self) -> TofPacket

where Self: Serialization,

Wrap myself in a TofPacket

impl Copy for DataSinkHB

impl StructuralPartialEq for DataSinkHB