Struct NetworkManager 

pub struct NetworkManager { /* private fields */ }

Network Manager - Central coordinator for all network resources

Responsibilities

1. Configuration Management: Reads and manages all network-related environment variables
2. Server Creation: Creates and starts request plane servers based on mode
3. Client Creation: Creates request plane clients on demand
4. Abstraction: Hides all transport-specific details from the rest of the codebase

Design Principles

• Single Source of Truth: All network config and creation logic lives here
• Lazy Initialization: Servers are created only when first accessed
• Transport Agnostic Interface: Exposes only trait objects to callers
• No Leaky Abstractions: Transport types never escape this module

Example

// Create manager (typically done once in DistributedRuntime)
let manager = NetworkManager::new(cancel_token, nats_client, component_registry, request_plane_mode);

// Get server (lazy init, cached)
let server = manager.server().await?;
server.register_endpoint(...).await?;

// Create client (not cached, lightweight)
let client = manager.create_client()?;
client.send_request(...).await?;

Implementations

impl NetworkManager

pub fn new( cancellation_token: CancellationToken, nats_client: Option<Client>, component_registry: Registry, mode: RequestPlaneMode, ) -> Self

Create a new network manager

This is the single constructor for NetworkManager. All configuration is loaded from environment variables internally.

Arguments

• cancellation_token - Token for graceful shutdown of servers
• nats_client - Optional NATS client (required only for NATS mode)
• component_registry - Component registry to get NATS service groups from

Returns

Returns an Arc-wrapped NetworkManager ready to create servers and clients.

pub async fn server(&self) -> Result<Arc<dyn RequestPlaneServer>>

Get or create the request plane server

The server is created lazily on first access and cached for subsequent calls. The server is automatically started in the background.

Returns

Returns a trait object that abstracts over HTTP/TCP/NATS implementations.

Errors

Returns an error if:

• Server creation fails (e.g., port already in use)
• NATS mode is selected but NATS client is not available
• Configuration is invalid (e.g., malformed bind address)

pub fn create_client(&self) -> Result<Arc<dyn RequestPlaneClient>>

Create a new request plane client

Clients are lightweight and not cached. Each call creates a new client instance.

Returns

Returns a trait object that abstracts over HTTP/TCP/NATS implementations.

Errors

Returns an error if:

• Client creation fails (e.g., invalid configuration)
• NATS mode is selected but NATS client is not available

pub fn mode(&self) -> RequestPlaneMode

Get the current request plane mode

This is provided primarily for logging and debugging purposes. Application logic should not branch on mode - use trait objects instead.