Versions in this module Expand all Collapse all v1 v1.0.0 Sep 7, 2022 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