broker

Documentation

Index

• Constants
• type Broker
  • func NewBroker[T any]() *Broker[T]
  • func (b *Broker[T]) Publish(msg *T)
  • func (b *Broker[T]) Subscribe() chan *T
  • func (b *Broker[T]) Unsubscribe(msgCh chan *T)

Constants

const MaxChannelSize = 512

Types

type Broker

type Broker[T any] struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewBroker

func NewBroker[T any]() *Broker[T]

func (*Broker[T]) Publish

func (b *Broker[T]) Publish(msg *T)

func (*Broker[T]) Subscribe

func (b *Broker[T]) Subscribe() chan *T

func (*Broker[T]) Unsubscribe

func (b *Broker[T]) Unsubscribe(msgCh chan *T)