svc-agent 0.21.0

An agent library.
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
41
42
43
44
45
46
47
48
49
50
51
52
53
54

use super::*;

/// A generic received message.
#[derive(Debug, Clone)]
pub enum IncomingMessage<T> {
    Event(IncomingEvent<T>),
    Request(IncomingRequest<T>),
    Response(IncomingResponse<T>),
}

#[derive(Debug, Clone)]
pub struct IncomingMessageContent<T, P>
where
    P: Addressable + serde::Serialize,
{
    payload: T,
    properties: P,
}

impl<T, P> IncomingMessageContent<T, P>
where
    P: Addressable + serde::Serialize,
{
    pub fn new(payload: T, properties: P) -> Self {
        Self {
            payload,
            properties,
        }
    }

    pub fn payload(&self) -> &T {
        &self.payload
    }

    pub fn extract_payload(self) -> T {
        self.payload
    }

    pub fn properties(&self) -> &P {
        &self.properties
    }

    pub fn properties_mut(&mut self) -> &mut P {
        &mut self.properties
    }
}

pub use incoming_event::*;
pub use incoming_request::*;
pub use incoming_response::*;

mod incoming_event;
mod incoming_request;
mod incoming_response;