Crate jammi_server 

Library surface for the OSS jammi-server binary.

The binary’s orchestration entry-point is runtime::OssServer. The library also re-exports building blocks (build_router, flight::*, grpc::*) so test fixtures and downstream binaries (e.g. the jammi CLI’s serve subcommand) can compose the same pieces without reimplementing them.

For downstream composition, runtime::assemble_grpc_chain returns an runtime::AssembledChain with the engine’s services pre-mounted; a downstream chains runtime::AssembledChain::mount to add its own services beside the engine’s on one listener, then serves — or splits via runtime::AssembledChain::into_axum_router to compose a single axum listener of its own. serve_grpc_chain is the thin OSS-only path over the same seam.

Modules

error

flight

Arrow Flight SQL server backed by a DataFusion SessionContext.

grpc

gRPC services exposed by jammi-server.

grpc_web_trailers

gRPC-Web trailers-only repair layer.

metrics_layer

Whole-server metrics layer.

routes

runtime

OssServer — the single orchestration entry-point for the OSS jammi-server binary.

telemetry

Tracing initialisation shared by every server entry-point.

tenant_resolver_layer

The async tenant-binding tower layer — the SINGLE binder for every engine gRPC service.

tiers

Service tiers — the mechanism that lets one jammi-server binary scale to many deployment shapes by mounting only the gRPC services a deployment needs.

Structs

TriggerHandles

Trigger-stream handles attached to the gRPC server. The caller constructs these once per deployment (sharing one broker, publisher, subscriber, and topic catalog repo across every connection).

Functions

build_health_router

Build the full side-channel router exposing /healthz, /readyz, and /metrics. The readiness probe and metrics registry are passed in as Arcs so test fixtures can substitute stubs.

build_router

Build the side-channel router with /healthz only — no readiness or metrics state attached. Callers that need the full surface construct the router through runtime::OssServer.