README
¶
Modulex NATS EventBus Adapter
This package provides a modulex.EventBus implementation backed by
NATS.
Usage
import (
"github.com/nats-io/nats.go"
natsadapter "github.com/mediusfy/modulex/nats"
)
conn, err := nats.Connect(nats.DefaultURL)
if err != nil {
return err
}
defer conn.Close()
eb := natsadapter.NewEventBus(conn)
manager, err := modulex.NewManager(modulex.WithEventBus(eb), modulex.WithLogger(logger))
if err != nil {
return err
}
Behavior
Publishmaps directly toconn.Publish(topic, payload).Subscribecreates a NATS subscription and adapts incoming messages to the genericmodulex.EventHandlersignature.Closeunsubscribes all registered subscriptions.
Testing
The adapter tests start an embedded NATS server using
github.com/nats-io/nats-server/v2/test. Run them with:
go test ./nats/...
Documentation
¶
Overview ¶
Package nats provides a Modulex EventBus adapter backed by NATS.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventBus ¶
type EventBus struct {
// contains filtered or unexported fields
}
EventBus implements modulex.EventBus by wrapping a concrete NATS connection.
func NewEventBus ¶
NewEventBus instantiates the NATS event bus driver.
The EventBus does not take ownership of conn: the caller creates and closes the underlying *nats.Conn, typically after modulex.Manager.StopModules has closed the EventBus. This lets a single connection be shared across multiple concerns outside the module lifecycle if desired.
func (*EventBus) Close ¶
Close implements modulex.EventBus. It unsubscribes all registered NATS subscriptions but does not close the underlying *nats.Conn, which the caller owns.
func (*EventBus) Subscribe ¶
Subscribe implements modulex.EventBus. It registers a NATS subscription, adapting the incoming message to the generic EventHandler signature.
The subscriber's context is propagated into the handler. If the incoming NATS message carries W3C trace context headers, they are extracted and merged so OpenTelemetry span continuity is preserved across the broker.
Source Files