Skip to main content

sentinel_driver/connection/
pipeline_impl.rs

1use super::{pipeline, Connection, PipelineBatch, Result};
2
3impl Connection {
4    /// Create a pipeline batch for executing multiple queries in a single round-trip.
5    ///
6    /// Use `execute_pipeline()` to send the batch.
7    pub fn pipeline(&self) -> PipelineBatch {
8        PipelineBatch::new()
9    }
10
11    /// Execute a pipeline batch, returning results for each query.
12    pub async fn execute_pipeline(
13        &mut self,
14        batch: PipelineBatch,
15    ) -> Result<Vec<pipeline::QueryResult>> {
16        batch.execute(&mut self.conn).await
17    }
18}