pubsub

Documentation

Index

• type Message
  • func NewMessage(msg []byte, topic string) *Message
  • func (m *Message) Payload() []byte
  • func (m *Message) Topic() string
• type PubSub
  • func NewPubSub() *PubSub
  • func (b *PubSub) Publish(topic string, msg []byte)
  • func (b *PubSub) Subscribe(topic string) *Subscriber
  • func (b *PubSub) Unsubscribe(s *Subscriber, topic string)
• type Subscriber
  • func NewSubscriber() *Subscriber
  • func (s *Subscriber) Close()
  • func (s *Subscriber) GetMessages() <-chan *Message
• type Subscribers

Types

type Message

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

func NewMessage

func NewMessage(msg []byte, topic string) *Message

func (*Message) Payload

func (m *Message) Payload() []byte

func (*Message) Topic

func (m *Message) Topic() string

type PubSub

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

func NewPubSub

func NewPubSub() *PubSub

func (*PubSub) Publish

func (b *PubSub) Publish(topic string, msg []byte)

func (*PubSub) Subscribe

func (b *PubSub) Subscribe(topic string) *Subscriber

func (*PubSub) Unsubscribe

func (b *PubSub) Unsubscribe(s *Subscriber, topic string)

type Subscriber

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

func NewSubscriber

func NewSubscriber() *Subscriber

func (*Subscriber) Close

func (s *Subscriber) Close()

func (*Subscriber) GetMessages

func (s *Subscriber) GetMessages() <-chan *Message

type Subscribers

type Subscribers map[string]*Subscriber