Function mz_postgres_util::schemas::publication_info

source ·
pub async fn publication_info(
    client: &Client,
    publication: &str,
) -> Result<Vec<PostgresTableDesc>, PostgresError>
Expand description

Fetches table schema information from an upstream Postgres source for tables that are part of a publication, given a connection string and the publication name.

§Errors

  • Invalid connection string, user information, or user permissions.
  • Upstream publication does not exist or contains invalid values.