bus

Documentation

Index

• type Bus
  • func New(bufSize int) *Bus
  • func (b *Bus) Publish(eventType string, properties any)
  • func (b *Bus) SubscribeAll() <-chan Event
  • func (b *Bus) Unsubscribe(ch <-chan Event)
• type Event

Types

type Bus

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

func New

func New(bufSize int) *Bus

func (*Bus) Publish

func (b *Bus) Publish(eventType string, properties any)

func (*Bus) SubscribeAll

func (b *Bus) SubscribeAll() <-chan Event

func (*Bus) Unsubscribe

func (b *Bus) Unsubscribe(ch <-chan Event)

type Event

type Event struct {
	Type       string          `json:"type"`
	Properties json.RawMessage `json:"properties"`
}