Skip to main content

migrate_outbox

Function migrate_outbox 

Source
pub async fn migrate_outbox(pool: &PgPool, schema: &str) -> Result<()>
Expand description

Create the outbox and inbox tables of schema (idempotent), where the events its hooks stage are written. The composing service runs it at startup, with a role that may create tables; the generated module offers it for each schema it stages in (declared::migrate_outbox).