Struct Server 

pub struct Server<A: DatabaseAdapter> { /* private fields */ }

FraiseQL HTTP Server.

Implementations

impl<A: DatabaseAdapter + Clone + Send + Sync + 'static> Server<A>

pub async fn new( config: ServerConfig, schema: CompiledSchema, adapter: Arc<A>, db_pool: Option<PgPool>, ) -> Result<Self>

Create new server.

Relay pagination queries will return a Validation error at runtime. Use Server::with_relay_pagination when the adapter implements RelayDatabaseAdapter and relay support is required.

Arguments

• config - Server configuration
• schema - Compiled GraphQL schema
• adapter - Database adapter
• db_pool - Database connection pool (optional, required for observers)

Errors

Returns error if OIDC validator initialization fails (e.g., unable to fetch discovery document or JWKS).

Example

let config = ServerConfig::default();
let schema = CompiledSchema::from_json(schema_json)?;
let adapter = Arc::new(PostgresAdapter::new(db_url).await?);

let server = Server::new(config, schema, adapter, None).await?;
server.serve().await?;

pub fn with_subscription_lifecycle( self, lifecycle: Arc<dyn SubscriptionLifecycle>, ) -> Self

Set lifecycle hooks for WebSocket subscriptions.

pub fn with_max_subscriptions_per_connection(self, max: u32) -> Self

Set maximum subscriptions allowed per WebSocket connection.

pub fn set_secrets_manager(&mut self, manager: Arc<SecretsManager>)

Set secrets manager for the server.

This allows attaching a secrets manager after server creation for credential management.

impl<A: DatabaseAdapter + RelayDatabaseAdapter + Clone + Send + Sync + 'static> Server<A>

pub async fn with_relay_pagination( config: ServerConfig, schema: CompiledSchema, adapter: Arc<A>, db_pool: Option<PgPool>, ) -> Result<Self>

Create a server with relay pagination support enabled.

The adapter must implement RelayDatabaseAdapter. Currently, only PostgresAdapter and CachedDatabaseAdapter<PostgresAdapter> satisfy this bound.

Relay queries issued against a server created with Server::new return a Validation error at runtime; those issued against a server created with this constructor succeed.

Arguments

• config - Server configuration
• schema - Compiled GraphQL schema
• adapter - Database adapter (must implement RelayDatabaseAdapter)
• db_pool - Database connection pool (optional, required for observers)

Errors

Returns error if OIDC validator initialization fails.

Example

let adapter = Arc::new(PostgresAdapter::new(db_url).await?);
let server = Server::with_relay_pagination(config, schema, adapter, None).await?;
server.serve().await?;

impl<A: DatabaseAdapter + Clone + Send + Sync + 'static> Server<A>

pub async fn serve(self) -> Result<()>

Start server and listen for requests.

Errors

Returns error if server fails to bind or encounters runtime errors.

pub async fn serve_with_shutdown<F>(self, shutdown: F) -> Result<()>

where F: Future<Output = ()> + Send + 'static,

Start server with a custom shutdown future.

Enables programmatic shutdown (e.g., for --watch hot-reload) by accepting any future that resolves when the server should stop.

Errors

Returns error if server fails to bind or encounters runtime errors.

pub async fn shutdown_signal()

Listen for shutdown signals (Ctrl+C or SIGTERM)