Documentation ¶ Index ¶ type Store func New(pool *redis.Pool) *Store func (s *Store) Get(clientID string) (*gmqtt.Session, error) func (s *Store) Iterate(fn session.IterateFn) error func (s *Store) Remove(clientID string) error func (s *Store) Set(session *gmqtt.Session) error func (s *Store) SetSessionExpiry(clientID string, expiry uint32) error Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Store ¶ type Store struct { // contains filtered or unexported fields } func New ¶ func New(pool *redis.Pool) *Store func (*Store) Get ¶ func (s *Store) Get(clientID string) (*gmqtt.Session, error) func (*Store) Iterate ¶ func (s *Store) Iterate(fn session.IterateFn) error func (*Store) Remove ¶ func (s *Store) Remove(clientID string) error func (*Store) Set ¶ func (s *Store) Set(session *gmqtt.Session) error func (*Store) SetSessionExpiry ¶ func (s *Store) SetSessionExpiry(clientID string, expiry uint32) error Source Files ¶ View all Source files store.go Click to show internal directories. Click to hide internal directories.