SocketEventBridge - abxbus

SocketEventBridge uses a Unix socket path for both send and listen directions.

Go support

Go
Rust

SocketEventBridge 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.

Constructor params

path: Unix socket path (absolute path recommended)
name: optional bridge label

Python
TypeScript
Go
Rust

from abxbus.bridges import SocketEventBridge

bridge = SocketEventBridge('/tmp/abxbus_events.sock', name='SocketBridge')

import { SocketEventBridge } from 'abxbus/bridges'

const bridge = new SocketEventBridge('/tmp/abxbus_events.sock', 'SocketBridge')

// SocketEventBridge 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 SocketEventBridge

bus = EventBus('AppBus')
bridge = SocketEventBridge('/tmp/abxbus_events.sock')

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

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

const bus = new EventBus('AppBus')
const bridge = new SocketEventBridge('/tmp/abxbus_events.sock')

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

// SocketEventBridge 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(...) writes newline-delimited event JSON frames to the Unix socket.
on(...) subscribes handlers on the inbound side and auto-starts the socket listener.
Incoming frames are decoded into events, reset, then emitted on the internal bus.
close() stops the socket server and tears down the internal bus.
TypeScript socket bridges require Node.js runtime support for Unix sockets.

HTTPEventBridge

RedisEventBridge