pqueue

type ItemStatus string

type PQueues struct {
	SuperUserPQueue *PriorityQueue
	UserPQueue      *PriorityQueue
}

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

type PriorityQueueInterface interface {
	WaitUntilInvoked(id string) (*QueueItem, error)
	ProcessQueue(requestLimit int64, timeLimit time.Duration, stop chan struct{})
}

type QueueItem struct {
	Id string

	Func     interface{}
	Args     []interface{}
	Response Response

	Priority int
	Amount   int
	// contains filtered or unexported fields
}

type Response struct {
	Value interface{}
	Error error
}