pubsub

Documentation

Index

• type Pubsub
  • func NewPubsub() *Pubsub
  • func (ps *Pubsub) Close()
  • func (ps *Pubsub) Publish(topic string, msg string)
  • func (ps *Pubsub) Subscribe(topic string) chan string

Types

type Pubsub

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

func NewPubsub

func NewPubsub() *Pubsub

func (*Pubsub) Close

func (ps *Pubsub) Close()

func (*Pubsub) Publish

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

publishing

func (*Pubsub) Subscribe

func (ps *Pubsub) Subscribe(topic string) chan string

subscribing