pipedream-rs 0.2.0

A typed, heterogeneous event relay with observable delivery, completion tracking, and lossless message routing
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12

/// Event emitted when a message is dropped due to a slow consumer.
///
/// Subscribe to this event to monitor stream health and identifying slow parts of your pipeline.
#[derive(Clone, Debug)]
pub struct Dropped {
    /// The ID of the message that was dropped.
    pub msg_id: u64,
    /// The ID of the stream where the drop occurred (usually the origin of the message).
    pub origin_stream_id: u64,
    /// The type name of the dropped event (for debugging).
    pub event_type_name: &'static str,
}