pubsub

Documentation

Index

• Variables
• type Message
• type MessageCallback
• type MessageChan
• type OptionFunc
  • func WithBufferSize(size int) OptionFunc
• type Options
• type PubSub
  • func New(optionFunc ...OptionFunc) *PubSub
  • func (pb *PubSub) Close()
  • func (pb *PubSub) Publish(topic string, data interface{}) error
  • func (pb *PubSub) Subscribe(topic string, callback MessageCallback) error
  • func (pb *PubSub) Wait()

Variables

var (
	ErrClosed      = errors.New("pub/sub is closed")
	ErrNoSubscribe = errors.New("no subscribe")
)

Types

type Message

type Message interface{}

type MessageCallback

type MessageCallback func(Message)

type MessageChan

type MessageChan chan Message

type OptionFunc

type OptionFunc func(*Options)

func WithBufferSize

func WithBufferSize(size int) OptionFunc

type Options

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

type PubSub

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

func New

func New(optionFunc ...OptionFunc) *PubSub

func (*PubSub) Close

func (pb *PubSub) Close()

func (*PubSub) Publish

func (pb *PubSub) Publish(topic string, data interface{}) error

func (*PubSub) Subscribe

func (pb *PubSub) Subscribe(topic string, callback MessageCallback) error

func (*PubSub) Wait

func (pb *PubSub) Wait()