Skip to content

Commit 1985831

Browse files
committed
adjust cluster methods
1 parent ec9af24 commit 1985831

File tree

2 files changed

+22
-2
lines changed

2 files changed

+22
-2
lines changed

django_valkey/cluster_cache/cache.py

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,12 +5,30 @@
55

66

77
class ClusterCommands:
8+
def msetnx(self: "ClusterValkeyCache", *args, **kwargs):
9+
return self.client.msetnx(*args, **kwargs)
10+
811
def mget_nonatomic(self: "ClusterValkeyCache", *args, **kwargs):
912
return self.client.mget_nonatomic(*args, **kwargs)
1013

1114
def mset_nonatomic(self: "ClusterValkeyCache", *args, **kwargs):
1215
return self.client.mset_nonatomic(*args, **kwargs)
1316

17+
def readonly(self: "ClusterValkeyCache", *args, **kwargs):
18+
return self.client.readonly(*args, **kwargs)
19+
20+
def readwrite(self: "ClusterValkeyCache", *args, **kwargs):
21+
return self.client.readwrite(*args, **kwargs)
22+
23+
def keyslot(self: "ClusterValkeyCache", *args, **kwargs):
24+
return self.client.keyslot(*args, **kwargs)
25+
26+
def flushall(self: "ClusterValkeyCache", *args, **kwargs):
27+
return self.client.flushall(*args, **kwargs)
28+
29+
def invalidate_key_from_cache(self: "ClusterValkeyCache", *args, **kwargs):
30+
return self.client.invalidate_key_from_cache(*args, **kwargs)
31+
1432

1533
class ClusterValkeyCache(
1634
BaseValkeyCache[DefaultClusterClient, ValkeyCluster],

django_valkey/cluster_cache/client/default.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -93,14 +93,16 @@ def mget_nonatomic(self, keys, version=None, client=None):
9393
recovered_data[map_keys[key]] = self.decode(value)
9494
return recovered_data
9595

96+
get_many = mget_nonatomic
97+
9698
def keyslot(self, key, version=None, client=None):
9799
client = self._get_client(client=client)
98100
key = self.make_key(key, version=version)
99101
return client.keyslot(key)
100102

101-
def flush_cache(self, client=None):
103+
def flushall(self, asynchronous=False, client=None):
102104
client = self._get_client(client=client)
103-
return client.flush_cache()
105+
return client.flushall(asynchronous=asynchronous)
104106

105107
def invalidate_key_from_cache(self, client=None):
106108
client = self._get_client(client=client)

0 commit comments

Comments
 (0)