18
18
from unittest .mock import patch
19
19
20
20
from opentelemetry import trace
21
- from opentelemetry .exporter .zipkin import DEFAULT_ENDPOINT , ZipkinSpanExporter
21
+ from opentelemetry .exporter .zipkin import DEFAULT_ENDPOINT , ZipkinExporter
22
22
from opentelemetry .exporter .zipkin .encoder import Protocol
23
23
from opentelemetry .exporter .zipkin .encoder .v2 .protobuf import ProtobufEncoder
24
24
from opentelemetry .exporter .zipkin .node_endpoint import NodeEndpoint
@@ -38,7 +38,7 @@ def __init__(self, status_code):
38
38
self .text = status_code
39
39
40
40
41
- class TestZipkinSpanExporter (unittest .TestCase ):
41
+ class TestZipkinExporter (unittest .TestCase ):
42
42
@classmethod
43
43
def setUpClass (cls ):
44
44
trace .set_tracer_provider (
@@ -52,7 +52,7 @@ def tearDown(self):
52
52
del os .environ [OTEL_EXPORTER_ZIPKIN_ENDPOINT ]
53
53
54
54
def test_constructor_default (self ):
55
- exporter = ZipkinSpanExporter (Protocol .V2_PROTOBUF )
55
+ exporter = ZipkinExporter (Protocol .V2_PROTOBUF )
56
56
self .assertIsInstance (exporter .encoder , ProtobufEncoder )
57
57
self .assertEqual (exporter .endpoint , DEFAULT_ENDPOINT )
58
58
self .assertEqual (exporter .local_node .service_name , TEST_SERVICE_NAME )
@@ -64,7 +64,7 @@ def test_constructor_env_vars(self):
64
64
os_endpoint = "https://foo:9911/path"
65
65
os .environ [OTEL_EXPORTER_ZIPKIN_ENDPOINT ] = os_endpoint
66
66
67
- exporter = ZipkinSpanExporter (Protocol .V2_PROTOBUF )
67
+ exporter = ZipkinExporter (Protocol .V2_PROTOBUF )
68
68
69
69
self .assertEqual (exporter .endpoint , os_endpoint )
70
70
self .assertEqual (exporter .local_node .service_name , TEST_SERVICE_NAME )
@@ -78,7 +78,7 @@ def test_constructor_protocol_endpoint(self):
78
78
protocol = Protocol .V2_PROTOBUF
79
79
endpoint = "https://opentelemetry.io:15875/myapi/traces?format=zipkin"
80
80
81
- exporter = ZipkinSpanExporter (protocol , endpoint )
81
+ exporter = ZipkinExporter (protocol , endpoint )
82
82
83
83
self .assertIsInstance (exporter .encoder , ProtobufEncoder )
84
84
self .assertEqual (exporter .endpoint , endpoint )
@@ -101,7 +101,7 @@ def test_constructor_all_params_and_env_vars(self):
101
101
local_node_port = 30301
102
102
max_tag_value_length = 56
103
103
104
- exporter = ZipkinSpanExporter (
104
+ exporter = ZipkinExporter (
105
105
constructor_param_protocol ,
106
106
constructor_param_endpoint ,
107
107
local_node_ipv4 ,
@@ -125,7 +125,7 @@ def test_constructor_all_params_and_env_vars(self):
125
125
def test_invalid_response (self , mock_post ):
126
126
mock_post .return_value = MockResponse (404 )
127
127
spans = []
128
- exporter = ZipkinSpanExporter (Protocol .V2_PROTOBUF )
128
+ exporter = ZipkinExporter (Protocol .V2_PROTOBUF )
129
129
status = exporter .export (spans )
130
130
self .assertEqual (SpanExportResult .FAILURE , status )
131
131
0 commit comments