pub async fn namespace(&self, name: &str) -> Option<Arc<QuerierNamespace>> {
        let name = Arc::from(name.to_owned());
        let schema = self
            .catalog_cache
            .namespace()
            .schema(Arc::clone(&name))
            .await?;
        Some(Arc::new(QuerierNamespace::new(
            Arc::clone(&self.chunk_adapter),
            schema,
            name,
            Arc::clone(&self.exec),
            Arc::clone(&self.ingester_connection),
            Arc::clone(&self.query_log),
        )))
    }
/// Get namespace if it exists.
///
/// This will await the internal namespace semaphore. Existence of namespaces is checked AFTER a semaphore permit
/// was acquired since this lowers the chance that we obtain stale data.
Get namespace if it exists.
This will await the internal namespace semaphore. Existence of namespaces is checked AFTER a semaphore permit
was acquired since this lowers the chance that we obtain stale data.
Get namespace if it exists . This will await the internal namespace semaphore . Existence of namespaces is checked AFTER a semaphore permit was acquired since this lowers the chance that we obtain stale data .
pub async fn namespace(&self, name: &str) -> Option<Arc<QuerierNamespace>> {
        let name = Arc::from(name.to_owned());
        let schema = self
            .catalog_cache
            .namespace()
            .schema(Arc::clone(&name))
            .await?;
        Some(Arc::new(QuerierNamespace::new(
            Arc::clone(&self.chunk_adapter),
            schema,
            name,
            Arc::clone(&self.exec),
            Arc::clone(&self.ingester_connection),
            Arc::clone(&self.query_log),
        )))
    }
pub async fn namespace ( & self , name : & str ) -> Option < Arc < QuerierNamespace > > { let name = Arc :: from ( name . to_owned ( ) ) ; let schema = self . catalog_cache . namespace ( ) . schema ( Arc :: clone ( & name ) ) . await ? ; Some ( Arc :: new ( QuerierNamespace :: new ( Arc :: clone ( & self . chunk_adapter ) , schema , name , Arc :: clone ( & self . exec ) , Arc :: clone ( & self . ingester_connection ) , Arc :: clone ( & self . query_log ) , ) ) ) }
Get namespace if it exists.
Get namespace if it exists .
&self
name
&str
&self
name
&str