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 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

fn get_timestamp(&self) -> u64

fn set_timestamp(&mut self, ts: u64)

impl MoniSeries<DataSinkHB> for DataSinkHBSeries

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 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 = 43_690u16

Byte marker to mark beginning of payload

const TAIL: u16 = 21_845u16

Byte marker to mark end of payload

const SIZE: usize = 84usize

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 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