pub struct DirectNominalChannelWriterServiceClient<T>(/* private fields */);Expand description
Writes data points directly to Nominal’s managed database offering.
Implementations§
Source§impl<T> DirectNominalChannelWriterServiceClient<T>where
T: Client,
impl<T> DirectNominalChannelWriterServiceClient<T>where
T: Client,
Sourcepub fn write_batches(
&self,
auth_: &BearerToken,
request: &WriteBatchesRequest,
) -> Result<(), Error>
pub 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: Clone> Clone for DirectNominalChannelWriterServiceClient<T>
impl<T: Clone> Clone for DirectNominalChannelWriterServiceClient<T>
Source§fn clone(&self) -> DirectNominalChannelWriterServiceClient<T>
fn clone(&self) -> DirectNominalChannelWriterServiceClient<T>
Returns a duplicate of the value. Read more
1.0.0§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl<T: Debug> Debug for DirectNominalChannelWriterServiceClient<T>
impl<T: Debug> Debug for DirectNominalChannelWriterServiceClient<T>
Auto Trait Implementations§
impl<T> Freeze for DirectNominalChannelWriterServiceClient<T>where
T: Freeze,
impl<T> RefUnwindSafe for DirectNominalChannelWriterServiceClient<T>where
T: RefUnwindSafe,
impl<T> Send for DirectNominalChannelWriterServiceClient<T>where
T: Send,
impl<T> Sync for DirectNominalChannelWriterServiceClient<T>where
T: Sync,
impl<T> Unpin for DirectNominalChannelWriterServiceClient<T>where
T: Unpin,
impl<T> UnwindSafe for DirectNominalChannelWriterServiceClient<T>where
T: UnwindSafe,
Blanket Implementations§
§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§unsafe fn clone_to_uninit(&self, dest: *mut u8)
unsafe fn clone_to_uninit(&self, dest: *mut u8)
🔬This is a nightly-only experimental API. (
clone_to_uninit)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