Struct FlightSqlServerBuilder 

pub struct FlightSqlServerBuilder { /* private fields */ }

Implementations

impl FlightSqlServerBuilder

pub fn with_view_factory_fn<F, Fut>(self, f: F) -> Self

where F: FnOnce(Arc<RuntimeEnv>, Arc<DataLakeConnection>) -> Fut + Send + 'static, Fut: Future<Output = Result<ViewFactory>> + Send + 'static,

Override the default view factory with a custom closure.

The closure receives the runtime and data lake created by the builder.

pub fn with_session_configurator( self, cfg: Arc<dyn SessionConfigurator>, ) -> Self

Override the default session configurator.

By default the builder loads static tables from MICROMEGAS_STATIC_TABLES_URL. Use this to replace that behavior entirely.

pub fn with_auth_provider(self, provider: Arc<dyn AuthProvider>) -> Self

Set an explicit auth provider.

pub fn with_default_auth(self) -> Self

Use the default auth provider from env vars during build.

Errors if no auth providers are configured (fail-fast).

pub fn with_max_decoding_message_size(self, bytes: usize) -> Self

Set the max decoding message size (default: 100 MB).

pub fn with_listen_addr(self, addr: SocketAddr) -> Self

Set the listen address (default: 0.0.0.0:50051).

pub fn with_shutdown_grace(self, grace: Duration) -> Self

Set the grace period for graceful shutdown on SIGTERM (default: 25s).

pub fn with_lakehouse(self, lakehouse: Arc<LakehouseContext>) -> Self

Inject a pre-built LakehouseContext instead of calling LakehouseContext::from_env.

Useful for the monolith, which constructs one shared context for all lake-backed roles.

pub fn with_shutdown( self, shutdown: impl Future<Output = ()> + Send + 'static, ) -> Self

Inject a custom shutdown future instead of the default wait_for_sigterm().

The monolith passes fanout.subscribe() here so all roles shut down from one signal.

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

Build and run the FlightSQL server.

Runs the full setup sequence and blocks until the server shuts down.

Trait Implementations

impl Default for FlightSqlServerBuilder

fn default() -> Self

Returns the “default value” for a type.