INNER CODE UNIT · Rust

set_dynamic_conf

valeriansaliou/sonic · core/src/executor/mod.rs:125

    pub fn set_dynamic_conf(
        &self,
        collection: &str,
        new_conf: DynamicConfig,
    ) -> Result<(), Box<dyn std::error::Error>> {
        tracing::debug!(
            ?new_conf.rocksdb,
            "Re-opening KV store connection for {collection:?} with new dynamic configuration overrides…"
        );

        let mut kv_pool_write_guard = self.kv_pool.pool_write_guard();

        self.kv_pool
            .close(collection, Some(&mut kv_pool_write_guard))
            .map_err(|()| std::io::Error::other("Error closing connection"))?;

        self.kv_pool
            .acquire(

View source record →