memory

Documentation

Index

• type ClientRegister
  • func NewClientRegister() *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
  • func NewSubscriptionRegister() *SubscriptionRegister
  • func (sr *SubscriptionRegister) AddSubscription(subscriber interface{}, patterns []string)
  • func (sr *SubscriptionRegister) GetSubscribers(patterns []string) []interface{}
  • func (sr *SubscriptionRegister) RemoveSubscription(subscriber interface{}, patterns []string)

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 ClientRegisterCounters struct {
	TotalFailed              uint64
	TotalSent                uint64
	Clients                  uint
	SubscriberByPatternCount uint64
}

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)