Struct ServerHandlers

pub struct ServerHandlers {
    handlers: Arc<RwLock<HashMap<String, ServerHandler>>>,
}

ServerHandlers is used to manage the lifecycle of all the services like http or grpc in the GreptimeDB server.

Fields

handlers: Arc<RwLock<HashMap<String, ServerHandler>>>

Implementations

impl ServerHandlers

pub fn new() -> Self

pub async fn insert(&self, handler: ServerHandler)

pub async fn addr(&self, name: &str) -> Option<SocketAddr>

Finds the actual bound address of the service by its name.

This is useful in testing. We can configure the service to bind to port 0 first, then start the server to get the real bound port number. This way we avoid doing careful assignment of the port number to the service in the test.

Note that the address is guaranteed to be correct only after the start_all method is successfully invoked. Otherwise you may find the address to be what you configured before.

pub async fn start_all(&self) -> Result<()>

Starts all the managed services. It will block until all the services are started. And it will set the actual bound address to the service.

pub async fn shutdown_all(&self) -> Result<()>

Shutdown all the managed services. It will block until all the services are shutdown.

Trait Implementations

impl Clone for ServerHandlers

fn clone(&self) -> ServerHandlers

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for ServerHandlers

fn default() -> ServerHandlers

Returns the “default value” for a type.