Documentation ¶
Index ¶
- type LedisStorage
- func (storage *LedisStorage) DeleteClient(clientID string)
- func (storage *LedisStorage) GetChannel(id string) *core.Channel
- func (storage *LedisStorage) GetClients() []*core.Client
- func (storage *LedisStorage) LoadClient(clientID string) *core.Client
- func (storage *LedisStorage) StoreChannel(id string, chann *core.Channel)
- func (storage *LedisStorage) StoreClient(clientID string, client *core.Client)
- func (storage *LedisStorage) StoreMessage(channelID string, event *core.ChannelEvent)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LedisStorage ¶
type LedisStorage struct {
// contains filtered or unexported fields
}
LedisStorage - Storage implementation with ledis
func NewLedisStorage ¶
func NewLedisStorage() *LedisStorage
NewLedisStorage - Create Storage implementation with ledis
func (*LedisStorage) DeleteClient ¶
func (storage *LedisStorage) DeleteClient(clientID string)
DeleteClient - Remove client info
func (*LedisStorage) GetChannel ¶
func (storage *LedisStorage) GetChannel(id string) *core.Channel
GetChannel - Get channel info
func (*LedisStorage) GetClients ¶
func (storage *LedisStorage) GetClients() []*core.Client
GetClients - Get all stored clients
func (*LedisStorage) LoadClient ¶
func (storage *LedisStorage) LoadClient(clientID string) *core.Client
LoadClient - Load client info
func (*LedisStorage) StoreChannel ¶
func (storage *LedisStorage) StoreChannel(id string, chann *core.Channel)
StoreChannel - Add new channel info
func (*LedisStorage) StoreClient ¶
func (storage *LedisStorage) StoreClient(clientID string, client *core.Client)
StoreClient - Add new client info
func (*LedisStorage) StoreMessage ¶
func (storage *LedisStorage) StoreMessage(channelID string, event *core.ChannelEvent)
StoreMessage - Store new channel message
Directories ¶
Path | Synopsis |
---|---|
This package holds the PGX driver implementation of the storage interface
|
This package holds the PGX driver implementation of the storage interface |
This package holds a default implementation of the storage interface
|
This package holds a default implementation of the storage interface |
Click to show internal directories.
Click to hide internal directories.