Struct CatalogStoreService 

pub struct CatalogStoreService { /* private fields */ }

Trait service backed by a Store. Read-only RPCs only.

Implementations

impl CatalogStoreService

pub fn new(store: Store) -> Self

pub fn from_path(path: &Path) -> Result<Self, TimeSeriesError>

pub fn into_server(self) -> CatalogStoreServer<Self>

Trait Implementations

impl CatalogStore for CatalogStoreService

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Additive read surface (Phase 4.4).

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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