|
65 | 65 | """ |
66 | 66 | # pylint: disable=protected-access |
67 | 67 |
|
68 | | -import base64 |
69 | 68 | import logging |
70 | | -import socket |
71 | | -from typing import Optional, Union |
72 | | - |
73 | | -from grpc import ( |
74 | | - ChannelCredentials, |
75 | | - insecure_channel, |
76 | | - secure_channel, |
77 | | - ssl_channel_credentials, |
78 | | -) |
79 | | -from thrift.protocol import TBinaryProtocol, TCompactProtocol |
80 | | -from thrift.transport import THttpClient, TTransport |
| 69 | +from os import environ |
| 70 | +from typing import Optional |
| 71 | + |
| 72 | +from grpc import ChannelCredentials, insecure_channel, secure_channel |
81 | 73 |
|
82 | | -from opentelemetry.configuration import Configuration |
83 | 74 | from opentelemetry.exporter.jaeger import util |
84 | 75 | from opentelemetry.exporter.jaeger.gen import model_pb2 |
85 | | -from opentelemetry.exporter.jaeger.gen.agent import Agent as agent |
86 | 76 | from opentelemetry.exporter.jaeger.gen.collector_pb2 import PostSpansRequest |
87 | 77 | from opentelemetry.exporter.jaeger.gen.collector_pb2_grpc import ( |
88 | 78 | CollectorServiceStub, |
|
92 | 82 | from opentelemetry.exporter.jaeger.translate import Translate |
93 | 83 | from opentelemetry.exporter.jaeger.translate.protobuf import ProtobufTranslator |
94 | 84 | from opentelemetry.exporter.jaeger.translate.thrift import ThriftTranslator |
95 | | -from opentelemetry.sdk.trace.export import Span, SpanExporter, SpanExportResult |
96 | | -from opentelemetry.trace import SpanKind |
97 | | -from opentelemetry.trace.status import StatusCode |
| 85 | +from opentelemetry.sdk.environment_variables import ( |
| 86 | + OTEL_EXPORTER_JAEGER_AGENT_HOST, |
| 87 | + OTEL_EXPORTER_JAEGER_AGENT_PORT, |
| 88 | + OTEL_EXPORTER_JAEGER_ENDPOINT, |
| 89 | + OTEL_EXPORTER_JAEGER_PASSWORD, |
| 90 | + OTEL_EXPORTER_JAEGER_USER, |
| 91 | +) |
| 92 | +from opentelemetry.sdk.trace.export import SpanExporter, SpanExportResult |
98 | 93 |
|
99 | 94 | DEFAULT_AGENT_HOST_NAME = "localhost" |
100 | 95 | DEFAULT_AGENT_PORT = 6831 |
@@ -142,30 +137,36 @@ def __init__( |
142 | 137 | self.service_name = service_name |
143 | 138 | self.agent_host_name = _parameter_setter( |
144 | 139 | param=agent_host_name, |
145 | | - env_variable=Configuration().EXPORTER_JAEGER_AGENT_HOST, |
| 140 | + env_variable=environ.get(OTEL_EXPORTER_JAEGER_AGENT_HOST), |
146 | 141 | default=DEFAULT_AGENT_HOST_NAME, |
147 | 142 | ) |
| 143 | + |
| 144 | + environ_agent_port = environ.get(OTEL_EXPORTER_JAEGER_AGENT_PORT) |
| 145 | + environ_agent_port = ( |
| 146 | + int(environ_agent_port) if environ_agent_port is not None else None |
| 147 | + ) |
| 148 | + |
148 | 149 | self.agent_port = _parameter_setter( |
149 | 150 | param=agent_port, |
150 | | - env_variable=Configuration().EXPORTER_JAEGER_AGENT_PORT, |
| 151 | + env_variable=environ_agent_port, |
151 | 152 | default=DEFAULT_AGENT_PORT, |
152 | 153 | ) |
153 | 154 | self._agent_client = AgentClientUDP( |
154 | 155 | host_name=self.agent_host_name, port=self.agent_port |
155 | 156 | ) |
156 | 157 | self.collector_endpoint = _parameter_setter( |
157 | 158 | param=collector_endpoint, |
158 | | - env_variable=Configuration().EXPORTER_JAEGER_ENDPOINT, |
| 159 | + env_variable=environ.get(OTEL_EXPORTER_JAEGER_ENDPOINT), |
159 | 160 | default=None, |
160 | 161 | ) |
161 | 162 | self.username = _parameter_setter( |
162 | 163 | param=username, |
163 | | - env_variable=Configuration().EXPORTER_JAEGER_USER, |
| 164 | + env_variable=environ.get(OTEL_EXPORTER_JAEGER_USER), |
164 | 165 | default=None, |
165 | 166 | ) |
166 | 167 | self.password = _parameter_setter( |
167 | 168 | param=password, |
168 | | - env_variable=Configuration().EXPORTER_JAEGER_PASSWORD, |
| 169 | + env_variable=environ.get(OTEL_EXPORTER_JAEGER_PASSWORD), |
169 | 170 | default=None, |
170 | 171 | ) |
171 | 172 | self._collector = None |
|
0 commit comments