diff options
author | Erik Johnston <erik@matrix.org> | 2022-04-07 13:18:29 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-04-07 13:18:29 +0100 |
commit | d1cd96ce2966bc5bd268eac56a485e785779e9e0 (patch) | |
tree | fc2663cc7ce2d4ef3f9905be68dd487639657960 /synapse/replication/tcp/external_cache.py | |
parent | Poetry: use locked environment in Docker images (#12385) (diff) | |
download | synapse-d1cd96ce2966bc5bd268eac56a485e785779e9e0.tar.xz |
Add opentracing spans to calls to external cache (#12380)
Diffstat (limited to 'synapse/replication/tcp/external_cache.py')
-rw-r--r-- | synapse/replication/tcp/external_cache.py | 31 |
1 files changed, 20 insertions, 11 deletions
diff --git a/synapse/replication/tcp/external_cache.py b/synapse/replication/tcp/external_cache.py index bf7d017968..a448dd7eb1 100644 --- a/synapse/replication/tcp/external_cache.py +++ b/synapse/replication/tcp/external_cache.py @@ -17,6 +17,7 @@ from typing import TYPE_CHECKING, Any, Optional from prometheus_client import Counter, Histogram +from synapse.logging import opentracing from synapse.logging.context import make_deferred_yieldable from synapse.util import json_decoder, json_encoder @@ -93,14 +94,18 @@ class ExternalCache: logger.debug("Caching %s %s: %r", cache_name, key, encoded_value) - with response_timer.labels("set").time(): - return await make_deferred_yieldable( - self._redis_connection.set( - self._get_redis_key(cache_name, key), - encoded_value, - pexpire=expiry_ms, + with opentracing.start_active_span( + "ExternalCache.set", + tags={opentracing.SynapseTags.CACHE_NAME: cache_name}, + ): + with response_timer.labels("set").time(): + return await make_deferred_yieldable( + self._redis_connection.set( + self._get_redis_key(cache_name, key), + encoded_value, + pexpire=expiry_ms, + ) ) - ) async def get(self, cache_name: str, key: str) -> Optional[Any]: """Look up a key/value in the named cache.""" @@ -108,10 +113,14 @@ class ExternalCache: if self._redis_connection is None: return None - with response_timer.labels("get").time(): - result = await make_deferred_yieldable( - self._redis_connection.get(self._get_redis_key(cache_name, key)) - ) + with opentracing.start_active_span( + "ExternalCache.get", + tags={opentracing.SynapseTags.CACHE_NAME: cache_name}, + ): + with response_timer.labels("get").time(): + result = await make_deferred_yieldable( + self._redis_connection.get(self._get_redis_key(cache_name, key)) + ) logger.debug("Got cache result %s %s: %r", cache_name, key, result) |