Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrBadTopic = errors.New("Topic does not fit within topic space")
Functions ¶
This section is empty.
Types ¶
type Matcher ¶
type Matcher interface { // Subscribe adds the Subscriber to the topic and returns a Subscription. Subscribe(topic string, sub Subscriber) (*Subscription, error) // Unsubscribe removes the Subscription. Unsubscribe(sub *Subscription) // Lookup returns the Subscribers for the given topic. Lookup(topic string) []Subscriber }
Matcher contains topic subscriptions and performs matches on them.
func NewCSTrieMatcher ¶
func NewCSTrieMatcher() Matcher
func NewNaiveMatcher ¶
func NewNaiveMatcher() Matcher
func NewTrieMatcher ¶
func NewTrieMatcher() Matcher
type Subscription ¶
type Subscription struct {
// contains filtered or unexported fields
}
Subscription represents a topic subscription.
Click to show internal directories.
Click to hide internal directories.