broker

Documentation

Overview

Package broker provides support for message broker.

Index

• type Message
• type MessageBroker
• type MessageContext

Types

type Message

type Message struct {
	Topic   string         // message topic
	Value   interface{}    // message value - typically JSON payload
	Context MessageContext // message context
}

Message represents structure which will be passed to message broker.

type MessageBroker

type MessageBroker interface {
	PublishMessage(ctx context.Context, message Message) error
	Subscribe(ctx context.Context, key string) (<-chan Message, error)

	system.Disposer
}

MessageBroker represents pub/sub mechanism.

type MessageContext

type MessageContext map[string]interface{}

MessageContext represents context which is passed with a message.