spop 0.11.0

Library for parsing HAProxy SPOP (Stream Processing Offload Protocol)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

use crate::{
    SpopFrame,
    frame::{FramePayload, FrameType, Message, Metadata},
};
use std::borrow::Cow;

/// Frame Notify
///
/// <https://github.com/haproxy/haproxy/blob/master/doc/SPOE.txt#L939>
///
/// ```text
/// 3.2.6. Frame: NOTIFY
/// ---------------------
///
/// Information are sent to the agents inside NOTIFY frames. These frames are
/// attached to a stream, so STREAM-ID and FRAME-ID must be set. The payload of
/// NOTIFY frames is a LIST-OF-MESSAGES.
///
/// NOTIFY frames must be acknowledge by agents sending an ACK frame, repeating
/// right STREAM-ID and FRAME-ID.
/// ```
#[derive(Debug)]
pub struct NotifyFrame {
    pub metadata: Metadata,
    pub messages: Vec<Message>,
}

impl SpopFrame for NotifyFrame {
    fn frame_type(&self) -> &FrameType {
        &FrameType::Notify
    }

    fn metadata(&self) -> Cow<'_, Metadata> {
        Cow::Borrowed(&self.metadata)
    }

    fn payload(&self) -> FramePayload<'_> {
        FramePayload::ListOfMessages(&self.messages)
    }
}