Trait SeriesCacheService 

pub trait SeriesCacheService<I: Iterator<Item = Result<Bytes, Error>>> {
    // Required methods
    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 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

impl<I: Iterator<Item = Result<Bytes, Error>>, __C> SeriesCacheService<I> for SeriesCacheServiceClient<__C>

where __C: Client<ResponseBody = I>,