Skip to content

Commit 7240154

Browse files
authored
Added KV and Object store instrumentations. (#52)
1 parent da02f19 commit 7240154

File tree

4 files changed

+841
-0
lines changed

4 files changed

+841
-0
lines changed

python/natsrpy/instrumentation/__init__.py

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,9 @@ async def main() -> None:
4040

4141
from .js_consumer import JSConsumerInstrumentation
4242
from .js_publish import JSPublishInstrumentation
43+
from .kv import KVInstrumentation
4344
from .nats_core import NatsCoreInstrumentator
45+
from .object_store import ObjectStoreInstrumentation
4446

4547
try:
4648
import opentelemetry # noqa: F401
@@ -105,8 +107,18 @@ def _instrument(self, **kwargs: Any) -> None:
105107
capture_body=capture_body,
106108
capture_headers=capture_headers,
107109
).instrument()
110+
KVInstrumentation(
111+
tracer,
112+
capture_body=capture_body,
113+
).instrument()
114+
ObjectStoreInstrumentation(
115+
tracer,
116+
capture_body=capture_body,
117+
).instrument()
108118

109119
def _uninstrument(self, **kwargs: Any) -> None:
110120
NatsCoreInstrumentator.uninstrument()
111121
JSConsumerInstrumentation.uninstrument()
112122
JSPublishInstrumentation.uninstrument()
123+
KVInstrumentation.uninstrument()
124+
ObjectStoreInstrumentation.uninstrument()

0 commit comments

Comments
 (0)