broker

Documentation

Index

• Constants
• Variables
• type Broker
  • func NewBroker(host string, port int, showStatus bool) (Broker, error)
  • func (b *Broker) Start()
• type Queue
  • func NewQueue(name string) Queue
  • func (q *Queue) Pop() (*transport.Message, error)
  • func (q *Queue) Push(msg transport.Message) error

Constants

const (
	DefaultHost = "localhost"
	DefaultPort = 4242
)

Variables

var (
	ErrEmptyQueue = errors.New("The queue is empty.")
)

Types

type Broker

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

func NewBroker

func NewBroker(host string, port int, showStatus bool) (Broker, error)

func (*Broker) Start

func (b *Broker) Start()

type Queue

type Queue struct {
	Name string
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue(name string) Queue

func (*Queue) Pop

func (q *Queue) Pop() (*transport.Message, error)

func (*Queue) Push

func (q *Queue) Push(msg transport.Message) error