messagebroker

Documentation

Index

• type Config
• type Message
• type MessageBroker
  • func New(c Config) (MessageBroker, error)

Types

type Config

type Config struct {
	URL string
}

Config configuration to start MessageBroker

type Message

type Message struct {
	Payload []byte
}

Message message being sent or received

type MessageBroker

type MessageBroker interface {
	// Publish publishes message to the topic
	Publish(topic string, message ...Message) error
	// Subscribe subscribes to a chanel mesagges of topic
	Subscribe(topic string) (chan Message, error)
	// Close end MessageBroker
	Close()
}

MessageBroker is the interface to publish, consume messages

func New

func New(c Config) (MessageBroker, error)

New returns a new MessageBroker