Versions in this module Expand all Collapse all v0 v0.30.1 Mar 1, 2019 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 v0.30.1-libsecp256k1 Mar 1, 2019
Go to main page