broker

Documentation

Index

• type Broker
• type Handler
• type Message
• type Options
• type Subscriber

Types

type Broker

type Broker interface {
	Publish(string, Message) error
	Subscribe(string) (Subscriber, error)
}

type Handler

type Handler func(Message) error

type Message

type Message interface {
	Topic() string
	Timestamp() int64
}

type Options

type Options struct {
}

type Subscriber

type Subscriber interface {
	Unsubscribe() error
	Next() (Message, error)
}