Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Fascriber ¶
type Fascriber struct {
Notification NotificationType
ClientId string
}
func (Fascriber) ConfirmSubscription ¶
func (f Fascriber) ConfirmSubscription()
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
type NotificationType ¶
type NotificationType string
const ( Http NotificationType = "Http" WebSocket = "WS" )
type Subscriber ¶
type Subscriber interface {
}
Subscriber is a value associated with a subscription.
type Subscription ¶
type Subscription struct {
// contains filtered or unexported fields
}
Subscription represents a topic subscription.
Source Files
Click to show internal directories.
Click to hide internal directories.