pubsub

Documentation

Index

• type Event
• type PubSub
  • func NewPubSub() *PubSub
  • func (p *PubSub) Publish(evt Event)
  • func (p *PubSub) Subscribe(ctx context.Context) chan Event
  • func (p *PubSub) Wait()

Types

type Event

type Event struct {
	Action string    `json:"action"`
	Id     uuid.UUID `json:"id"`
}

type PubSub

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

func NewPubSub

func NewPubSub() *PubSub

func (*PubSub) Publish

func (p *PubSub) Publish(evt Event)

Publish an event

func (*PubSub) Subscribe

func (p *PubSub) Subscribe(ctx context.Context) chan Event

Subscribe

func (*PubSub) Wait

func (p *PubSub) Wait()

Wait for all subscribers closing