subscription

Documentation

Index

• type Subscription
• type SubscriptionManager
  • func NewSubscriptionManager() *SubscriptionManager
  • func (sm *SubscriptionManager) AddSubscription(topic string, conn *websocket.Conn)
  • func (sm *SubscriptionManager) GetSubscriptions(topic string) []*Subscription
  • func (sm *SubscriptionManager) RemoveAllSubscriptions(conn *websocket.Conn)
  • func (sm *SubscriptionManager) RemoveSubscription(topic string, conn *websocket.Conn)
  • func (sm *SubscriptionManager) SendMessageToSubscribers(topic string, message []byte)

Types

type Subscription

type Subscription struct {
	// contains filtered or unexported fields
}

type SubscriptionManager

type SubscriptionManager struct {
	// contains filtered or unexported fields
}

SubscriptionManager to hold subscriptions.

func NewSubscriptionManager

func NewSubscriptionManager() *SubscriptionManager

NewSubscriptionManager creates a new instance of SubscriptionManager.

func (*SubscriptionManager) AddSubscription

func (sm *SubscriptionManager) AddSubscription(topic string, conn *websocket.Conn)

AddSubscription adds a new subscription for a topic.

func (*SubscriptionManager) GetSubscriptions

func (sm *SubscriptionManager) GetSubscriptions(topic string) []*Subscription

GetSubscriptions returns all subscriptions for a topic.

func (*SubscriptionManager) RemoveAllSubscriptions

func (sm *SubscriptionManager) RemoveAllSubscriptions(conn *websocket.Conn)

func (*SubscriptionManager) RemoveSubscription

func (sm *SubscriptionManager) RemoveSubscription(topic string, conn *websocket.Conn)

RemoveSubscription removes a subscription for a topic.

func (*SubscriptionManager) SendMessageToSubscribers

func (sm *SubscriptionManager) SendMessageToSubscribers(topic string, message []byte)

SendMessageToSubscribers sends a message to all subscribers of a topic.