pubsub

Documentation

Index

• type PubSub
  • func (d *PubSub) Publish(payload event.Payload)
  • func (d *PubSub) Subscribe(f func(payload event.Payload)) error
• type PubSuber
  • func NewPubSub() PubSuber

Types

type PubSub

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

func (*PubSub) Publish

func (d *PubSub) Publish(payload event.Payload)

func (*PubSub) Subscribe

func (d *PubSub) Subscribe(f func(payload event.Payload)) error

type PubSuber

type PubSuber interface {
	Publish(payload event.Payload)
	Subscribe(f func(paylaod event.Payload)) error
}

func NewPubSub

func NewPubSub() PubSuber