Struct nakadi_types::model::event_type::EventTypeStatistics

pub struct EventTypeStatistics {
    pub messages_per_minute: u64,
    pub message_size: u64,
    pub read_parallelism: u64,
    pub write_parallelism: u64,
}

Operational statistics for an EventType. This data may be provided by users on Event Type creation. Nakadi uses this object in order to provide an optimal number of partitions from a throughput perspective.

See also Nakadi Manual

Fields

messages_per_minute: u64

Write rate for events of this EventType. This rate encompasses all producers of this EventType for a Nakadi cluster.

Measured in event count per minute.

message_size: u64

Average message size for each Event of this EventType. Includes in the count the whole serialized form of the event, including metadata. Measured in bytes.

read_parallelism: u64

Amount of parallel readers (consumers) to this EventType.

write_parallelism: u64

Amount of parallel writers (producers) to this EventType.

Methods

impl EventTypeStatistics

pub fn new(
    messages_per_minute: u64,
    message_size: u64,
    read_parallelism: u64,
    write_parallelism: u64
) -> Self

Trait Implementations

impl Clone for EventTypeStatistics

fn clone(&self) -> EventTypeStatistics

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Copy for EventTypeStatistics

impl Debug for EventTypeStatistics

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for EventTypeStatistics

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl Eq for EventTypeStatistics

impl PartialEq<EventTypeStatistics> for EventTypeStatistics

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

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

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

This method tests for !=.

impl Serialize for EventTypeStatistics

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

Serialize this value into the given Serde serializer.

impl StructuralEq for EventTypeStatistics

impl StructuralPartialEq for EventTypeStatistics