mz_postgres_util::schemas

Function publication_info

Source
pub async fn publication_info(
    client: &Client,
    publication: &str,
    oids: Option<&[Oid]>,
) -> Result<BTreeMap<Oid, 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. Returns a map from table OID to table schema information.

The oids parameter controls for which tables to fetch schema information. If None, schema information for all tables in the publication is fetched. If Some, only schema information for the tables with the specified OIDs is fetched.

§Errors

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