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 · Source§const fn clone_from(&mut self, source: &Self)
const 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§
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