Versions in this module Expand all Collapse all v1 v1.0.0 Feb 28, 2025 Changes in this version + var ErrAlreadyInQueue = errors.New("value already in queue") + var ErrNotFound = errors.New("no key found") + type Queue struct + func NewQueue(db *leveldb.DB, prefix []byte, closeUnderlyingDB bool) (*Queue, error) + func Open(dataDir string) (*Queue, error) + func (queue *Queue) Close() error + func (queue *Queue) LHandle(h func([]byte) error) error + func (queue *Queue) LPop() ([]byte, error) + func (queue *Queue) LPush(data []byte) error + func (queue *Queue) Len() int64 + func (queue *Queue) RHandle(h func([]byte) error) error + func (queue *Queue) RPop() ([]byte, error) + func (queue *Queue) RPush(data []byte) error + type Set struct + func NewSet(db *leveldb.DB, prefix []byte, closeUnderlyingDB bool) (*Set, error) + func OpenSet(dataDir string) (*Set, error) + func (set *Set) Add(value []byte) (bool, error) + func (set *Set) Close() error + func (set *Set) Has(value []byte) (bool, error) + func (set *Set) Members() ([][]byte, error) + func (set *Set) Remove(value []byte) (bool, error) + type UniqueQueue struct + func NewUniqueQueue(db *leveldb.DB, queuePrefix []byte, setPrefix []byte, closeUnderlyingDB bool) (*UniqueQueue, error) + func OpenUnique(dataDir string) (*UniqueQueue, error) + func (queue *UniqueQueue) Close() error + func (queue *UniqueQueue) Has(data []byte) (bool, error) + func (queue *UniqueQueue) LHandle(h func([]byte) error) error + func (queue *UniqueQueue) LPop() ([]byte, error) + func (queue *UniqueQueue) LPush(data []byte) error + func (queue *UniqueQueue) LPushFunc(data []byte, fn func() error) error + func (queue *UniqueQueue) Len() int64 + func (queue *UniqueQueue) RHandle(h func([]byte) error) error + func (queue *UniqueQueue) RPop() ([]byte, error) + func (queue *UniqueQueue) RPush(data []byte) error + func (queue *UniqueQueue) RPushFunc(data []byte, fn func() error) error
Go to main page