1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
|
import logging
from typing import Deque
from typing import List
from typing import Optional
from py_zipkin.encoding._helpers import Span
from py_zipkin.storage import get_default_tracer
from py_zipkin.util import ZipkinAttrs
log = logging.getLogger("py_zipkin.thread_local")
def get_thread_local_zipkin_attrs() -> List[ZipkinAttrs]:
"""A wrapper to return _thread_local.zipkin_attrs
Returns a list of ZipkinAttrs objects, used for intra-process context
propagation.
.. deprecated::
Use the Tracer interface which offers better multi-threading support.
get_thread_local_zipkin_attrs will be removed in version 1.0.
:returns: list that may contain zipkin attribute tuples
:rtype: list
"""
log.warning(
"get_thread_local_zipkin_attrs is deprecated. See DEPRECATIONS.rst"
" for details on how to migrate to using Tracer."
)
return get_default_tracer()._context_stack._storage
def get_thread_local_span_storage() -> Deque[Span]:
"""A wrapper to return _thread_local.span_storage
Returns a SpanStorage object used to temporarily store all spans created in
the current process. The transport handlers will pull from this storage when
they emit the spans.
.. deprecated::
Use the Tracer interface which offers better multi-threading support.
get_thread_local_span_storage will be removed in version 1.0.
:returns: SpanStore object containing all non-root spans.
:rtype: py_zipkin.storage.SpanStore
"""
log.warning(
"get_thread_local_span_storage is deprecated. See DEPRECATIONS.rst"
" for details on how to migrate to using Tracer."
)
return get_default_tracer()._span_storage
def get_zipkin_attrs() -> Optional[ZipkinAttrs]:
"""Get the topmost level zipkin attributes stored.
.. deprecated::
Use the Tracer interface which offers better multi-threading support.
get_zipkin_attrs will be removed in version 1.0.
:returns: tuple containing zipkin attrs
:rtype: :class:`zipkin.ZipkinAttrs`
"""
from py_zipkin.storage import ThreadLocalStack
log.warning(
"get_zipkin_attrs is deprecated. See DEPRECATIONS.rst for"
"details on how to migrate to using Tracer."
)
return ThreadLocalStack().get()
def pop_zipkin_attrs() -> Optional[ZipkinAttrs]:
"""Pop the topmost level zipkin attributes, if present.
.. deprecated::
Use the Tracer interface which offers better multi-threading support.
pop_zipkin_attrs will be removed in version 1.0.
:returns: tuple containing zipkin attrs
:rtype: :class:`zipkin.ZipkinAttrs`
"""
from py_zipkin.storage import ThreadLocalStack
log.warning(
"pop_zipkin_attrs is deprecated. See DEPRECATIONS.rst for"
"details on how to migrate to using Tracer."
)
return ThreadLocalStack().pop()
def push_zipkin_attrs(zipkin_attr: ZipkinAttrs) -> None:
"""Stores the zipkin attributes to thread local.
.. deprecated::
Use the Tracer interface which offers better multi-threading support.
push_zipkin_attrs will be removed in version 1.0.
:param zipkin_attr: tuple containing zipkin related attrs
:type zipkin_attr: :class:`zipkin.ZipkinAttrs`
"""
from py_zipkin.storage import ThreadLocalStack
log.warning(
"push_zipkin_attrs is deprecated. See DEPRECATIONS.rst for"
"details on how to migrate to using Tracer."
)
ThreadLocalStack().push(zipkin_attr)
|
