Struct clickhouse::insert::Insert

pub struct Insert<T> { /* private fields */ }

Performs only one INSERT.

Rows are being sent progressively to spread network load.

Implementations

impl<T> Insert<T>

pub fn with_timeouts( self, send_timeout: Option<Duration>, end_timeout: Option<Duration> ) -> Self

Sets timeouts for different operations.

send_timeout restricts time on sending a data chunk to a socket. None disables the timeout, it’s a default. It’s roughly equivalent to tokio::time::timeout(insert.write(..)).

end_timeout restricts time on waiting for a response from the CH server. Thus, it includes all work needed to handle INSERT by the CH server, e.g. handling all materialized views and so on. None disables the timeout, it’s a default. It’s roughly equivalent to tokio::time::timeout(insert.end(..)).

These timeouts are much more performant (~x10) than wrapping write() and end() calls into tokio::time::timeout().

pub fn write<'a>( &'a mut self, row: &T ) -> impl Future<Output = Result<()>> + 'a + Sendwhere T: Serialize,

Serializes and writes to the socket a provided row.

Panics

If called after previous call returned an error.

pub async fn end(self) -> Result<()>

Ends INSERT. Succeeds if the server returns 200.

If it isn’t called, the whole INSERT is aborted.

Trait Implementations

impl<T> Drop for Insert<T>

fn drop(&mut self)

Executes the destructor for this type.