Trait LocalAsyncNominalDataSourceService 

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

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

Required Methods

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

Creates a data source.

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

fn batch_get( &self, auth_: BearerToken, rids: BTreeSet<NominalDataSourceRid>, ) -> impl Future<Output = 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>, ) -> impl Future<Output = 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, ) -> impl Future<Output = 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.

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