pubsub

Documentation

Index

• Constants
• type Filter
• type PubSub
  • func New() PubSub
• type Publisher
• type QueueSubscription
  • func (ps *QueueSubscription) Cancel()
  • func (ps *QueueSubscription) Channel() <-chan interface{}
  • func (ps *QueueSubscription) Next() (interface{}, error)
• type Subscriber
• type Subscription

Constants

const (
	ErrSubscriptionCanceled = errors.Error("subscription canceled")
)

Types

type Filter

type Filter func(interface{}) bool

type PubSub

type PubSub interface {
	Publisher
	Subscriber
}

func New

func New() PubSub

New constructs and returns a new PubSub

type Publisher

type Publisher interface {
	Publish(interface{})
}

Publisher deals with the publishing part of our PubSub

type QueueSubscription

type QueueSubscription struct {
	Queue *queue.Queue
	// contains filtered or unexported fields
}

func (*QueueSubscription) Cancel

func (ps *QueueSubscription) Cancel()

func (*QueueSubscription) Channel

func (ps *QueueSubscription) Channel() <-chan interface{}

func (*QueueSubscription) Next

func (ps *QueueSubscription) Next() (interface{}, error)

type Subscriber

type Subscriber interface {
	Subscribe(...Filter) Subscription
}

Subscriber deals with the subscribing part of our PubSub

type Subscription

type Subscription interface {
	Channel() <-chan interface{}
	Next() (interface{}, error)
	Cancel()
}

Subscription is returned for every subscription