pubsub

Documentation

Index

• type Pubsub
  • func New() *Pubsub
  • func (ps *Pubsub) Close() error
  • func (ps *Pubsub) Publish(topic string, msg string)
  • func (ps *Pubsub) Subscribe(topic, id string, ch chan string)
  • func (ps *Pubsub) Unsubscribe(topic, id string)

Types

type Pubsub

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

func New

func New() *Pubsub

func (*Pubsub) Close

func (ps *Pubsub) Close() error

func (*Pubsub) Publish

func (ps *Pubsub) Publish(topic string, msg string)

func (*Pubsub) Subscribe

func (ps *Pubsub) Subscribe(topic, id string, ch chan string)

func (*Pubsub) Unsubscribe

func (ps *Pubsub) Unsubscribe(topic, id string)