matching

Documentation

Index

• type Fascriber
  • func (f Fascriber) ConfirmSubscription()
• type Matcher
  • func NewCSTrieMatcher() Matcher
• type NotificationType
• type Subscriber
• type Subscription

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.