summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-10-14 17:12:47 +0300
committerGitHub <[email protected]>2021-10-14 17:12:47 +0300
commit0ffbcea1aea3cc63af3168c278c193792f01f656 (patch)
treefcf3bc27c45ba13cffa09cecb101ad38ac4f967c
parent4d352766d1acda15e29616ef961cbf7e87f92dc8 (diff)
parent9de85482ce19c4e40b68d9e3f6458875856a071e (diff)
[#827]: upd(priority queue): update PQ interface v2.5.0-beta.4
## Description of Changes - Remove methods that are not related to the PQ interface. - Move `jobs` specific PQ methods to the `roadrunner-plugins` repo with a separate `Acknowledger` interface.
-rw-r--r--priority_queue/binary_heap_test.go12
-rw-r--r--priority_queue/interface.go9
2 files changed, 0 insertions, 21 deletions
diff --git a/priority_queue/binary_heap_test.go b/priority_queue/binary_heap_test.go
index 2eed34e6..e29835c2 100644
--- a/priority_queue/binary_heap_test.go
+++ b/priority_queue/binary_heap_test.go
@@ -12,18 +12,6 @@ import (
type Test int
-func (t Test) Ack() error {
- return nil
-}
-
-func (t Test) Nack() error {
- return nil
-}
-
-func (t Test) Requeue(_ map[string][]string, _ int64) error {
- return nil
-}
-
func (t Test) Body() []byte {
return nil
}
diff --git a/priority_queue/interface.go b/priority_queue/interface.go
index 9efa4652..42510f96 100644
--- a/priority_queue/interface.go
+++ b/priority_queue/interface.go
@@ -19,13 +19,4 @@ type Item interface {
// Context is the Item meta information
Context() ([]byte, error)
-
- // Ack - acknowledge the Item after processing
- Ack() error
-
- // Nack - discard the Item
- Nack() error
-
- // Requeue - put the message back to the queue with the optional delay
- Requeue(headers map[string][]string, delay int64) error
}