asteroid-mq 0.1.0-alpha.3

An embeddable message queue system
Documentation
1
2
3
4
5
6
7
8
9
10
11
12
use serde::{Deserialize, Serialize};

use crate::prelude::{EndpointAddr, Interest, NodeId, TopicCode};

#[derive(Debug, Clone, Serialize, Deserialize)]

pub struct EndpointOnline {
    pub topic_code: TopicCode,
    pub endpoint: EndpointAddr,
    pub interests: Vec<Interest>,
    pub host: NodeId,
}