diff options
author | Valery Piashchynski <[email protected]> | 2021-10-14 17:12:47 +0300 |
---|---|---|
committer | GitHub <[email protected]> | 2021-10-14 17:12:47 +0300 |
commit | 0ffbcea1aea3cc63af3168c278c193792f01f656 (patch) | |
tree | fcf3bc27c45ba13cffa09cecb101ad38ac4f967c | |
parent | 4d352766d1acda15e29616ef961cbf7e87f92dc8 (diff) | |
parent | 9de85482ce19c4e40b68d9e3f6458875856a071e (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.go | 12 | ||||
-rw-r--r-- | priority_queue/interface.go | 9 |
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 } |