Documentation ¶
Index ¶
- type ClientRegister
- func (cr *ClientRegister) AddClient(client *protocol.Client)
- func (cr *ClientRegister) AddSubscription(client *protocol.Client, patterns []string)
- func (cr *ClientRegister) GetClient(clientId uint32) *protocol.Client
- func (cr *ClientRegister) Publish(msg protocol.Message)
- func (cr *ClientRegister) Reap() *ClientRegisterCounters
- func (cr *ClientRegister) RemoveSubscription(client *protocol.Client, patterns []string)
- type ClientRegisterCounters
- type SubscriptionRegister
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClientRegister ¶
type ClientRegister struct {
// contains filtered or unexported fields
}
func NewClientRegister ¶
func NewClientRegister() *ClientRegister
func (*ClientRegister) AddClient ¶
func (cr *ClientRegister) AddClient(client *protocol.Client)
func (*ClientRegister) AddSubscription ¶
func (cr *ClientRegister) AddSubscription(client *protocol.Client, patterns []string)
func (*ClientRegister) GetClient ¶
func (cr *ClientRegister) GetClient(clientId uint32) *protocol.Client
func (*ClientRegister) Publish ¶
func (cr *ClientRegister) Publish(msg protocol.Message)
func (*ClientRegister) Reap ¶
func (cr *ClientRegister) Reap() *ClientRegisterCounters
func (*ClientRegister) RemoveSubscription ¶
func (cr *ClientRegister) RemoveSubscription(client *protocol.Client, patterns []string)
type ClientRegisterCounters ¶
type SubscriptionRegister ¶
type SubscriptionRegister struct { SubscriberByPatternCount *atomic.Uint64 // contains filtered or unexported fields }
func NewSubscriptionRegister ¶
func NewSubscriptionRegister() *SubscriptionRegister
func (*SubscriptionRegister) AddSubscription ¶
func (sr *SubscriptionRegister) AddSubscription(subscriber interface{}, patterns []string)
func (*SubscriptionRegister) GetSubscribers ¶
func (sr *SubscriptionRegister) GetSubscribers(patterns []string) []interface{}
func (*SubscriptionRegister) RemoveSubscription ¶
func (sr *SubscriptionRegister) RemoveSubscription(subscriber interface{}, patterns []string)
Click to show internal directories.
Click to hide internal directories.