@@ -67,7 +67,7 @@ impl PyObjectProtocol for Stats {
67
67
68
68
/// The main reporter class.
69
69
#[ pyclass]
70
- #[ text_signature = "()" ]
70
+ #[ pyo3 ( text_signature = "()" ) ]
71
71
struct Reporter {
72
72
span_sender : Sender < thrift_gen:: jaeger:: Span > ,
73
73
process_sender : Sender < thrift_gen:: jaeger:: Process > ,
@@ -179,7 +179,7 @@ impl Reporter {
179
179
}
180
180
181
181
/// Sets the process information needed to report spans.
182
- #[ text_signature = "($self, service_name, tags, max_length, /)" ]
182
+ #[ pyo3 ( text_signature = "($self, service_name, tags, max_length, /)" ) ]
183
183
fn set_process (
184
184
self_ : PyRef < Self > ,
185
185
service_name : String ,
@@ -200,7 +200,7 @@ impl Reporter {
200
200
}
201
201
202
202
/// Queue a span to be reported to local jaeger agent.
203
- #[ text_signature = "($self, span, /)" ]
203
+ #[ pyo3 ( text_signature = "($self, span, /)" ) ]
204
204
fn report_span ( & self , py : Python , py_span : Py < PyAny > ) -> PyResult < ( ) > {
205
205
// This may fail if the queue is full. We should probably log something
206
206
// somehow?
@@ -217,7 +217,7 @@ impl Reporter {
217
217
Ok ( ( ) )
218
218
}
219
219
220
- #[ text_signature = "($self, /)" ]
220
+ #[ pyo3 ( text_signature = "($self, /)" ) ]
221
221
fn get_stats ( & self ) -> Stats {
222
222
let queue_size = self . queue_size . load ( Ordering :: Relaxed ) ;
223
223
let sent_batches = self . sent_batches . load ( Ordering :: Relaxed ) ;
0 commit comments