cdrs-async 0.1.0-alpha.0

Asynchronous driver for Apache Cassandra
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use std::pin::Pin;

use async_trait::async_trait;
use cassandra_proto::{error, frame::Frame, query::QueryBatch};

/// Traits that provides methods for sending multiple queries
/// to a DB server.
#[async_trait]
pub trait BatchExecutor: Send {
  async fn batch_with_params_tw(
    mut self: Pin<&mut Self>,
    batch: QueryBatch,
    with_tracing: bool,
    with_warnings: bool,
  ) -> error::Result<Frame>;

  async fn batch_with_params(mut self: Pin<&mut Self>, batch: QueryBatch) -> error::Result<Frame> {
    self.batch_with_params_tw(batch, false, false).await
  }
}