Trait AsyncSeriesCacheService 

pub trait AsyncSeriesCacheService {
    // Required methods
    fn batch_get_cached_series(
        &self,
        auth_: BearerToken,
        request: GetCachedSeriesRequest,
    ) -> impl Future<Output = Result<CachedSeriesResponse, Error>> + Send;
    fn create_cached_series(
        &self,
        auth_: BearerToken,
        request: CreateCachedSeriesRequest,
    ) -> impl Future<Output = Result<(), Error>> + Send;
    fn get_chunks(
        &self,
        auth_: BearerToken,
        logical_series_rid: LogicalSeriesRid,
        get_chunks_parameters: GetChunksParameters,
    ) -> impl Future<Output = Result<GetChunksResponse, Error>> + Send;
    fn create_chunks(
        &self,
        auth_: BearerToken,
        logical_series_rid: LogicalSeriesRid,
        create_chunks_parameters: CreateChunksParameters,
    ) -> impl Future<Output = Result<CreateChunksResponse, Error>> + Send;
    fn batch_create_chunks(
        &self,
        auth_: BearerToken,
        request: CreateChunksParameters,
    ) -> impl Future<Output = Result<CreateChunksResponse, Error>> + Send;
    fn delete_chunks(
        &self,
        auth_: BearerToken,
        logical_series_rid: LogicalSeriesRid,
        request: DeleteChunksParameters,
    ) -> impl Future<Output = Result<DeleteChunksResponse, Error>> + Send;
}

The Series Cache service manages internal chunks of data cached by Nominal’s backend.

Required Methods

fn batch_get_cached_series( &self, auth_: BearerToken, request: GetCachedSeriesRequest, ) -> impl Future<Output = Result<CachedSeriesResponse, Error>> + Send

Fetches information about logical series that are cached in the Nominal time series database.

fn create_cached_series( &self, auth_: BearerToken, request: CreateCachedSeriesRequest, ) -> impl Future<Output = Result<(), Error>> + Send

Records a logical series as cached in the Nominal time series database.

fn get_chunks( &self, auth_: BearerToken, logical_series_rid: LogicalSeriesRid, get_chunks_parameters: GetChunksParameters, ) -> impl Future<Output = Result<GetChunksResponse, Error>> + Send

Fetches “chunks” of series that are stored as Arrow files in S3. This endpoint is being deprecated for new series in favor of batchGetCachedSeries

fn create_chunks( &self, auth_: BearerToken, logical_series_rid: LogicalSeriesRid, create_chunks_parameters: CreateChunksParameters, ) -> impl Future<Output = Result<CreateChunksResponse, Error>> + Send

fn batch_create_chunks( &self, auth_: BearerToken, request: CreateChunksParameters, ) -> impl Future<Output = Result<CreateChunksResponse, Error>> + Send

fn delete_chunks( &self, auth_: BearerToken, logical_series_rid: LogicalSeriesRid, request: DeleteChunksParameters, ) -> impl Future<Output = Result<DeleteChunksResponse, Error>> + Send

Deletes the chunks that intersect the given time range. Does not delete the corresponding files from S3.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors