Struct pulsar_admin_sdk::models::load_report::LoadReport

pub struct LoadReport {

    pub allocated_bandwidth_in: Option<f64>,
    pub allocated_bandwidth_out: Option<f64>,
    pub allocated_cpu: Option<f64>,
    pub allocated_memory: Option<f64>,
    pub allocated_msg_rate_in: Option<f64>,
    pub allocated_msg_rate_out: Option<f64>,
    pub bandwidth_in: Option<Box<ResourceUsage>>,
    pub bandwidth_out: Option<Box<ResourceUsage>>,
    pub broker_version_string: Option<String>,
    pub bundle_gains: Option<Vec<String>>,
    pub bundle_losses: Option<Vec<String>>,
    pub bundle_stats: Option<HashMap<String, NamespaceBundleStats>>,
    pub cpu: Option<Box<ResourceUsage>>,
    pub direct_memory: Option<Box<ResourceUsage>>,
    pub last_update: Option<i64>,
    pub load_manager_class_name: Option<String>,
    pub load_report_type: Option<String>,
    pub memory: Option<Box<ResourceUsage>>,
    pub msg_rate_in: Option<f64>,
    pub msg_rate_out: Option<f64>,
    pub msg_throughput_in: Option<f64>,
    pub msg_throughput_out: Option<f64>,
    pub name: Option<String>,
    pub non_persistent_topics_enabled: Option<bool>,
    pub num_bundles: Option<i32>,
    pub num_consumers: Option<i32>,
    pub num_producers: Option<i32>,
    pub num_topics: Option<i64>,
    pub over_loaded: Option<bool>,
    pub persistent_topics_enabled: Option<bool>,
    pub pre_allocated_bandwidth_in: Option<f64>,
    pub pre_allocated_bandwidth_out: Option<f64>,
    pub pre_allocated_cpu: Option<f64>,
    pub pre_allocated_memory: Option<f64>,
    pub pre_allocated_msg_rate_in: Option<f64>,
    pub pre_allocated_msg_rate_out: Option<f64>,
    pub protocols: Option<HashMap<String, String>>,
    pub pulsar_service_url: Option<String>,
    pub pulsar_service_url_tls: Option<String>,
    pub start_timestamp: Option<i64>,
    pub system_resource_usage: Option<Box<SystemResourceUsage>>,
    pub timestamp: Option<i64>,
    pub under_loaded: Option<bool>,
    pub web_service_url: Option<String>,
    pub web_service_url_tls: Option<String>,
}

Fields

allocated_bandwidth_in: Option<f64>

allocated_bandwidth_out: Option<f64>

allocated_cpu: Option<f64>

allocated_memory: Option<f64>

allocated_msg_rate_in: Option<f64>

allocated_msg_rate_out: Option<f64>

bandwidth_in: Option<Box<ResourceUsage>>

bandwidth_out: Option<Box<ResourceUsage>>

broker_version_string: Option<String>

bundle_gains: Option<Vec<String>>

bundle_losses: Option<Vec<String>>

bundle_stats: Option<HashMap<String, NamespaceBundleStats>>

cpu: Option<Box<ResourceUsage>>

direct_memory: Option<Box<ResourceUsage>>

last_update: Option<i64>

load_manager_class_name: Option<String>

load_report_type: Option<String>

memory: Option<Box<ResourceUsage>>

msg_rate_in: Option<f64>

msg_rate_out: Option<f64>

msg_throughput_in: Option<f64>

msg_throughput_out: Option<f64>

name: Option<String>

non_persistent_topics_enabled: Option<bool>

num_bundles: Option<i32>

num_consumers: Option<i32>

num_producers: Option<i32>

num_topics: Option<i64>

over_loaded: Option<bool>

persistent_topics_enabled: Option<bool>

pre_allocated_bandwidth_in: Option<f64>

pre_allocated_bandwidth_out: Option<f64>

pre_allocated_cpu: Option<f64>

pre_allocated_memory: Option<f64>

pre_allocated_msg_rate_in: Option<f64>

pre_allocated_msg_rate_out: Option<f64>

protocols: Option<HashMap<String, String>>

pulsar_service_url: Option<String>

pulsar_service_url_tls: Option<String>

start_timestamp: Option<i64>

system_resource_usage: Option<Box<SystemResourceUsage>>

timestamp: Option<i64>

under_loaded: Option<bool>

web_service_url: Option<String>

web_service_url_tls: Option<String>

Implementations

impl LoadReport

pub fn new() -> LoadReport

Trait Implementations

impl Clone for LoadReport

fn clone(&self) -> LoadReport

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for LoadReport

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

Formats the value using the given formatter.

impl Default for LoadReport

fn default() -> LoadReport

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for LoadReport

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for LoadReport

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

This method tests for self and other values to be equal, and is used by ==.

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

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

impl Serialize for LoadReport

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for LoadReport