Struct AstraeaServer 

pub struct AstraeaServer { /* private fields */ }

TCP server that accepts newline-delimited JSON requests.

Protocol: each request is a single JSON line, each response is a single JSON line. Supports connection limits, request timeouts, idle timeouts, metrics, auth, TLS/mTLS, and graceful shutdown.

Implementations

impl AstraeaServer

pub fn new( config: ServerConfig, handler: RequestHandler, ) -> Result<Self, TlsError>

Create a new server. If TLS is configured, this will load the certificates.

Errors

Returns an error if TLS is configured but certificates cannot be loaded.

pub fn new_without_tls(config: ServerConfig, handler: RequestHandler) -> Self

Create a new server without TLS validation at construction time. Use this for testing or when you want to defer TLS setup.

pub fn with_auth(self, auth: AuthManager) -> Self

Create a server with authentication enabled.

pub fn metrics(&self) -> &Arc<ServerMetrics>

Get a reference to the metrics collector.

pub fn connection_manager(&self) -> &Arc<ConnectionManager>

Get a reference to the connection manager (for external shutdown).

pub async fn run(&self) -> Result<()>

Run the server, accepting connections until shutdown is initiated.

pub fn is_tls_enabled(&self) -> bool

Check if TLS is enabled for this server.