Documentation ¶
Index ¶
- type Lane
- type Store
- func (s *Store) Close()
- func (s *Store) Dequeue() (tinyq.Message, error)
- func (s *Store) Enqueue(msg tinyq.Message) error
- func (s *Store) IsEmpty() bool
- func (s *Store) List(typ tinyq.MessageStatus, offset, limit uint64) (tinyq.Messages, error)
- func (s *Store) Notify(uuid string, merr error) error
- func (s *Store) Remove(typ tinyq.MessageStatus) error
- func (s *Store) Retry() error
- func (s *Store) Statistic() (tinyq.Stats, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
Click to show internal directories.
Click to hide internal directories.