Skip to main content

pipedream_rs/
events.rs

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