Struct ConcurrentIntrospector 

pub struct ConcurrentIntrospector { /* private fields */ }

Concurrent database introspector.

Implementations

impl ConcurrentIntrospector

pub fn new(config: IntrospectionConfig) -> Self

Create a new concurrent introspector.

pub async fn introspect_tables<F, Fut>( &self, table_names: Vec<String>, operation: F, ) -> IntrospectionResult

where F: Fn(String) -> Fut + Clone + Send + 'static, Fut: Future<Output = Result<TableMetadata, String>> + Send + 'static,

Introspect tables concurrently using a custom operation.

The operation function is called for each table name and should return the table metadata.

pub async fn introspect_named<F, Fut>( &self, table_names: Vec<String>, operation: F, ) -> IntrospectionResult

where F: Fn(String) -> Fut + Clone + Send + 'static, Fut: Future<Output = Result<TableMetadata, String>> + Send + 'static,

Introspect tables with associated names for error tracking.

pub fn config(&self) -> &IntrospectionConfig

Get the configuration.