pub struct AsyncNominalDataSourceServiceClient<C> { /* private fields */ }Trait Implementations§
Source§impl<I: Stream<Item = Result<Bytes, Error>>, __C> AsyncNominalDataSourceService<I> for AsyncNominalDataSourceServiceClient<__C>
impl<I: Stream<Item = Result<Bytes, Error>>, __C> AsyncNominalDataSourceService<I> for AsyncNominalDataSourceServiceClient<__C>
Source§async fn create(
&self,
auth_: &BearerToken,
request: &CreateNominalDataSourceRequest,
) -> Result<NominalDataSource, Error>
async fn create( &self, auth_: &BearerToken, request: &CreateNominalDataSourceRequest, ) -> Result<NominalDataSource, Error>
Creates a data source.
async fn update( &self, auth_: &BearerToken, rid: &NominalDataSourceRid, request: &UpdateNominalDataSourceRequest, ) -> Result<NominalDataSource, Error>
Source§async fn batch_get(
&self,
auth_: &BearerToken,
rids: &BTreeSet<NominalDataSourceRid>,
) -> Result<BTreeSet<NominalDataSource>, Error>
async fn batch_get( &self, auth_: &BearerToken, rids: &BTreeSet<NominalDataSourceRid>, ) -> Result<BTreeSet<NominalDataSource>, Error>
Retrieves the data sources for the given data source RIDs. Read more
Source§async fn update_last_written_timestamp(
&self,
auth_: &BearerToken,
rid: &NominalDataSourceRid,
timestamp: DateTime<Utc>,
) -> Result<(), Error>
async 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.
Source§async fn ensure_dataset_for_data_source(
&self,
auth_: &BearerToken,
rid: &NominalDataSourceRid,
) -> Result<DatasetRid, Error>
async 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.
Source§impl<C> AsyncService<C> for AsyncNominalDataSourceServiceClient<C>
impl<C> AsyncService<C> for AsyncNominalDataSourceServiceClient<C>
Source§fn new(client: C, runtime: &Arc<ConjureRuntime>) -> Self
fn new(client: C, runtime: &Arc<ConjureRuntime>) -> Self
Creates a new service wrapping an async HTTP client.
Source§impl<C: Clone> Clone for AsyncNominalDataSourceServiceClient<C>
impl<C: Clone> Clone for AsyncNominalDataSourceServiceClient<C>
Source§fn clone(&self) -> AsyncNominalDataSourceServiceClient<C>
fn clone(&self) -> AsyncNominalDataSourceServiceClient<C>
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl<C> Freeze for AsyncNominalDataSourceServiceClient<C>where
C: Freeze,
impl<C> !RefUnwindSafe for AsyncNominalDataSourceServiceClient<C>
impl<C> Send for AsyncNominalDataSourceServiceClient<C>where
C: Send,
impl<C> Sync for AsyncNominalDataSourceServiceClient<C>where
C: Sync,
impl<C> Unpin for AsyncNominalDataSourceServiceClient<C>where
C: Unpin,
impl<C> UnsafeUnpin for AsyncNominalDataSourceServiceClient<C>where
C: UnsafeUnpin,
impl<C> !UnwindSafe for AsyncNominalDataSourceServiceClient<C>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request