Struct CatalogSvc 

pub struct CatalogSvc(pub Arc<TransactorNode>);

Catalog gRPC service over a node.

Tuple Fields

0: Arc<TransactorNode>

Trait Implementations

impl Catalog for CatalogSvc

fn create_database<'life0, 'async_trait>( &'life0 self, request: Request<CreateDatabaseRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateDatabaseResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn delete_database<'life0, 'async_trait>( &'life0 self, request: Request<DeleteDatabaseRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteDatabaseResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn fork_database<'life0, 'async_trait>( &'life0 self, request: Request<ForkDatabaseRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ForkDatabaseResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Creates a new database duplicating an existing one at a transaction basis (point-in-time fork).

fn list_databases<'life0, 'async_trait>( &'life0 self, _request: Request<ListDatabasesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListDatabasesResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn gc_deleted_databases<'life0, 'async_trait>( &'life0 self, request: Request<GcDeletedDatabasesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GcDeletedDatabasesResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn request_index<'life0, 'async_trait>( &'life0 self, request: Request<RequestIndexRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RequestIndexResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Publishes the database’s covering indexes now, bypassing pacing.

fn set_index_policy<'life0, 'async_trait>( &'life0 self, request: Request<SetIndexPolicyRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SetIndexPolicyResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Adjusts (or reads) the database’s index-publication pacing at runtime.