pub async fn write_buffer_producer(
        &self,
        db_name: &str,
        cfg: &WriteBufferConnection,
    ) -> Result<Arc<dyn WriteBufferWriting>, ConnectionError> {
        let res = self
            .write_buffer_producers
            .get_with_meta((db_name.to_string(), cfg.clone()))
            .await
            .map_err(|e| Arc::new(e) as ConnectionError)?;
        debug!(was_cached=%res.cached, %db_name, "getting write buffer");
        Ok(res.result)
    }
/// Get write buffer producer given a DB name and config.
Get write buffer producer given a DB name and config.
Get write buffer producer given a DB name and config .
pub async fn write_buffer_producer(
        &self,
        db_name: &str,
        cfg: &WriteBufferConnection,
    ) -> Result<Arc<dyn WriteBufferWriting>, ConnectionError> {
        let res = self
            .write_buffer_producers
            .get_with_meta((db_name.to_string(), cfg.clone()))
            .await
            .map_err(|e| Arc::new(e) as ConnectionError)?;
        debug!(was_cached=%res.cached, %db_name, "getting write buffer");
        Ok(res.result)
    }
pub async fn write_buffer_producer ( & self , db_name : & str , cfg : & WriteBufferConnection , ) -> Result < Arc < dyn WriteBufferWriting > , ConnectionError > { let res = self . write_buffer_producers . get_with_meta ( ( db_name . to_string ( ) , cfg . clone ( ) ) ) . await . map_err ( | e | Arc :: new ( e ) as ConnectionError ) ? ; debug ! ( was_cached res cached db_name " " ) ; Ok ( res . result ) }
Get write buffer producer given a DB name and config.
Get write buffer producer given a DB name and config .
&self
db_name
&str
cfg
&WriteBufferConnection
&self
db_name
&str
cfg
&WriteBufferConnection