bus

Documentation

Index

• type Bus
  • func New() *Bus
  • func (b *Bus) Publish(msg *protocol.Message) error
  • func (b *Bus) Register(id string, ch chan *protocol.Message) error
  • func (b *Bus) Retrieve() <-chan *protocol.Message
  • func (b *Bus) Start()
  • func (b *Bus) Stop()
  • func (b *Bus) Unregister(id string)
• type Reader
• type Writer

Types

type Bus

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

Bus struct

func New

func New() *Bus

New Bus struct

func (*Bus) Publish

func (b *Bus) Publish(msg *protocol.Message) error

Publish msg to bus

func (*Bus) Register

func (b *Bus) Register(id string, ch chan *protocol.Message) error

Register receiver

func (*Bus) Retrieve

func (b *Bus) Retrieve() <-chan *protocol.Message

Retrieve msg from bus

func (*Bus) Start

func (b *Bus) Start()

func (*Bus) Stop

func (b *Bus) Stop()

func (*Bus) Unregister

func (b *Bus) Unregister(id string)

Unregister receiver

type Reader

type Reader interface {
	Retrieve() <-chan *protocol.Message
}

Reader interface

type Writer

type Writer interface {
	Publish(msg *protocol.Message) error
}

Writer interface