diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-06 23:32:23 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-06 23:32:23 +0300 |
| commit | 36bf9228e60f59f569e84822e2860980d7ed698d (patch) | |
| tree | c76e7656bd26e033678dc52bed8167cfb9b39aa7 /common | |
| parent | 2c78e93222cc9d3b88456175348e42f7f40c449b (diff) | |
Update Jobs interface...
Use bh.len everywhere in the binary heaps algo instead of direct len
check.
Add Ack/Nack to the main jobs loop.
Add PushBatch method to the jobs rpc layer.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'common')
| -rw-r--r-- | common/jobs/interface.go | 1 |
1 files changed, 0 insertions, 1 deletions
diff --git a/common/jobs/interface.go b/common/jobs/interface.go index 6738ed46..786eca0e 100644 --- a/common/jobs/interface.go +++ b/common/jobs/interface.go @@ -9,7 +9,6 @@ import ( // Consumer todo naming type Consumer interface { Push(job *structs.Job) (*string, error) - PushBatch(job *[]structs.Job) (*string, error) Consume(job *pipeline.Pipeline) Stop(pipeline string) |