Struct Inserter

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

Implementations

impl<T> Inserter<T>

where T: Reflection,

pub fn new(client: &Client, table: &str) -> Result<Self>

pub fn with_max_entries(self, threshold: u64) -> Self

pub fn with_max_duration(self, threshold: Duration) -> Self

pub fn set_max_entries(&mut self, threshold: u64)

pub fn set_max_duration(&mut self, threshold: Duration)

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

where T: Serialize,

pub async fn commit(&mut self) -> Result<Quantities>

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