broker

Documentation

Index

• type BackToBack
  • func NewBackToBack(registry metrics.Registry) *BackToBack
  • func (btb *BackToBack) ClientWorkerConsumer(c net.Conn)
  • func (btb *BackToBack) ClientWorkerProducer(c net.Conn)
  • func (btb *BackToBack) GetRegistry() metrics.Registry
  • func (btb *BackToBack) Listen(listener net.Listener, worker func(net.Conn))
  • func (btb *BackToBack) PrintStatsEvery(n int, l metrics.Logger)
• type MessageAndReply
• type Topic

Types

type BackToBack

type BackToBack struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewBackToBack

func NewBackToBack(registry metrics.Registry) *BackToBack

func (*BackToBack) ClientWorkerConsumer

func (btb *BackToBack) ClientWorkerConsumer(c net.Conn)

func (*BackToBack) ClientWorkerProducer

func (btb *BackToBack) ClientWorkerProducer(c net.Conn)

func (*BackToBack) GetRegistry

func (btb *BackToBack) GetRegistry() metrics.Registry

func (*BackToBack) Listen

func (btb *BackToBack) Listen(listener net.Listener, worker func(net.Conn))

func (*BackToBack) PrintStatsEvery

func (btb *BackToBack) PrintStatsEvery(n int, l metrics.Logger)

type MessageAndReply

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

type Topic

type Topic struct {
	sync.RWMutex
	// contains filtered or unexported fields
}