func NewEvalBatcher(batchDuration time.Duration, raft DeploymentRaftEndpoints, ctx context.Context) *EvalBatcher {
	b := &EvalBatcher{
		batch: batchDuration,
		raft:  raft,
		ctx:   ctx,
		inCh:  make(chan *structs.Evaluation, 10),
	}

	go b.batcher()
	return b
}
// NewEvalBatcher returns an EvalBatcher that uses the passed raft endpoints to
// create the evaluations and exits the batcher when the passed exit channel is
// closed.
NewEvalBatcher returns an EvalBatcher that uses the passed raft endpoints to
create the evaluations and exits the batcher when the passed exit channel is
closed.
// NewEvalBatcher returns an EvalBatcher that uses the passed raft endpoints to // create the evaluations and exits the batcher when the passed exit channel is // closed .
func NewEvalBatcher(batchDuration time.Duration, raft DeploymentRaftEndpoints, ctx context.Context) *EvalBatcher {
	b := &EvalBatcher{
		batch: batchDuration,
		raft:  raft,
		ctx:   ctx,
		inCh:  make(chan *structs.Evaluation, 10),
	}
	go b.batcher()
	return b
}
func NewEvalBatcher ( batchDuration time . Duration , raft DeploymentRaftEndpoints , ctx context . Context ) * EvalBatcher { b := & EvalBatcher { batch : batchDuration , raft : raft , ctx : ctx , inCh : make ( chan * structs . Evaluation , 10 ) , } go b . batcher ( ) return b }
NewEvalBatcher returns an EvalBatcher that uses the passed raft endpoints to
create the evaluations and exits the batcher when the passed exit channel is
closed.
NewEvalBatcher returns an EvalBatcher that uses the passed raft endpoints to create the evaluations and exits the batcher when the passed exit channel is closed .