Versions in this module Expand all Collapse all v0 v0.10.0 Oct 5, 2019 Changes in this version type Queue + func (q *Queue) DeletePush(box Box) error v0.9.0 Jul 1, 2019 Changes in this version + const OnlyForTesting v0.8.0 Jul 1, 2019 Changes in this version + var ErrClosed = fmt.Errorf("pq is closed") + var ErrInvalidKey = fmt.Errorf("pq storage key invalid") + func IsCorrupted(err error) bool + type Box struct + func (b *Box) Bytes() []byte + func (b *Box) Empty() bool + func (b *Box) Unmarshal(x encoding.BinaryUnmarshaler) error + type Queue struct + func Open(path string) (*Queue, error) + func (q *Queue) Close() error + func (q *Queue) Delete(box Box) error + func (q *Queue) MarshalPush(item encoding.BinaryMarshaler) error + func (q *Queue) Peek() (Box, error) + func (q *Queue) Push(value []byte) error