Overview - abxbus

Bridges are optional connectors for forwarding serialized events between buses in different processes or machines. All bridges expose the same minimal surface:

emit(...) for outbound forwarding
on(...) for inbound subscription
start() and close() for lifecycle control

Quick setup

Python
TypeScript
Go
Rust

from abxbus import EventBus
from abxbus.bridges import RedisEventBridge

bus = EventBus('AppBus')
bridge = RedisEventBridge('redis://localhost:6379/0/abxbus_events')

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

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

const bus = new EventBus('AppBus')
const bridge = new RedisEventBridge('redis://localhost:6379/0/abxbus_events')

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

bus := abxbus.NewEventBus("AppBus", nil)
bridge := abxbus.NewJSONLEventBridge("/tmp/abxbus_events.jsonl", 0.25, "JsonlBridge")

bus.OnEventName("*", "jsonl_emit", func(event *abxbus.BaseEvent) (any, error) {
	return bridge.Emit(event)
}, nil)
bridge.OnEventName("*", "bus_emit", func(event *abxbus.BaseEvent) (any, error) {
	return bus.Emit(event), nil
}, nil)

Go currently implements JSONLEventBridge. The HTTP, socket, Redis, NATS, Postgres, SQLite, and Tachyon bridges are Python/TypeScript-only for now.

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

Bridge pages