memory

Documentation

Index

• type Broker
  • func New(logger *log.Logger, queueSize int) *Broker
  • func (b *Broker) Close() error
  • func (b *Broker) Publish(ctx context.Context, event broker.Publishable) error
  • func (b *Broker) StartConsumer(handlers map[string]func([]byte) error, ...) error

Types

type Broker

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

func New

func New(logger *log.Logger, queueSize int) *Broker

New allocates and returns an in-memory Broker with provided queue size.

func (*Broker) Close

func (b *Broker) Close() error

func (*Broker) Publish

func (b *Broker) Publish(ctx context.Context, event broker.Publishable) error

func (*Broker) StartConsumer

func (b *Broker) StartConsumer(handlers map[string]func([]byte) error, errorHandler func(msgType string, msgBody []byte, err error)) error