utils

Documentation

Index

• Constants
• type MessageHandler
• type PubSub
• type Publisher
• type Subscriber

Constants

const (
	NL = "\n"
)

Types

type MessageHandler

type MessageHandler func(msg []byte) error

MessageHandler represents Message handler for Subscriber.

type PubSub

type PubSub interface {
	Publisher
	Subscriber
}

PubSub represents aggregation interface for publisher and subscriber.

type Publisher

type Publisher interface {
	// Publishes message to the stream.
	Publish(topic, subtopic string, msg []byte) error
}

Publisher specifies message publishing API.

type Subscriber

type Subscriber interface {
	// Subscribe subscribes to the message stream and consumes messages.
	Subscribe(topic string, handler MessageHandler) error

	// Unsubscribe unsubscribes from the message stream and
	// stops consuming messages.
	Unsubscribe(topic string) error
}

Subscriber specifies message subscription API.