Struct Telemetry 

pub struct Telemetry { /* private fields */ }

Implementations

impl Telemetry

pub fn incr_total_connections(incr_by: usize) -> usize

Increment the total number of connections by incr_by Return the number of total connections after the increment

pub fn decr_total_connections(decr_by: usize) -> usize

Decrease the total number of connections by decr_by Return the number of total connections after the decrease

pub fn incr_total_clients(incr_by: usize) -> usize

Increment the total number of clients by incr_by Return the number of total clients after the increment

pub fn decr_total_clients(decr_by: usize) -> usize

Decrease the total number of clients by decr_by Return the number of total clients after the decrease

pub fn total_connections() -> usize

Return the number of active connections

pub fn total_clients() -> usize

Return the number of active clients

pub fn incr_total_values_compressed(incr_by: usize) -> usize

Increment the total number of values compressed

pub fn total_values_compressed() -> usize

Return the total number of values compressed

pub fn incr_total_values_decompressed(incr_by: usize) -> usize

Increment the total number of values decompressed

pub fn total_values_decompressed() -> usize

Return the total number of values decompressed

pub fn incr_total_original_bytes(incr_by: usize) -> usize

Increment the total original bytes before compression

pub fn total_original_bytes() -> usize

Return the total original bytes before compression

pub fn incr_total_bytes_compressed(incr_by: usize) -> usize

Increment the total bytes after compression

pub fn total_bytes_compressed() -> usize

Return the total bytes after compression

pub fn incr_total_bytes_decompressed(incr_by: usize) -> usize

Increment the total bytes after decompression

pub fn total_bytes_decompressed() -> usize

Return the total bytes after decompression

pub fn incr_compression_skipped_count(incr_by: usize) -> usize

Increment the compression skipped count

pub fn compression_skipped_count() -> usize

Return the compression skipped count

pub fn incr_subscription_out_of_sync() -> usize

Increment the subscription out of sync count Return the new count after increment

pub fn subscription_out_of_sync_count() -> usize

Get the current subscription out of sync count

pub fn update_subscription_last_sync_timestamp(timestamp: u64) -> u64

Update the subscription last sync timestamp Return the new timestamp

pub fn subscription_last_sync_timestamp() -> u64

Get the subscription last sync timestamp

pub fn reset()

Reset the telemetry collected thus far

Trait Implementations

impl Default for Telemetry

fn default() -> Self

Returns the “default value” for a type.

impl Serialize for Telemetry

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.