Struct LocalAsyncSeriesMetadataServiceClient 

pub struct LocalAsyncSeriesMetadataServiceClient<C> { /* private fields */ }

Trait Implementations

impl<C> AsyncService<C> for LocalAsyncSeriesMetadataServiceClient<C>

fn new(client: C, runtime: &Arc<ConjureRuntime>) -> Self

Creates a new service wrapping an async HTTP client.

impl<C: Clone> Clone for LocalAsyncSeriesMetadataServiceClient<C>

fn clone(&self) -> LocalAsyncSeriesMetadataServiceClient<C>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<C: Debug> Debug for LocalAsyncSeriesMetadataServiceClient<C>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<I: Stream<Item = Result<Bytes, Error>>, __C> LocalAsyncSeriesMetadataService<I> for LocalAsyncSeriesMetadataServiceClient<__C>

where __C: LocalAsyncClient<ResponseBody = I>,

async fn batch_get( &self, auth_: &BearerToken, request: &BatchGetSeriesMetadataRequest, ) -> Result<BatchGetSeriesMetadataResponse, Error>

Batch get series metadata by DataSourceRid.

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

Create new series metadata.

async fn batch_create( &self, auth_: &BearerToken, request: &BatchCreateSeriesMetadataRequest, ) -> Result<(), Error>

Idempotently creates series metadata.

async fn create_or_update( &self, auth_: &BearerToken, request: &CreateSeriesMetadataRequest, ) -> Result<(), Error>

Upserts series metadata. Creates new series metadata if it does not exist for the given channel and data source. If it already exists, updates the locator and any provided unit and description fields while preserving existing values for fields not supplied.

async fn batch_create_or_update( &self, auth_: &BearerToken, request: &BatchCreateSeriesMetadataRequest, ) -> Result<(), Error>

Batch version of createOrUpdate.

async fn get( &self, auth_: &BearerToken, rid: &SeriesMetadataRid, ) -> Result<SeriesMetadata, Error>

Get series metadata from its series metadata rid.

async fn update_metadata( &self, auth_: &BearerToken, rid: &SeriesMetadataRid, request: &UpdateSeriesMetadataRequest, ) -> Result<SeriesMetadata, Error>

Update existing series metadata. Throws SeriesMetadataNotFound if the series metadata does not exist.

async fn batch_create_video_series( &self, auth_: &BearerToken, request: &BatchCreateVideoSeriesRequest, ) -> Result<BatchCreateVideoSeriesResponse, Error>

Batch creates series metadata for video channels if they don’t exist. Idempotent - returns existing SeriesMetadataRid if already exists.