Versions in this module Expand all Collapse all v0 v0.1.0 Dec 14, 2021 Changes in this version + type Store struct + func New(path string, opts *bbolt.Options) *Store + func (s *Store) Close() + func (s *Store) DeleteClient(id string) error + func (s *Store) DeleteInflight(id string) error + func (s *Store) DeleteRetained(id string) error + func (s *Store) DeleteSubscription(id string) error + func (s *Store) Open() error + func (s *Store) ReadClients() (v []persistence.Client, err error) + func (s *Store) ReadInflight() (v []persistence.Message, err error) + func (s *Store) ReadRetained() (v []persistence.Message, err error) + func (s *Store) ReadServerInfo() (v persistence.ServerInfo, err error) + func (s *Store) ReadSubscriptions() (v []persistence.Subscription, err error) + func (s *Store) WriteClient(v persistence.Client) error + func (s *Store) WriteInflight(v persistence.Message) error + func (s *Store) WriteRetained(v persistence.Message) error + func (s *Store) WriteServerInfo(v persistence.ServerInfo) error + func (s *Store) WriteSubscription(v persistence.Subscription) error
Go to main page