event

Documentation

Overview

Package event provides event system definition and data event types.

Package event provides Watermill-based publish/subscribe infrastructure backed by Redis Streams.

Index

• Variables
• func BotEventFire(ctx types.Context, eventName string, param types.KV, pub message.Publisher) error
• func NewMessage(payload any) (*message.Message, error)
• func NewPublisher(lc fx.Lifecycle, client *redis.Client) (message.Publisher, error)
• func NewRouter(_ *sdktrace.TracerProvider) (*message.Router, error)
• func NewSubscriber(lc fx.Lifecycle, client *redis.Client) (message.Subscriber, error)
• func PublishMessage(ctx context.Context, topic string, payload any) error
• func SendMessage(ctx types.Context, msg types.MsgPayload, pub message.Publisher) error
• func TraceConsumerMiddleware() message.HandlerMiddleware

Variables

var Publisher message.Publisher

Publisher is the global Watermill publisher, provided by NewPublisher via fx.

Functions

func BotEventFire

func BotEventFire(ctx types.Context, eventName string, param types.KV, pub message.Publisher) error

BotEventFire publishes a bot-run event to the event bus, triggering any subscribed pipeline handlers.

func NewMessage

func NewMessage(payload any) (*message.Message, error)

NewMessage creates a Watermill message from the given payload, marshaled as JSON.

func NewPublisher

func NewPublisher(lc fx.Lifecycle, client *redis.Client) (message.Publisher, error)

NewPublisher creates a Watermill Redis Stream publisher using the shared Redis client.

func NewRouter

func NewRouter(_ *sdktrace.TracerProvider) (*message.Router, error)

NewRouter creates a Watermill message router with standard middleware.

func NewSubscriber

func NewSubscriber(lc fx.Lifecycle, client *redis.Client) (message.Subscriber, error)

NewSubscriber creates a Watermill Redis Stream subscriber using the shared Redis client.

func PublishMessage

func PublishMessage(ctx context.Context, topic string, payload any) error

PublishMessage publishes a message to the given topic using the global Publisher, with OpenTelemetry tracing.

func SendMessage

func SendMessage(ctx types.Context, msg types.MsgPayload, pub message.Publisher) error

SendMessage delivers a message payload to the user's channels, scoped to a specific topic when ctx.Topic is set, or broadcast to all channels the user is a member of.

func TraceConsumerMiddleware

func TraceConsumerMiddleware() message.HandlerMiddleware

TraceConsumerMiddleware returns a Watermill middleware that extracts OTel trace context from message metadata and creates a consumer span for each incoming message.