Remove deprecated transports (#452)

Replace trace transports with common transports, increasing default batch size
and changing behavior on exit.

Author: kornholi

README.rst

@@ -158,13 +158,12 @@ This example shows how to configure Census to use a background thread:
 
 .. code:: python
 
+    from opencensus.common.transport.async_ import AsyncTransport
     from opencensus.trace.exporters import stackdriver_exporter
     from opencensus.trace import tracer as tracer_module
-    from opencensus.trace.exporters.transports.background_thread \
-        import BackgroundThreadTransport
 
     exporter = stackdriver_exporter.StackdriverExporter(
-        project_id='your_cloud_project', transport=BackgroundThreadTransport)
+        project_id='your_cloud_project', transport=AsyncTransport)
     tracer = tracer_module.Tracer(exporter=exporter)
 
 Propagators

opencensus/common/transports/async_.py

@@ -22,7 +22,7 @@
 from opencensus.common.transports import base
 
 _DEFAULT_GRACE_PERIOD = 5.0  # Seconds
-_DEFAULT_MAX_BATCH_SIZE = 200
+_DEFAULT_MAX_BATCH_SIZE = 600
 _WAIT_PERIOD = 60.0  # Seconds
 _WORKER_THREAD_NAME = 'opencensus.common.Worker'
 _WORKER_TERMINATOR = object()

opencensus/trace/exporters/file_exporter.py

@@ -16,9 +16,9 @@
 
 import json
 
+from opencensus.common.transports import sync
 from opencensus.trace import span_data
 from opencensus.trace.exporters import base
-from opencensus.trace.exporters.transports import sync
 
 DEFAULT_FILENAME = 'opencensus-traces.json'
 
@@ -33,7 +33,7 @@ class FileExporter(base.Exporter):
                       extend from the base :class:`.Transport` type and
                       implement :meth:`.Transport.export`. Defaults to
                       :class:`.SyncTransport`. The other option is
-                      :class:`.BackgroundThreadTransport`.
+                      :class:`.AsyncTransport`.
 
     :type file_mode: str
     :param file_mode: The file mode to open the output file with.

opencensus/trace/exporters/jaeger_exporter.py

@@ -20,11 +20,11 @@
 from thrift.protocol import TBinaryProtocol, TCompactProtocol
 from thrift.transport import THttpClient, TTransport
 
+from opencensus.common.transports import sync
 from opencensus.common.utils import timestamp_to_microseconds
 from opencensus.trace import link as link_module
 from opencensus.trace.exporters import base
 from opencensus.trace.exporters.gen.jaeger import agent, jaeger
-from opencensus.trace.exporters.transports import sync
 
 DEFAULT_HOST_NAME = 'localhost'
 DEFAULT_AGENT_PORT = 6831
@@ -71,7 +71,7 @@ class JaegerExporter(base.Exporter):
                       extend from the base :class:`.Transport` type and
                       implement :meth:`.Transport.export`. Defaults to
                       :class:`.SyncTransport`. The other option is
-                      :class:`.BackgroundThreadTransport`.
+                      :class:`.AsyncTransport`.
     """
 
     def __init__(
@@ -332,7 +332,7 @@ class Collector(base.Exporter):
                       extend from the base :class:`.Transport` type and
                       implement :meth:`.Transport.export`. Defaults to
                       :class:`.SyncTransport`. The other option is
-                      :class:`.BackgroundThreadTransport`.
+                      :class:`.AsyncTransport`.
 
     :type http_transport: :class:`type`
     :param http_transport: Class for creating new client for Thrift
@@ -414,7 +414,7 @@ class AgentClientUDP(base.Exporter):
                       extend from the base :class:`.Transport` type and
                       implement :meth:`.Transport.export`. Defaults to
                       :class:`.SyncTransport`. The other option is
-                      :class:`.BackgroundThreadTransport`.
+                      :class:`.AsyncTransport`.
     """
 
     def __init__(

opencensus/trace/exporters/logging_exporter.py

@@ -16,9 +16,9 @@
 
 import logging
 
+from opencensus.common.transports import sync
 from opencensus.trace import span_data
 from opencensus.trace.exporters import base
-from opencensus.trace.exporters.transports import sync
 
 
 class LoggingExporter(base.Exporter):
@@ -33,7 +33,7 @@ class LoggingExporter(base.Exporter):
                       extend from the base :class:`.Transport` type and
                       implement :meth:`.Transport.export`. Defaults to
                       :class:`.SyncTransport`. The other option is
-                      :class:`.BackgroundThreadTransport`.
+                      :class:`.AsyncTransport`.
 
     Example:
 

opencensus/trace/exporters/ocagent/trace_exporter.py

@@ -20,6 +20,7 @@
 import socket
 
 from opencensus.__version__ import __version__
+from opencensus.common.transports import sync
 from opencensus.trace.exporters import base
 from opencensus.trace.exporters.gen.opencensus.agent.common.v1 \
     import common_pb2
@@ -28,7 +29,6 @@
 from opencensus.trace.exporters.gen.opencensus.agent.trace.v1 \
     import trace_service_pb2_grpc
 from opencensus.trace.exporters.ocagent import utils
-from opencensus.trace.exporters.transports import sync
 
 # Default agent endpoint
 DEFAULT_ENDPOINT = 'localhost:55678'
@@ -57,7 +57,7 @@ class TraceExporter(base.Exporter):
                       extend from the base :class:`.Transport` type and
                       implement :meth:`.Transport.export`. Defaults to
                       :class:`.SyncTransport`. The other option is
-                      :class:`.BackgroundThreadTransport`.
+                      :class:`.AsyncTransport`.
     """
 
     def __init__(

opencensus/trace/exporters/print_exporter.py

@@ -14,8 +14,8 @@
 
 """Export the trace spans by printing them out."""
 
+from opencensus.common.transports import sync
 from opencensus.trace.exporters import base
-from opencensus.trace.exporters.transports import sync
 
 
 class PrintExporter(base.Exporter):
@@ -26,7 +26,7 @@ class PrintExporter(base.Exporter):
                       extend from the base :class:`.Transport` type and
                       implement :meth:`.Transport.export`. Defaults to
                       :class:`.SyncTransport`. The other option is
-                      :class:`.BackgroundThreadTransport`.
+                      :class:`.AsyncTransport`.
     """
 
     def __init__(self, transport=sync.SyncTransport):

opencensus/trace/exporters/stackdriver_exporter.py

@@ -20,11 +20,11 @@
 from opencensus.__version__ import __version__
 from opencensus.common.monitored_resource_util.monitored_resource_util \
     import MonitoredResourceUtil
+from opencensus.common.transports import sync
 from opencensus.trace import attributes_helper
 from opencensus.trace import span_data
 from opencensus.trace.attributes import Attributes
 from opencensus.trace.exporters import base
-from opencensus.trace.exporters.transports import sync
 
 # Agent
 AGENT = 'opencensus-python [{}]'.format(__version__)
@@ -188,7 +188,7 @@ class StackdriverExporter(base.Exporter):
                       extend from the base :class:`.Transport` type and
                       implement :meth:`.Transport.export`. Defaults to
                       :class:`.SyncTransport`. The other option is
-                      :class:`.BackgroundThreadTransport`.
+                      :class:`.AsyncTransport`.
     """
 
     def __init__(self, client=None, project_id=None,