pubsub

Documentation

Overview

Package pubsub contains types to deal with subscriptions.

Index

• type PubSub
  • func New() *PubSub
  • func (p *PubSub) Publish(msgType string, msg interface{})
  • func (p *PubSub) Subscribe(ctx context.Context, msgType string, fn func(interface{}))

Types

type PubSub

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

PubSub deals with subscribing and publishing messages.

func New

func New() *PubSub

New creates a new PubSub.

func (*PubSub) Publish

func (p *PubSub) Publish(msgType string, msg interface{})

Publish will publish a message of the given type to all subscribers for that type.

func (*PubSub) Subscribe

func (p *PubSub) Subscribe(ctx context.Context, msgType string, fn func(interface{}))

Subscribe register a function that will receive messages of the given type. To unsubscribe the context must be closed.