PostgresEventBridge

PostgresEventBridge stores event payloads in a Postgres table and uses LISTEN/NOTIFY for low-latency fanout.

Go support

Go
Rust

PostgresEventBridge is not implemented in abxbus-go yet. Use JSONLEventBridge for the currently supported Go bridge.

// Not implemented in the Rust crate yet.
// Use typed event JSON serialization with an external transport for now.

Optional dependencies

Python
TypeScript
Go
Rust

Install the Postgres extra (recommended):

pip install "abxbus[postgres]"

Equivalent direct dependency install:

pip install asyncpg

Install the Postgres client package:

npm install abxbus pg

This bridge is Node.js-only.

// PostgresEventBridge is not implemented in abxbus-go yet.
// Use JSONLEventBridge for the currently supported Go bridge.

// Not implemented in the Rust crate yet.
// Use typed events plus EventBus JSON serialization with an external transport for now.

Constructor params

table_url: postgresql://user:pass@host:5432/dbname[/tablename]?...
channel: optional notify/listen channel (defaults to abxbus_events)
name: optional bridge label

Python
TypeScript
Go
Rust

from abxbus.bridges import PostgresEventBridge

bridge = PostgresEventBridge(
    'postgresql://user:pass@localhost:5432/mydb/abxbus_events',
    channel='abxbus_events',
    name='PgBridge',
)

import { PostgresEventBridge } from 'abxbus/bridges'

const bridge = new PostgresEventBridge(
  'postgresql://user:pass@localhost:5432/mydb/abxbus_events',
  'abxbus_events',
  'PgBridge'
)

// PostgresEventBridge is not implemented in abxbus-go yet.
// Use JSONLEventBridge for Go process-to-process bridge tests and deployments.

// Not implemented in the Rust crate yet.
// Use typed events plus EventBus JSON serialization with an external transport for now.

Setup with a bus

Python
TypeScript
Go
Rust

from abxbus import EventBus
from abxbus.bridges import PostgresEventBridge

bus = EventBus('AppBus')
bridge = PostgresEventBridge('postgresql://user:pass@localhost:5432/mydb/abxbus_events')

bus.on('*', bridge.emit)
bridge.on('*', bus.emit)

import { EventBus } from 'abxbus'
import { PostgresEventBridge } from 'abxbus/bridges'

const bus = new EventBus('AppBus')
const bridge = new PostgresEventBridge('postgresql://user:pass@localhost:5432/mydb/abxbus_events')

bus.on('*', bridge.emit)
bridge.on('*', bus.emit)

// PostgresEventBridge is not implemented in abxbus-go yet.
// Use JSONLEventBridge for Go process-to-process bridge tests and deployments.

// Not implemented in the Rust crate yet.
// Use typed events plus EventBus JSON serialization with an external transport for now.

Behavior

emit(...) upserts event payload data into the bridge table, then sends NOTIFY with the event id.
on(...) registers inbound handlers and auto-starts listener startup.
On notifications, the bridge fetches the full row payload, reconstructs an event, resets it, and emits locally.
Columns are created on demand only for event_* fields.
The full event JSON is stored in event_payload (not just non-event_* fields).
event_* columns are also stored as flat mirrored fields for indexing/querying.
Rehydration merges event_payload with event_* column values back into a flat event object.
Runtime requirements: Python needs asyncpg, TypeScript needs pg and Node.js.

Getting Started

Features

API Reference

Concurrency Control

Integrations

Further Reading

PostgresEventBridge

Go support

Optional dependencies

Constructor params

Setup with a bus

Behavior

​Go support

​Optional dependencies

​Constructor params

​Setup with a bus

​Behavior

Go support

Optional dependencies

Constructor params

Setup with a bus

Behavior