Versions in this module Expand all Collapse all v0 v0.1.0 Mar 7, 2024 Changes in this version + type Store struct + func NewStore(dsn string) (*Store, error) + func (s *Store) Append(topic string, msgs ...[]byte) error + func (s *Store) Close() + func (s *Store) Commit(clientID string, topic string, idx int) error + func (s *Store) FetchNext(clientID string, topic string, limit int) ([]message.Message, error)