pub struct DirectNominalChannelWriterServiceAsyncClient<T>(/* private fields */);
Expand description
Writes data points directly to Nominal’s managed database offering.
Implementations§
Source§impl<T> DirectNominalChannelWriterServiceAsyncClient<T>where
T: AsyncClient,
impl<T> DirectNominalChannelWriterServiceAsyncClient<T>where
T: AsyncClient,
Sourcepub async fn write_batches(
&self,
auth_: &BearerToken,
request: &WriteBatchesRequest,
) -> Result<(), Error>
pub async fn write_batches( &self, auth_: &BearerToken, request: &WriteBatchesRequest, ) -> Result<(), Error>
Synchronously writes batches of records to a Nominal data source. This endpoint bypasses the Channel Writer service entirely, and should only be used if the implications are well understood.
If you call this endpoint, writes will go directly into Nominal DB and will not be placed in Nominal’s durable queue. This results in lower latency, but also consequently lower durability.
Trait Implementations§
Source§impl<T> AsyncService<T> for DirectNominalChannelWriterServiceAsyncClient<T>where
T: AsyncClient,
impl<T> AsyncService<T> for DirectNominalChannelWriterServiceAsyncClient<T>where
T: AsyncClient,
Source§impl<T: Clone> Clone for DirectNominalChannelWriterServiceAsyncClient<T>
impl<T: Clone> Clone for DirectNominalChannelWriterServiceAsyncClient<T>
Source§fn clone(&self) -> DirectNominalChannelWriterServiceAsyncClient<T>
fn clone(&self) -> DirectNominalChannelWriterServiceAsyncClient<T>
Returns a duplicate of the value. Read more
1.0.0 · Source§const fn clone_from(&mut self, source: &Self)
const fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreAuto Trait Implementations§
impl<T> Freeze for DirectNominalChannelWriterServiceAsyncClient<T>where
T: Freeze,
impl<T> RefUnwindSafe for DirectNominalChannelWriterServiceAsyncClient<T>where
T: RefUnwindSafe,
impl<T> Send for DirectNominalChannelWriterServiceAsyncClient<T>where
T: Send,
impl<T> Sync for DirectNominalChannelWriterServiceAsyncClient<T>where
T: Sync,
impl<T> Unpin for DirectNominalChannelWriterServiceAsyncClient<T>where
T: Unpin,
impl<T> UnwindSafe for DirectNominalChannelWriterServiceAsyncClient<T>where
T: UnwindSafe,
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