Struct XdsServer 

pub struct XdsServer { /* private fields */ }

The main xDS server.

This server wraps the cache and provides gRPC services for xDS. It includes production-ready features like health checking, metrics, graceful shutdown, and connection tracking.

Implementations

impl XdsServer

pub fn builder() -> XdsServerBuilder

Create a new builder for configuring the server.

pub fn cache(&self) -> &Arc<ShardedCache>

Get a reference to the cache.

pub fn registry(&self) -> &Arc<ResourceRegistry>

Get a reference to the resource registry.

pub fn config(&self) -> &ServerConfig

Get the server configuration.

pub fn metrics(&self) -> Option<&XdsMetrics>

Get the metrics instance, if enabled.

pub fn shutdown_controller(&self) -> &ShutdownController

Get the shutdown controller.

pub fn connections(&self) -> Option<&ConnectionTracker>

Get the connection tracker, if enabled.

pub fn service_state(&self) -> ServiceState

Create the service state for all discovery services.

pub async fn serve(self, addr: SocketAddr) -> Result<(), Error>

Start the server and listen on the given address.

This method will:

1. Set up health checking (if enabled)
2. Register all xDS services
3. Handle graceful shutdown on SIGTERM/SIGINT

Example

let server = XdsServerBuilder::new()
    .cache(cache)
    .build()?;

server.serve("[::]:18000".parse()?).await?;

pub async fn serve_with_shutdown( self, addr: SocketAddr, shutdown_rx: Receiver<()>, ) -> Result<(), Error>

Start the server with a custom shutdown signal.

This allows you to control shutdown programmatically.

Trait Implementations

impl Debug for XdsServer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.