pubsub

Apr 23, 2018

Changes in this version

+ type TagMap interface

+ Get func(key string) (value interface{}, ok bool)

+ Len func() int

+ func NewTagMap(data map[string]interface{}) TagMap

Apr 4, 2018

Changes in this version

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

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

type Server

+ func (s *Server) OnReset() error

Dec 29, 2017

Changes in this version

type Query

+ String func() string

Dec 6, 2017

Changes in this version

+ type Option func(*Server)

+ func BufferCapacity(cap int) Option

+ type Query interface

+ Matches func(tags map[string]interface{}) bool

+ type Server struct

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

+ 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 map[string]interface{}) 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

+ func (s Server) BufferCapacity() int