Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager manages subscriptions
func NewManager ¶
func NewManager() *Manager
func (*Manager) HasSubscription ¶
HasSubscription returns true if the subscription exists
func (*Manager) Subscribe ¶
func (m *Manager) Subscribe(sub *Subscription) error
Subscribe performs a subscribe operation
func (*Manager) SubscriptionCount ¶ added in v0.2.0
SubscriptionCount counts all or specific connection id subscriptions can be used for diagnostics
func (*Manager) Unsubscribe ¶
func (m *Manager) Unsubscribe(operationID string) *Subscription
Unsubscribe removes a single operation
func (*Manager) UnsubscribeAll ¶
func (m *Manager) UnsubscribeAll()
Unsubscribe all unsubscribes and removes all operations for a specific connection id
Click to show internal directories.
Click to hide internal directories.