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]>

1 files changed, 0 insertions, 6 deletions

diff --git a/plugins/jobs/brokers/ephemeral/broker.go b/plugins/jobs/brokers/ephemeral/broker.go
index 4bbb4095..6c7108f6 100644
--- a/plugins/jobs/brokers/ephemeral/broker.go
+++ b/plugins/jobs/brokers/ephemeral/broker.go
@@ -57,12 +57,6 @@ func (j *JobBroker) Register(pipeline string) error {
 	return nil
 }
 
-func (j *JobBroker) PushBatch(job *[]structs.Job) (*string, error) {
-	// Use a batch response
-	// Add JobID to the payload to match responses
-	panic("todo")
-}
-
 func (j *JobBroker) Stop(pipeline string) {
 	if q, ok := j.queues.Load(pipeline); ok {
 		if q == true {