bus

package

v0.0.0-...-ac7f640 Latest Latest Go to latest Published: Jul 24, 2017 License: Apache-2.0 Imports: 1 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type BroadcastPublisher interface {
	Broadcaster
	Publisher
}

BroadcastPublisher use when you need to publish & broadcast.

type Broadcaster interface {
	Broadcast(exchange, routingKey string, msg []byte) error
}

Broadcaster is an interface for broadcasting a message over a fanout channel. in other words, over rabbit's fanout exchange.

type Broker struct {
	AmqpURL string
}

Broker wraps a rabbitmq functionality. It implements the publisher and broadcaster interfaces.

func NewBroker(AmqpURL string) *Broker

NewBroker takes a rabbitmq host url and returns a broker struct

func (b *Broker) Broadcast(exName, routingKey string, msg []byte) (err error)

Broadcast sends a message to a rabbitmq fanout exchange.

func (b *Broker) Publish(qName string, msg []byte) (err error)

Publish sends a message to a rabbitmq server with default settings

type MockBroker struct {
}

MockBroker implements the publisher/consumer interface but does nothing

func (m MockBroker) Broadcast(exName string, msg []byte) error

Broadcast satisfies the broadcaster interface. Does nothing.

func (m MockBroker) Publish(qName string, msg []byte) error

Publish satisfies the publisher interface. does nothing. Does nothing.

type Publisher interface {
	Publish(qName string, body []byte) error
}

Publisher wraps a message bus publish. In our case, rabbitmq's channel.Publish method.