integrationspackages/integrations/event-bus

event-bus package

In-process pub/sub with cross-app fanout. Used by audit, billing, and notifications to react to commerce events without circular imports.

Open docs

Stability: Stable
Scope: Global
Boundary: packages/integrations/event-bus
Owners: @nebutra/integrations

event-buspackages/integrations/event-bus

Provider-agnostic

Available providers

NATSstandby

KafkaActive

Inngeststandby

Inbound requestevent-bus

{ topic: "orders.created", v: 1 }

Adapter resolve3ms

event-bus Dispatch100ms

Acked2ms

x

Provider

Kafka

Latency p50

110 ms

Success rate

98%

+0.7%

Volume today

6,028

packages/integrations/event-busprovider-agnostic

Usageevent-bus.ts

typescript

event-bus.ts

1import { getEventBusProvider } from "@nebutra/event-bus";
2
3// Provider-agnostic — backend chosen from env at runtime.
4const eventBus = await getEventBusProvider();
5
6await eventBus.connect({ tenantId: org.id });

More in domain · integrationsView domain

admin-toolingPackage

packages/integrations/admin-tooling

Self-serve operator dashboards — tenants, billing overrides, feature-flag flips — all gated by @nebutra/permissions.

Explore

cachePackage

packages/integrations/cache

Tag-based cache with Redis, Upstash, or in-memory backend. Same get/set/invalidate(tags) for serverless and self-hosted.

Explore

collabPackage

packages/integrations/collab

Realtime co-editing primitives — Yjs CRDT, WebSocket transport, presence cursors. The piece every multi-user app eventually needs.

Explore

emailPackage

packages/integrations/email

Render React Email templates, dispatch through Resend / SES / SMTP. One sendEmail(template, props, recipient) for every transactional flow.

Explore

event-bus packagepackage

event-bus packagepackage

event-bus package

event-bus package