Struct IntrospectionClient 

pub struct IntrospectionClient<'a> {
    pub(crate) client: &'a Client,
}

Domain sub-client for metadata and object introspection operations.

Fields

client: &'a Client

Implementations

impl IntrospectionClient<'_>

pub async fn get_current_user(&self) -> Result<String, ConnectionError>

Get the current Materialize user/role.

pub async fn check_objects_exist( &self, objects: &BTreeSet<ObjectId>, ) -> Result<BTreeSet<ObjectId>, ConnectionError>

Check which objects from a set exist in the production database.

pub async fn check_catalog_objects_exist( &self, objects: &BTreeSet<ObjectId>, catalog_table: &str, ) -> Result<BTreeSet<ObjectId>, ConnectionError>

Check which objects from a set exist in a specific catalog table.

pub async fn check_tables_exist( &self, tables: &BTreeSet<ObjectId>, ) -> Result<BTreeSet<ObjectId>, ConnectionError>

Check which tables from the given set exist in the database.

pub async fn check_sources_exist( &self, sources: &BTreeSet<ObjectId>, ) -> Result<BTreeSet<ObjectId>, ConnectionError>

Check which sources from the given set exist in the database.

pub async fn check_secrets_exist( &self, secrets: &BTreeSet<ObjectId>, ) -> Result<BTreeSet<ObjectId>, ConnectionError>

Check which secrets from the given set exist in the database.

pub async fn check_connections_exist( &self, connections: &BTreeSet<ObjectId>, ) -> Result<BTreeSet<ObjectId>, ConnectionError>

Check which connections from the given set exist in the database.

pub async fn check_sinks_exist( &self, sinks: &BTreeSet<ObjectId>, ) -> Result<BTreeSet<ObjectId>, ConnectionError>

Check which sinks from the given set exist in the database.

pub async fn check_schemas_exist( &self, schemas: &[(String, String)], ) -> Result<BTreeSet<(String, String)>, ConnectionError>

Check which schemas from a set of (database, schema) pairs exist.

pub async fn check_clusters_exist( &self, clusters: &[String], ) -> Result<BTreeSet<String>, ConnectionError>

Check which clusters from a set of names exist.

pub async fn find_sinks_depending_on_schemas( &self, schemas: &[SchemaQualifier], ) -> Result<Vec<DependentSink>, ConnectionError>

Find sinks that depend on objects in the specified schemas.

pub async fn check_connection_exists( &self, database: &str, schema: &str, name: &str, ) -> Result<bool, ConnectionError>

Check if a connection exists in the specified database and schema.

pub async fn object_exists( &self, database: &str, schema: &str, object: &str, ) -> Result<bool, ConnectionError>

Check if an object (MV, table, source) exists in the specified schema.

pub async fn get_staging_schemas( &self, deploy_id: &str, ) -> Result<Vec<SchemaQualifier>, ConnectionError>

Get staging schema names for a specific deployment.

pub async fn get_staging_clusters( &self, deploy_id: &str, ) -> Result<Vec<String>, ConnectionError>

Get staging cluster names for a specific deployment.

pub async fn drop_schema_objects( &self, database: &str, schema: &str, ) -> Result<Vec<String>, ConnectionError>

Drop all objects in a schema.

pub async fn drop_objects( &self, objects: &BTreeSet<ObjectId>, ) -> Result<Vec<String>, ConnectionError>

Drop specific objects by their ObjectIds.

pub async fn drop_staging_schemas( &self, schemas: &[SchemaQualifier], ) -> Result<(), ConnectionError>

Drop staging schemas by name.

pub async fn drop_staging_clusters( &self, clusters: &[String], ) -> Result<(), ConnectionError>

Drop staging clusters by name.

pub async fn schema_exists( &self, database: &str, schema: &str, ) -> Result<bool, ConnectionError>

Check if a schema exists in the specified database.

pub async fn network_policy_exists( &self, name: &str, ) -> Result<bool, ConnectionError>

Check if a network policy exists.

pub async fn role_exists(&self, name: &str) -> Result<bool, ConnectionError>

Check if a role exists.

pub async fn get_role_members( &self, name: &str, ) -> Result<Vec<String>, ConnectionError>

Get the members granted to a role.

pub async fn get_role_parameters( &self, name: &str, ) -> Result<Vec<String>, ConnectionError>

Get session default parameter names for a role.

pub async fn cluster_exists(&self, name: &str) -> Result<bool, ConnectionError>

Check if a cluster exists.

pub async fn get_cluster( &self, name: &str, ) -> Result<Option<Cluster>, ConnectionError>

Get a cluster by name.

pub async fn list_clusters(&self) -> Result<Vec<Cluster>, ConnectionError>

List all clusters.

pub async fn get_cluster_config( &self, name: &str, ) -> Result<Option<ClusterConfig>, ConnectionError>

Get cluster configuration including replicas and grants.

pub async fn get_cluster_grants( &self, name: &str, ) -> Result<Vec<ObjectGrant>, ConnectionError>

Get privilege grants on a cluster by name.

pub async fn get_network_policy_grants( &self, name: &str, ) -> Result<Vec<ObjectGrant>, ConnectionError>

Get privilege grants on a network policy by name.

pub async fn get_database_object_grants( &self, catalog_table: &str, database: &str, schema: &str, name: &str, ) -> Result<Vec<ObjectGrant>, ConnectionError>

Get privilege grants on a database object.

pub async fn get_connection_create_sql( &self, database: &str, schema: &str, name: &str, ) -> Result<Option<String>, ConnectionError>

Get the CREATE CONNECTION SQL for an existing connection.

pub async fn get_default_privilege_grants_for_cluster( &self, name: &str, ) -> Result<Vec<ObjectGrant>, ConnectionError>

Get default privilege grants for a cluster by name.

pub async fn get_default_privilege_grants_for_network_policy( &self, name: &str, ) -> Result<Vec<ObjectGrant>, ConnectionError>

Get default privilege grants for a network policy by name.

pub async fn get_default_privilege_grants_for_database_object( &self, catalog_table: &str, database: &str, schema: &str, name: &str, object_type: &str, ) -> Result<Vec<ObjectGrant>, ConnectionError>

Get default privilege grants for a database object.