Struct WriteRequest 

pub struct WriteRequest<'a, W: WriteInput> { /* private fields */ }

Builder produced by Client::write; chain options, then .await.

Implementations

impl<'a, W: WriteInput> WriteRequest<'a, W>

pub fn precision(self, p: Precision) -> Self

pub fn no_sync(self) -> Self

pub fn accept_partial(self, accept: bool) -> Self

pub fn use_v2_api(self) -> Self

pub fn batch_size(self, n: usize) -> Self

pub fn max_inflight(self, n: usize) -> Self

pub fn default_tag( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

pub fn gzip_threshold(self, t: Option<usize>) -> Self

Compress bodies larger than t bytes; None disables compression. Disable or raise this for high-throughput ingest over a fast LAN where gzip CPU outweighs the bandwidth saved. See WriteOptions::gzip_threshold.

pub fn tag_order( self, order: impl IntoIterator<Item = impl Into<String>>, ) -> Self

pub fn with_options(self, opts: WriteOptions) -> Self

Replace the underlying options wholesale.

pub fn retry(self, policy: RetryConfig) -> Self

Override the retry policy for this write (defaults to the client’s).

pub fn no_retry(self) -> Self

Disable retries for this write.

Trait Implementations

impl<'a, W: WriteInput + Send + 'a> IntoFuture for WriteRequest<'a, W>

type Output = Result<(), Error>

The output that the future will produce on completion.

type IntoFuture = Pin<Box<dyn Future<Output = <WriteRequest<'a, W> as IntoFuture>::Output> + Send + 'a>>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.