Trait NominalDataSourceService 

pub trait NominalDataSourceService<I: Iterator<Item = Result<Bytes, Error>>> {
    // Required methods
    fn create(
        &self,
        auth_: &BearerToken,
        request: &CreateNominalDataSourceRequest,
    ) -> Result<NominalDataSource, Error>;
    fn update(
        &self,
        auth_: &BearerToken,
        rid: &NominalDataSourceRid,
        request: &UpdateNominalDataSourceRequest,
    ) -> Result<NominalDataSource, Error>;
    fn batch_get(
        &self,
        auth_: &BearerToken,
        rids: &BTreeSet<NominalDataSourceRid>,
    ) -> Result<BTreeSet<NominalDataSource>, Error>;
    fn update_last_written_timestamp(
        &self,
        auth_: &BearerToken,
        rid: &NominalDataSourceRid,
        timestamp: DateTime<Utc>,
    ) -> Result<(), Error>;
    fn ensure_dataset_for_data_source(
        &self,
        auth_: &BearerToken,
        rid: &NominalDataSourceRid,
    ) -> Result<DatasetRid, Error>;
}

Manages data sources (logical groupings of series) that are stored by Nominal.

Required Methods

fn create( &self, auth_: &BearerToken, request: &CreateNominalDataSourceRequest, ) -> Result<NominalDataSource, Error>

Creates a data source.

fn update( &self, auth_: &BearerToken, rid: &NominalDataSourceRid, request: &UpdateNominalDataSourceRequest, ) -> Result<NominalDataSource, Error>

fn batch_get( &self, auth_: &BearerToken, rids: &BTreeSet<NominalDataSourceRid>, ) -> Result<BTreeSet<NominalDataSource>, Error>

Retrieves the data sources for the given data source RIDs.

Excludes data sources that do not exist or are unauthorized. A maximum of 1000 rids can be requested.

fn update_last_written_timestamp( &self, auth_: &BearerToken, rid: &NominalDataSourceRid, timestamp: DateTime<Utc>, ) -> Result<(), Error>

Sets the timestamp that the Nominal Data Source in question was last written to. Only needs to be called once per minute.

fn ensure_dataset_for_data_source( &self, auth_: &BearerToken, rid: &NominalDataSourceRid, ) -> Result<DatasetRid, Error>

Ensures a corresponding dataset exists for the given NominalDataSource. If the dataset already exists, this is a no-op. If it doesn’t exist, creates one with the same UUID as the NominalDataSource. This is to facilitate the migration from NominalDataSource to Dataset.

Implementors

impl<I: Iterator<Item = Result<Bytes, Error>>, __C> NominalDataSourceService<I> for NominalDataSourceServiceClient<__C>

where __C: Client<ResponseBody = I>,