summaryrefslogtreecommitdiff
path: root/pkg/priority_queue
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-06-25 14:21:53 +0300
committerValery Piashchynski <[email protected]>2021-06-25 14:21:53 +0300
commitad1ca84b26bb6a4ba410a8a684fe3d2e2f86eaea (patch)
tree9d426322de665a47b059d094eebb034f43673269 /pkg/priority_queue
parent09041fe7499be1929aaffaa113f93f6853564c09 (diff)
- Update jobs interface
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'pkg/priority_queue')
-rw-r--r--pkg/priority_queue/interface.go2
-rw-r--r--pkg/priority_queue/queue.go4
2 files changed, 3 insertions, 3 deletions
diff --git a/pkg/priority_queue/interface.go b/pkg/priority_queue/interface.go
index d1c3229f..5945a013 100644
--- a/pkg/priority_queue/interface.go
+++ b/pkg/priority_queue/interface.go
@@ -2,6 +2,6 @@ package priorityqueue
type Queue interface {
Push()
- Pop()
+ Pop() interface{}
BLPop()
}
diff --git a/pkg/priority_queue/queue.go b/pkg/priority_queue/queue.go
index 88d18acb..79afab18 100644
--- a/pkg/priority_queue/queue.go
+++ b/pkg/priority_queue/queue.go
@@ -12,8 +12,8 @@ func (q *QueueImpl) Push() {
}
-func (q *QueueImpl) Pop() {
-
+func (q *QueueImpl) Pop() interface{} {
+ return nil
}
func (q *QueueImpl) BLPop() {