Skip to content

Commit

Permalink
NewEvalBroker comment
Browse files Browse the repository at this point in the history
  • Loading branch information
dadgar committed Apr 14, 2017
1 parent 3062b26 commit d3807db
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion nomad/eval_broker.go
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand Down

0 comments on commit d3807db

Please sign in to comment.