pubsub

Documentation

Index

• func Discard() *discarder
• type Client
• type Memory
  • func New() *Memory
  • func (m *Memory) Publish(topic string, data []byte)
  • func (m *Memory) Subscribe(topics ...string) Subscription
• type Publisher
• type Subscriber
• type Subscription

Functions

func Discard

func Discard() *discarder

Types

type Client

type Client interface {
	Publisher
	Subscriber
}

type Memory

type Memory struct {
	// contains filtered or unexported fields
}

func New

func New() *Memory

func (*Memory) Publish

func (m *Memory) Publish(topic string, data []byte)

func (*Memory) Subscribe

func (m *Memory) Subscribe(topics ...string) Subscription

type Publisher

type Publisher interface {
	Publish(topic string, data []byte)
}

type Subscriber

type Subscriber interface {
	Subscribe(topics ...string) Subscription
}

type Subscription

type Subscription interface {
	Wait() <-chan []byte
	Close()
}