broker

Documentation

Index

• Constants
• Variables
• type Broker
• type Mux
  • func NewMux(targetKey string) (*Mux, error)
  • func (mb *Mux) AddBroker(value string, b Broker)
  • func (mb Mux) Publish(ctx context.Context, msg messenger.Message) error

Constants

const MessageIDKey = "message_id"

MessageIDKey defines the key that will be send the message unique identifier.

Variables

var (
	ErrEmptyTarMetadataKey            = errors.New("empty target metadata key")
	ErrMessageDoesNotMatchWithBrokers = errors.New("message does not match with any broker")
)

Errors ...

Types

type Broker

type Broker interface {
	messenger.Publisher
}

Broker is the interface that wraps the basic message publishing.

type Mux

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

Mux contains multiple brokers and a metadata key to allow route messages depending on the metadata value of the message.

func NewMux

func NewMux(targetKey string) (*Mux, error)

NewMux returns an empty Mux target, if the targetKey is empty it returns ErrEmptyTarMetadataKey error.

func (*Mux) AddBroker

func (mb *Mux) AddBroker(value string, b Broker)

AddBroker registers the broker with the value filter.

func (Mux) Publish

func (mb Mux) Publish(ctx context.Context, msg messenger.Message) error

Publish routes the message to a broker depending if it matches the metadata key and metadata value. It it does not match it returns an error.