mqueue

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 26, 2019 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MultiQueueItem

type MultiQueueItem interface {
	MQueName() string
}

MultiQueueItem

type MultiQueues

type MultiQueues struct {
	// contains filtered or unexported fields
}

MultiQueuea

func NewMultiQueues

func NewMultiQueues() *MultiQueues

func (*MultiQueues) FilterWalk

func (mq *MultiQueues) FilterWalk(f func(string, MultiQueueItem) bool)

func (*MultiQueues) Len

func (mq *MultiQueues) Len() int

func (*MultiQueues) Pop

func (mq *MultiQueues) Pop(name string) MultiQueueItem

func (*MultiQueues) Push

func (mq *MultiQueues) Push(item MultiQueueItem)

func (*MultiQueues) Remove

func (mq *MultiQueues) Remove(f func(MultiQueueItem) bool)

func (*MultiQueues) RemoveByName

func (mq *MultiQueues) RemoveByName(name string, f func(MultiQueueItem) bool)

func (*MultiQueues) Size

func (mq *MultiQueues) Size(name string) int

func (*MultiQueues) Walk

func (mq *MultiQueues) Walk(f func(string, MultiQueueItem))

func (*MultiQueues) WalkByName

func (mq *MultiQueues) WalkByName(name string, f func(MultiQueueItem))

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL