pubsub

Documentation

Index

• Constants
• type PubSub
  • func New(capacity int) *PubSub
  • func (ps *PubSub) Publish(topic string, payload interface{})
  • func (ps *PubSub) Shutdown()
  • func (ps *PubSub) Subscribe(topic string, options interface{}, callback func(interface{}) error) (subscription.Subscription, error)
  • func (ps *PubSub) Unsubscribe(sub subscription.Subscription) error
• type Subscription

Constants

const (
	SUBSCRIBE operation = iota
	UNSUBSCRIBE
	PUBLISH
	SHUTDOWN
)

Types

type PubSub

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

func New

func New(capacity int) *PubSub

func (*PubSub) Publish

func (ps *PubSub) Publish(topic string, payload interface{})

func (*PubSub) Shutdown

func (ps *PubSub) Shutdown()

func (*PubSub) Subscribe

func (ps *PubSub) Subscribe(topic string, options interface{}, callback func(interface{}) error) (subscription.Subscription, error)

func (*PubSub) Unsubscribe

func (ps *PubSub) Unsubscribe(sub subscription.Subscription) error

type Subscription

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