In Jaeger Config, enable to add directly a sampler

jaeger_client/config.py

@@ -33,7 +33,7 @@
     ProbabilisticSampler,
     RateLimitingSampler,
     RemoteControlledSampler,
-)
+    Sampler)
 from .constants import (
     DEFAULT_SAMPLING_INTERVAL,
     DEFAULT_FLUSH_INTERVAL,
@@ -220,6 +220,8 @@ def max_traceback_length(self):
     @property
     def sampler(self):
         sampler_config = self.config.get('sampler', {})
+        if isinstance(sampler_config, Sampler):
+            return sampler_config
         sampler_type = sampler_config.get('type', None)
         sampler_param = sampler_config.get('param', None)
         if not sampler_type:

tests/test_config.py

@@ -13,14 +13,18 @@
 # limitations under the License.
 
 from __future__ import absolute_import
+
 import os
 import unittest
+
 import opentracing.tracer
+
 from jaeger_client import Config, ConstSampler, ProbabilisticSampler, RateLimitingSampler
+from jaeger_client import constants
 from jaeger_client.config import DEFAULT_THROTTLER_PORT
 from jaeger_client.metrics import MetricsFactory
 from jaeger_client.reporter import NullReporter
-from jaeger_client import constants
+from tests.test_utils import TestSampler
 
 
 class ConfigTests(unittest.TestCase):
@@ -80,6 +84,11 @@ def test_bad_sampler(self):
         with self.assertRaises(ValueError):
             c.sampler.is_sampled(0)
 
+    def test_object_sampler_sampler(self):
+        sampler = TestSampler()
+        c = Config({'sampler': sampler}, service_name='x')
+        assert c.sampler is sampler
+
     def test_agent_reporting_host(self):
         c = Config({}, service_name='x')
         assert c.local_agent_reporting_host == 'localhost'

tests/test_utils.py

@@ -18,6 +18,7 @@
 import unittest
 
 from jaeger_client import utils
+from jaeger_client.sampler import Sampler
 
 
 class ConfigTests(unittest.TestCase):
@@ -43,10 +44,10 @@ def test_get_unknown_boolean(self):
     def test_get_None_boolean(self):
         self.check_boolean(None, 'qwer', False)
 
-#    def test_error_reporter_doesnt_send_metrics_if_not_configured(self):
-#        er = utils.ErrorReporter(False)
-#        er.error('foo', 1)
-#        assert not mock_metrics.count.called
+    #    def test_error_reporter_doesnt_send_metrics_if_not_configured(self):
+    #        er = utils.ErrorReporter(False)
+    #        er.error('foo', 1)
+    #        assert not mock_metrics.count.called
 
     def test_error_reporter_sends_metrics_if_configured(self):
         mock_metrics = mock.MagicMock()
@@ -81,3 +82,7 @@ def test_local_ip_does_not_blow_up():
 def test_get_local_ip_by_socket_does_not_blow_up():
     import jaeger_client.utils
     jaeger_client.utils.get_local_ip_by_socket()
+
+
+class TestSampler(Sampler):
+    pass