Documentation ¶ Index ¶ type Queue func NewQueue() *Queue func (q *Queue) Delete(key string) error func (q *Queue) Drain(key string) [][]byte func (q *Queue) Push(key string, value []byte) (int, error) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Queue ¶ type Queue struct { // contains filtered or unexported fields } Queue is a simple in-memory queue implementation. It uses a map to store multiple byte slices under a single key. All operations are safe for concurrent use. func NewQueue ¶ func NewQueue() *Queue func (*Queue) Delete ¶ func (q *Queue) Delete(key string) error func (*Queue) Drain ¶ func (q *Queue) Drain(key string) [][]byte func (*Queue) Push ¶ func (q *Queue) Push(key string, value []byte) (int, error) Source Files ¶ View all Source files queue.go Click to show internal directories. Click to hide internal directories.
Documentation
¶
Source Files