asteroid_mq/
lib.rs

1pub mod error;
2pub mod protocol;
3pub(crate) mod util;
4use std::net::{IpAddr, Ipv4Addr, SocketAddr};
5
6pub use bytes;
7pub use error::Error;
8pub use openraft;
9pub type Result<T> = std::result::Result<T, Error>;
10pub mod prelude {
11    pub use crate::error::Error;
12    pub use crate::model::*;
13    pub use crate::protocol::node::durable_message::{
14        Durable, DurableError, DurableMessage, DurableMessageQuery, DurableService,
15        MessageDurableConfig,
16    };
17    pub use crate::protocol::node::raft::state_machine::topic::config::*;
18    pub use crate::protocol::node::{Node, NodeConfig};
19    pub use crate::util::{KB, MB};
20}
21
22pub use asteroid_mq_model as model;
23pub const DEFAULT_TCP_PORT: u16 = 9559;
24pub const DEFAULT_TCP_ADDR: IpAddr = IpAddr::V4(Ipv4Addr::UNSPECIFIED);
25pub const DEFAULT_TCP_SOCKET_ADDR: SocketAddr = SocketAddr::new(DEFAULT_TCP_ADDR, DEFAULT_TCP_PORT);
asteroid_mq/lib.rs

asteroid_mq/
lib.rs
