Versions in this module Expand all Collapse all v0 v0.5.2 Jul 27, 2023 v0.5.1 Jul 27, 2023 Changes in this version + type Store struct + 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
Go to main page