queue

type CondWaiter interface {
	Wait()
	Signal()
	Broadcast()
}

type Conditioner interface {
	sync.Locker
	CondWaiter
}

type Heap []Prioritier

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

type Map interface {
	Has(item T) bool
	// Insert overwrites item's value
	Insert(item T, value T)
	Get(item T) T
	Delete(item T)
}

type MapSet map[T]empty

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

type Prioritier interface {
	Priority() int
}

type PriorityQueue interface {
	Insert(item PriorityQueueItem)
	Get() (item PriorityQueueItem, ctx context.Context, ok bool)
	Done(item PriorityQueueItem)
	Len() int
	Close()
	Closed() bool
}

type PriorityQueueItem interface {
	Prioritier
	Handle() T
}

type PriorityQueueItems interface {
	// Insert inserts item into the queue
	Insert(PriorityQueueItem)
	// Get gets item if available and reports whether item is returned successfully
	Get() (PriorityQueueItem, bool)
	// Len returns length of the queue
	Len() int
}

type Set interface {
	Has(item T) bool
	// Insert overwrites item in the set
	Insert(item T)
	Delete(item T)
}

type SimpleMap map[T]T

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

type T interface{}