Initial take on Sentinel support

Author: vladvildanov

tests/conftest.py

@@ -410,7 +410,7 @@ def sslclient(request):
 
 
 @pytest.fixture()
-def sentinel_setup(local_cache, request):
+def sentinel_setup(cache, request):
     sentinel_ips = request.config.getoption("--sentinels")
     sentinel_endpoints = [
         (ip.strip(), int(port.strip()))
@@ -420,7 +420,8 @@ def sentinel_setup(local_cache, request):
     sentinel = Sentinel(
         sentinel_endpoints,
         socket_timeout=0.1,
-        client_cache=local_cache,
+        use_cache=cache,
+        cache=cache,
         protocol=3,
         **kwargs,
     )

tests/test_cache.py

@@ -488,3 +488,21 @@ def test_cache_flushed_on_server_flush(self, r, cache):
         assert r.flushall()
         assert r.get("foo") is None
         assert cache.currsize == 0
+
+@pytest.mark.skipif(HIREDIS_AVAILABLE, reason="PythonParser only")
+@pytest.mark.onlynoncluster
+class TestSentinelCache:
+    def test_get_from_cache(self, cache, master):
+        master.set("foo", "bar")
+        # get key from redis and save in local cache
+        assert master.get("foo") == b"bar"
+        # get key from local cache
+        assert cache.get(("GET", "foo")) == b"bar"
+        # change key in redis (cause invalidation)
+        master.set("foo", "barbar")
+        # send any command to redis (process invalidation in background)
+        master.ping()
+        # the command is not in the local cache anymore
+        assert cache.get(("GET", "foo")) is None
+        # get key from redis
+        assert master.get("foo") == b"barbar"