channelpubsub

Documentation

Index

• type Pubsub
  • func NewPubsub() *Pubsub
  • func (ps *Pubsub) Close()
  • func (ps *Pubsub) Publish(topic string, msg exports.StoredEvent)
  • func (ps *Pubsub) Subscribe(topic string) <-chan exports.StoredEvent

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 exports.StoredEvent)

func (*Pubsub) Subscribe

func (ps *Pubsub) Subscribe(topic string) <-chan exports.StoredEvent