memory

Documentation

Index

• type ClientRegister
  • func NewClientRegister(logger utils.Logger) *ClientRegister
  • func (cr ClientRegister) AddClient(client *protocol.Client)
  • func (cr ClientRegister) AddSubscription(clientId string, patterns []string)
  • func (cr ClientRegister) GetClient(clientId string) *protocol.Client
  • func (cr ClientRegister) GetClients(patterns []string) []string
  • func (cr ClientRegister) RemoveSubscription(clientId string, patterns []string)
• type MemoryMsgStore
  • func NewMemoryMsgStore() *MemoryMsgStore
  • func (m *MemoryMsgStore) EnqueueMessages(msgs []protocol.Message)
  • func (m *MemoryMsgStore) GetAndClearMessages() []protocol.Message
• type MemoryNamespace
  • func NewMemoryNamespace() MemoryNamespace
  • func (m MemoryNamespace) Expire(id string)
  • func (m MemoryNamespace) Generate() string
  • func (m MemoryNamespace) IsUsed(id string) bool
• type SubscriptionRegister
  • func NewSubscriptionRegister() *SubscriptionRegister
  • func (sr SubscriptionRegister) AddSubscription(clientId string, patterns []string)
  • func (sr SubscriptionRegister) GetClients(patterns []string) []string
  • func (sr SubscriptionRegister) RemoveClient(clientId string)
  • func (sr SubscriptionRegister) RemoveSubscription(clientId string, patterns []string)

Types

type ClientRegister

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

func NewClientRegister

func NewClientRegister(logger utils.Logger) *ClientRegister

func (ClientRegister) AddClient

func (cr ClientRegister) AddClient(client *protocol.Client)

func (ClientRegister) AddSubscription

func (cr ClientRegister) AddSubscription(clientId string, patterns []string)

func (ClientRegister) GetClient

func (cr ClientRegister) GetClient(clientId string) *protocol.Client

func (ClientRegister) GetClients

func (cr ClientRegister) GetClients(patterns []string) []string

func (ClientRegister) RemoveSubscription

func (cr ClientRegister) RemoveSubscription(clientId string, patterns []string)

type MemoryMsgStore

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

func NewMemoryMsgStore

func NewMemoryMsgStore() *MemoryMsgStore

func (*MemoryMsgStore) EnqueueMessages

func (m *MemoryMsgStore) EnqueueMessages(msgs []protocol.Message)

func (*MemoryMsgStore) GetAndClearMessages

func (m *MemoryMsgStore) GetAndClearMessages() []protocol.Message

type MemoryNamespace

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

func NewMemoryNamespace

func NewMemoryNamespace() MemoryNamespace

func (MemoryNamespace) Expire

func (m MemoryNamespace) Expire(id string)

func (MemoryNamespace) Generate

func (m MemoryNamespace) Generate() string

func (MemoryNamespace) IsUsed

func (m MemoryNamespace) IsUsed(id string) bool

type SubscriptionRegister

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

func NewSubscriptionRegister

func NewSubscriptionRegister() *SubscriptionRegister

func (SubscriptionRegister) AddSubscription

func (sr SubscriptionRegister) AddSubscription(clientId string, patterns []string)

func (SubscriptionRegister) GetClients

func (sr SubscriptionRegister) GetClients(patterns []string) []string

func (SubscriptionRegister) RemoveClient

func (sr SubscriptionRegister) RemoveClient(clientId string)

func (SubscriptionRegister) RemoveSubscription

func (sr SubscriptionRegister) RemoveSubscription(clientId string, patterns []string)