pubsub

Documentation

Index

• func New() internal.PubsubWithContext
• type Pubsub
  • func (this *Pubsub) Publish(context app.Context, topic string, message app.PubsubMessage)
  • func (this *Pubsub) Subscribe(context app.Context, topic string, handler app.TopicHandler)
• type TopicHandlerList
  • func NewTopicHandlerList(handlers ...app.TopicHandler) *TopicHandlerList
  • func (this *TopicHandlerList) Add(handler app.TopicHandler)
  • func (this *TopicHandlerList) Dispatch(message app.PubsubMessage)

Functions

func New

func New() internal.PubsubWithContext

Types

type Pubsub

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

func (*Pubsub) Publish

func (this *Pubsub) Publish(context app.Context, topic string, message app.PubsubMessage)

func (*Pubsub) Subscribe

func (this *Pubsub) Subscribe(context app.Context, topic string, handler app.TopicHandler)

type TopicHandlerList

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

func NewTopicHandlerList

func NewTopicHandlerList(handlers ...app.TopicHandler) *TopicHandlerList

func (*TopicHandlerList) Add

func (this *TopicHandlerList) Add(handler app.TopicHandler)

func (*TopicHandlerList) Dispatch

func (this *TopicHandlerList) Dispatch(message app.PubsubMessage)