ipq

Documentation

Index

• type IPQ
• type Item
• type MemoryIPQ
  • func NewMemoryIPQ(maxLen int, f func(interface{})) *MemoryIPQ
  • func (m *MemoryIPQ) Del(k interface{})
  • func (m *MemoryIPQ) DelInRange(f func(*Item) (bool, bool))
  • func (m *MemoryIPQ) Free()
  • func (m *MemoryIPQ) Get(k interface{}) interface{}
  • func (m *MemoryIPQ) Len() int
  • func (m *MemoryIPQ) List() *list.List
  • func (m *MemoryIPQ) PushBack(k, v interface{}, move, update bool)
  • func (m *MemoryIPQ) Range(f func(*Item) bool)
  • func (m *MemoryIPQ) Reset()
  • func (m *MemoryIPQ) SpaceLeft() bool

Types

type IPQ

type IPQ interface {
	Len() int

	SpaceLeft() bool

	// PushBack push element to the back of the queue
	// if k exists and move is true, element will be move to back
	// if k exists and update is true, Value of element will be replaced
	PushBack(k, v interface{}, move, update bool)

	Get(k interface{}) interface{}

	Del(k interface{})

	Range(f func(*Item) bool)

	DelInRange(f func(*Item) (bool, bool))

	Reset()

	Free()
}

type Item

type Item struct {
	Key   interface{}
	Value interface{}
}

type MemoryIPQ

type MemoryIPQ struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewMemoryIPQ

func NewMemoryIPQ(maxLen int, f func(interface{})) *MemoryIPQ

func (*MemoryIPQ) Del

func (m *MemoryIPQ) Del(k interface{})

func (*MemoryIPQ) DelInRange

func (m *MemoryIPQ) DelInRange(f func(*Item) (bool, bool))

func (*MemoryIPQ) Free

func (m *MemoryIPQ) Free()

func (*MemoryIPQ) Get

func (m *MemoryIPQ) Get(k interface{}) interface{}

func (*MemoryIPQ) Len

func (m *MemoryIPQ) Len() int

func (*MemoryIPQ) List

func (m *MemoryIPQ) List() *list.List

func (*MemoryIPQ) PushBack

func (m *MemoryIPQ) PushBack(k, v interface{}, move, update bool)

func (*MemoryIPQ) Range

func (m *MemoryIPQ) Range(f func(*Item) bool)

func (*MemoryIPQ) Reset

func (m *MemoryIPQ) Reset()

func (*MemoryIPQ) SpaceLeft

func (m *MemoryIPQ) SpaceLeft() bool