broker

Documentation

Index

• type Broker
  • func (b *Broker) Close() error
  • func (b *Broker) Consume(queue, exchange, exchangeKing string, ...)
  • func (b *Broker) IsAvailable() bool
  • func (b *Broker) Publish(queue, exchange, exchangeKind string, body []byte) error
• type IBroker
  • func NewBroker(config brokerConfig.IConfig) (IBroker, error)
• type Mock
  • func (m *Mock) Close() error
  • func (m *Mock) Consume(queue, exchange, exchangeKind string, ...)
  • func (m *Mock) IsAvailable() bool
  • func (m *Mock) Publish(queue, exchange, exchangeKind string, body []byte) error

Types

type Broker

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

func (*Broker) Close

func (b *Broker) Close() error

func (*Broker) Consume

func (b *Broker) Consume(queue, exchange, exchangeKing string, handler func(packet brokerPacket.IPacket))

func (*Broker) IsAvailable

func (b *Broker) IsAvailable() bool

func (*Broker) Publish

func (b *Broker) Publish(queue, exchange, exchangeKind string, body []byte) error

type IBroker

type IBroker interface {
	IsAvailable() bool
	Consume(queue, exchange, exchangeKind string, handler func(packet brokerPacket.IPacket))
	Publish(queue, exchange, exchangeKind string, body []byte) error
	Close() error
}

func NewBroker

func NewBroker(config brokerConfig.IConfig) (IBroker, error)

type Mock

type Mock struct {
	mock.Mock
}

func (*Mock) Close

func (m *Mock) Close() error

func (*Mock) Consume

func (m *Mock) Consume(queue, exchange, exchangeKind string, handler func(packet brokerPacket.IPacket))

func (*Mock) IsAvailable

func (m *Mock) IsAvailable() bool

func (*Mock) Publish

func (m *Mock) Publish(queue, exchange, exchangeKind string, body []byte) error