Struct ReplServer 

pub struct ReplServer { /* private fields */ }

REPL server that accepts TCP connections and processes requests

Manages multiple concurrent client connections, each with independent request/response handling. All connections share the same SessionManager, allowing sessions to be accessed from multiple clients.

Supports graceful shutdown with configurable timeout for active connections.

Implementations

impl ReplServer

pub fn new(address: impl Into<String>) -> Self

Create a new REPL server

Arguments

• address - Address to bind to (e.g., “127.0.0.1:5555”)

Example

use oxur_repl::server::ReplServer;

let server = ReplServer::new("127.0.0.1:5555");

pub fn with_metrics(self) -> Self

Enable metrics collection for the server

When enabled, the server records:

• Connection counts (total and active)
• Session counts (total and active)
• Request/response counts by type and status

Example

use oxur_repl::server::ReplServer;

let server = ReplServer::new("127.0.0.1:5555")
    .with_metrics();

pub fn with_shutdown_timeout(self, timeout: Duration) -> Self

Set the graceful shutdown timeout

This configures how long the server will wait for active connections to finish when shutting down.

Example

use oxur_repl::server::ReplServer;
use std::time::Duration;

let mut server = ReplServer::new("127.0.0.1:5555")
    .with_shutdown_timeout(Duration::from_secs(60));

pub fn shutdown_handle(&self) -> ShutdownHandle

Get a shutdown handle that can be used to trigger graceful shutdown

Call shutdown() on the returned handle to initiate server shutdown.

Example

use oxur_repl::server::ReplServer;

let mut server = ReplServer::new("127.0.0.1:5555");
let shutdown_handle = server.shutdown_handle();

// Later, from another task:
tokio::spawn(async move {
    // ... some condition ...
    shutdown_handle.shutdown();
});

pub async fn start(&mut self) -> Result<()>

Start the server and listen for connections

This method blocks until the server is shut down via a shutdown signal. When shutdown is triggered, the server will:

1. Stop accepting new connections
2. Wait for active connections to finish (up to shutdown_timeout)
3. Close all sessions

Errors

Returns error if:

• Failed to bind to address
• Failed to accept connections

Example

use oxur_repl::server::ReplServer;

let mut server = ReplServer::new("127.0.0.1:5555");

// Get shutdown handle before starting
let shutdown_handle = server.shutdown_handle();

// Spawn server in background
let server_task = tokio::spawn(async move {
    server.start().await
});

// Later, trigger shutdown
shutdown_handle.shutdown();

// Wait for server to finish
server_task.await.unwrap()?;

Trait Implementations

impl Debug for ReplServer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.