Trait SeriesCacheService

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

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, ) -> Result<CachedSeriesResponse, Error>

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

fn create_cached_series( &self, auth_: BearerToken, request: CreateCachedSeriesRequest, ) -> Result<(), Error>

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, ) -> Result<GetChunksResponse, Error>

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, ) -> Result<CreateChunksResponse, Error>

fn batch_create_chunks( &self, auth_: BearerToken, request: CreateChunksParameters, ) -> Result<CreateChunksResponse, Error>

fn delete_chunks( &self, auth_: BearerToken, logical_series_rid: LogicalSeriesRid, request: DeleteChunksParameters, ) -> Result<DeleteChunksResponse, Error>

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

Implementors