Struct OssServer 

pub struct OssServer { /* private fields */ }

The OSS server instance. Constructed via Self::new and consumed by Self::run. Holds every long-lived dependency the binary orchestrates — bind addresses, the engine session, the shared SessionStore, the metrics registry, and the readiness probe.

Implementations

impl OssServer

pub async fn new(config: JammiConfig) -> Result<Self, ServerError>

Build an OSS server from JammiConfig. Validates the server configuration up front (parses both bind addresses, rejects two identical FIXED bind addresses — identical :0 ephemeral addresses are allowed, since each resolves to a distinct port at bind), constructs the engine session (catalog, mutable tables, broker), and prepares the shared metrics registry and readiness probe.

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

Shared handle to the metrics registry. Test fixtures and the gRPC services use this to increment counters.

pub fn session(&self) -> Arc<InferenceSession>

Shared handle to the engine session. Useful in tests that want to publish to a topic or read a mutable table while the server is running.

pub fn with_readiness(self, readiness: Arc<ReadinessProbe>) -> Self

Override the readiness probe. Used by integration tests to make /readyz deterministically return 503.

pub async fn bind(self) -> Result<BoundServer, ServerError>

Bind both listeners eagerly and return a BoundServer holding them live. The gRPC + Flight SQL surface and the HTTP side-channel are each bound here — so their ACTUAL addresses are known (the real ports even when the config requested an ephemeral :0) before a single connection is served, and neither port is released before BoundServer::serve_with_shutdown serves on the same listeners. A caller reads the resolved ports off the returned handle (BoundServer::flight_addr / BoundServer::health_addr) while the listeners stay bound, with no observable release-then-rebind window.

pub async fn run(self) -> Result<(), ServerError>

Drive the server until SIGINT / SIGTERM arrives. Both the HTTP side-channel and the gRPC surface drain in parallel; the call returns when both have stopped accepting new connections and finished serving in-flight requests.

pub async fn run_with_shutdown( self, shutdown: impl Future<Output = ()> + Send + 'static, ) -> Result<(), ServerError>

Variant of Self::run that accepts a caller-provided shutdown future. Tests use this to drive deterministic teardown.