broker

package
v0.0.0-...-07ad8dd Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 5, 2018 License: BSD-2-Clause Imports: 6 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.