From d3807db78fc67fd82a8d5c9507e484e0773a4be4 Mon Sep 17 00:00:00 2001 From: Alex Dadgar Date: Fri, 14 Apr 2017 15:26:54 -0700 Subject: [PATCH] NewEvalBroker comment --- nomad/eval_broker.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/nomad/eval_broker.go b/nomad/eval_broker.go index 92fd0bc8a..4835ee07d 100644 --- a/nomad/eval_broker.go +++ b/nomad/eval_broker.go @@ -103,7 +103,10 @@ type PendingEvaluations []*structs.Evaluation // NewEvalBroker creates a new evaluation broker. This is parameterized // with the timeout used for messages that are not acknowledged before we // assume a Nack and attempt to redeliver as well as the deliveryLimit -// which prevents a failing eval from being endlessly delivered. +// which prevents a failing eval from being endlessly delivered. The +// initialNackDelay is the delay before making a Nacked evalution available +// again for the first Nack and subsequentNackDelay is the compounding delay +// after the first Nack. func NewEvalBroker(timeout, initialNackDelay, subsequentNackDelay time.Duration, deliveryLimit int) (*EvalBroker, error) { if timeout < 0 { return nil, fmt.Errorf("timeout cannot be negative")