bus

Documentation

Overview

Package bus is a lightweight publish-subscribe message bus. It decouples components by letting them communicate through typed topics instead of direct method calls. Thread-safe; zero allocations on the publish path when there are no subscribers for a topic.

Index

• type Bus
  • func New() *Bus
  • func (b *Bus) Pub(topic string, msg Msg)
  • func (b *Bus) Sub(topic string, fn Handler) (stop func())
  • func (b *Bus) SubscriberCount() int
  • func (b *Bus) Topics() []string
• type Handler
• type Msg

Types

type Bus

type Bus struct {
	// contains filtered or unexported fields
}

func New

func New() *Bus

func (*Bus) Pub

func (b *Bus) Pub(topic string, msg Msg)

func (*Bus) Sub

func (b *Bus) Sub(topic string, fn Handler) (stop func())

func (*Bus) SubscriberCount

func (b *Bus) SubscriberCount() int

func (*Bus) Topics

func (b *Bus) Topics() []string

type Handler

type Handler func(topic string, msg Msg)

type Msg

type Msg = any