pubsub

May 31, 2018

Changes in this version

+ var ErrAlreadySubscribed = errors.New("already subscribed")

+ var ErrSubscriptionNotFound = errors.New("subscription not found")

+ type Option func(*Server)

+ func BufferCapacity(cap int) Option

+ type Query interface

+ Matches func(tags TagMap) bool

+ String func() string

+ type Server struct

+ func NewServer(options ...Option) *Server

+ func (s *Server) BufferCapacity() int

+ func (s *Server) OnReset() error

+ func (s *Server) OnStart() error

+ func (s *Server) OnStop()

+ func (s *Server) Publish(ctx context.Context, msg interface{}) error

+ func (s *Server) PublishWithTags(ctx context.Context, msg interface{}, tags TagMap) error

+ func (s *Server) Subscribe(ctx context.Context, clientID string, query Query, out chan<- interface{}) error

+ func (s *Server) Unsubscribe(ctx context.Context, clientID string, query Query) error

+ func (s *Server) UnsubscribeAll(ctx context.Context, clientID string) error

+ type TagMap interface

+ Get func(key string) (value string, ok bool)

+ Len func() int

+ func NewTagMap(data map[string]string) TagMap