Struct Server

pub struct Server<S>
where
    S: Storage,
{ /* private fields */ }

A running server instance.

Implementations

impl<S> Server<S>

where S: Storage,

pub fn spawn(storage: S, options: ServerOptions) -> Result<Self>

Start a new server with the given storage backend and options.

The server will spawn backgrounds tasks that will run until the server is stopped.

pub fn admin_service(&self) -> impl AdminService

Get a handle to the admin gRPC service.

pub fn executor_service(&self) -> impl ExecutorService

Get a handle to the executor service.

pub fn admin_service_client(&self) -> AdminServiceClient<Channel>

Get an admin service client that connects to the server using an in-memory transport.

Make sure to reuse the client as every call to this function will spawn a new task that is only cleaned up once the server is dropped.

pub fn executor_service_client(&self) -> ExecutorServiceClient<Channel>

Get an executor service client that connects to the server using an in-memory transport.

Make sure to reuse the client as every call to this function will spawn a new task that is only cleaned up once the server is dropped.

pub fn options(&self) -> &ServerOptions

Get the server options.

pub fn events( &self, ) -> impl Stream<Item = AuditEvent> + Unpin + Send + Sync + 'static

Subscribe to system events.

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

Shutdown the server.

impl<S> Server<S>

where S: Storage + StorageSnapshot,

pub fn snapshot_service(&self) -> impl SnapshotService

Get a handle to the snapshot service.

pub fn snapshot_service_client(&self) -> SnapshotServiceClient<Channel>

Get a snapshot service client that connects to the server using an in-memory transport.

Make sure to reuse the client as every call to this function will spawn a new task that is only cleaned up once the server is dropped.

Trait Implementations

impl<S> Drop for Server<S>

where S: Storage,

fn drop(&mut self)

Executes the destructor for this type.