lib/ci/queue/configuration.rb in ci-queue-0.12.0 vs lib/ci/queue/configuration.rb in ci-queue-0.12.1

@@ -1,18 +1,20 @@
 
 module CI
   module Queue
     class Configuration
-      attr_accessor :timeout, :build_id, :worker_id, :max_requeues, :requeue_tolerance, :namespace, :seed, :failing_test
+      attr_accessor :timeout, :build_id, :worker_id, :max_requeues
+      attr_accessor :requeue_tolerance, :namespace, :seed, :failing_test, :statsd_endpoint
 
       class << self
         def from_env(env)
           new(
             build_id: env['CIRCLE_BUILD_URL'] || env['BUILDKITE_BUILD_ID'] || env['TRAVIS_BUILD_ID'],
             worker_id: env['CIRCLE_NODE_INDEX'] || env['BUILDKITE_PARALLEL_JOB'],
             seed: env['CIRCLE_SHA1'] || env['BUILDKITE_COMMIT'] || env['TRAVIS_COMMIT'],
             flaky_tests: load_flaky_tests(env['CI_QUEUE_FLAKY_TESTS']),
+            statsd_endpoint: env['CI_QUEUE_STATSD_ADDR'],
           )
         end
 
         def load_flaky_tests(path)
           return [] unless path
@@ -22,19 +24,20 @@
         end
       end
 
       def initialize(
         timeout: 30, build_id: nil, worker_id: nil, max_requeues: 0, requeue_tolerance: 0,
-        namespace: nil, seed: nil, flaky_tests: []
+        namespace: nil, seed: nil, flaky_tests: [], statsd_endpoint: nil
       )
         @namespace = namespace
         @timeout = timeout
         @build_id = build_id
         @worker_id = worker_id
         @max_requeues = max_requeues
         @requeue_tolerance = requeue_tolerance
         @seed = seed
         @flaky_tests = flaky_tests
+        @statsd_endpoint = statsd_endpoint
       end
 
       def flaky?(test)
         @flaky_tests.include?(test.id)
       end