tinypubsub

README

This is a tiny implementation of PubSub. It is mainly used for testing, but if you want to build a monolith application, and skip 3:rd party message queues, then you could hook this up.

Documentation

Index

• type TinyPubSub
  • func NewTinyPubSub() *TinyPubSub
  • func (tps *TinyPubSub) Close() error
  • func (tps *TinyPubSub) Pub(topic string, data []byte) error
  • func (tps *TinyPubSub) PubFork(topic string, data []byte) error
  • func (tps *TinyPubSub) Sub(topic string, handler remote.SubHandler) error

Types

type TinyPubSub

type TinyPubSub struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewTinyPubSub

func NewTinyPubSub() *TinyPubSub

func (*TinyPubSub) Close

func (tps *TinyPubSub) Close() error

func (*TinyPubSub) Pub

func (tps *TinyPubSub) Pub(topic string, data []byte) error

func (*TinyPubSub) PubFork

func (tps *TinyPubSub) PubFork(topic string, data []byte) error

func (*TinyPubSub) Sub

func (tps *TinyPubSub) Sub(topic string, handler remote.SubHandler) error