broker

Documentation

Index

• func Publish(topic string, msg interface{})
• func Subscribe(topic string, handler Handler)
• type Broker
  • func NewLocalBroker() Broker
• type Handler
• type Publication

Functions

func Publish

func Publish(topic string, msg interface{})

func Subscribe

func Subscribe(topic string, handler Handler)

Types

type Broker

type Broker interface {
	Publish(topic string, msg interface{})
	Subscribe(topic string, handler Handler)
}

var (
	Default Broker
)

func NewLocalBroker

func NewLocalBroker() Broker

type Handler

type Handler func(Publication)

type Publication

type Publication interface {
	Topic() string
	Message() interface{}
}