broker

Documentation

Index

• func New(addr string) model.Broker
• type AsyncBroker
  • func NewAsyncBroker(addr string) *AsyncBroker
  • func (b *AsyncBroker) Close()
  • func (b *AsyncBroker) Do(req model.Request, resp model.Response) error

Functions

func New

func New(addr string) model.Broker

Types

type AsyncBroker

type AsyncBroker struct {
	Timeout  time.Duration
	QueueLen int
	Addr     string
	// contains filtered or unexported fields
}

func NewAsyncBroker

func NewAsyncBroker(addr string) *AsyncBroker

func (*AsyncBroker) Close

func (b *AsyncBroker) Close()

func (*AsyncBroker) Do

func (b *AsyncBroker) Do(req model.Request, resp model.Response) error