Trait NominalDataSourceService 

pub trait NominalDataSourceService {
    // 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