Versions in this module Expand all Collapse all v0 v0.3.0 May 20, 2026 v0.2.1 May 20, 2026 v0.2.0 May 20, 2026 v0.1.0 May 18, 2026 Changes in this version + var ErrClosed = errors.New("store: closed") + var ErrDuplicateID = errors.New("store: duplicate message id") + var ErrUnknownPeer = errors.New("store: unknown peer") + type AuditRow struct + Event []byte + Hash string + PrevHash string + Seq int64 + TS int64 + type Message struct + Acked bool + Attempts int + Delivered bool + Envelope []byte + From string + ID string + Seq int64 + TS int64 + To string + type Peer struct + Name string + type Store struct + func Open(path string) (*Store, error) + func (s *Store) AuditAppend(r AuditRow) error + func (s *Store) AuditCount() (int64, error) + func (s *Store) AuditLast() (AuditRow, bool, error) + func (s *Store) AuditRows() ([]AuditRow, error) + func (s *Store) AuditTamper(seq int64, event []byte, hash string) error + func (s *Store) Close() error + func (s *Store) Enqueue(msg Message) error + func (s *Store) MarkAcked(id string) error + func (s *Store) MarkDelivered(id string) error + func (s *Store) PendingFor(name string) ([]Message, error) + func (s *Store) Register(p Peer) error + func (s *Store) RequeueUnacked(name string) (int, error)
Go to main page