rzmq 0.5.5

A high performance, fully asynchronous, safe pure-Rust implementation of ZeroMQ (ØMQ) messaging with io_uring and tcp cork acceleration on Linux.
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

#![allow(dead_code)] // Allow dead code for now

use crate::context::Context;
use crate::socket::events::MonitorSender;
use crate::Msg; 

use fibre::mpmc::AsyncReceiver;

/// General configuration and context for the SessionConnectionActorX.
#[derive(Debug, Clone)] // Clone if it needs to be passed around easily
pub(crate) struct ActorConfigX {
  pub context: Context,
  pub monitor_tx: Option<MonitorSender>,
  pub logical_target_endpoint_uri: String,
  pub connected_endpoint_uri: String,
  pub is_server_role: bool,
}

// Shell for CorePipeManagerX state, to be fleshed out later.
// Located here as it's primarily a state holder for pipe-related fields.
#[derive(Debug)]
pub(crate) struct CorePipeManagerXState {
  pub rx_from_core: Option<AsyncReceiver<Vec<Msg>>>,
  pub core_pipe_read_id_for_incoming_routing: Option<usize>,
  pub is_attached: bool,
}

impl CorePipeManagerXState {
  pub(crate) fn new() -> Self {
    Self {
      rx_from_core: None,
      core_pipe_read_id_for_incoming_routing: None,
      is_attached: false,
    }
  }
}