[redis] update to 4.3.5 (#9284)

This commit is contained in:
Nikita Sobolev
2022-11-28 09:23:51 +03:00
committed by GitHub
parent 7806607df9
commit a29624ee42
3 changed files with 124 additions and 64 deletions

View File

@@ -1 +1 @@
version = "4.3.4"
version = "4.3.5"

View File

@@ -88,14 +88,14 @@ class TOPKCommands:
def info(self, key): ...
class TDigestCommands:
def create(self, key, compression): ...
def create(self, key, compression: int = ...): ...
def reset(self, key): ...
def add(self, key, values, weights): ...
def merge(self, toKey, fromKey): ...
def add(self, key, values): ...
def merge(self, destination_key, num_keys, *keys, compression: int | None = ..., override: bool = ...): ...
def min(self, key): ...
def max(self, key): ...
def quantile(self, key, quantile): ...
def cdf(self, key, value): ...
def quantile(self, key, quantile, *quantiles): ...
def cdf(self, key, value, *values): ...
def info(self, key): ...
class CMSCommands:

View File

@@ -1,5 +1,6 @@
from typing import Any
from typing_extensions import Literal
from typing_extensions import Literal, TypeAlias
_Key: TypeAlias = bytes | str | memoryview
ADD_CMD: Literal["TS.ADD"]
ALTER_CMD: Literal["TS.ALTER"]
@@ -20,76 +21,135 @@ RANGE_CMD: Literal["TS.RANGE"]
REVRANGE_CMD: Literal["TS.REVRANGE"]
class TimeSeriesCommands:
def create(self, key, **kwargs): ...
def alter(self, key, **kwargs): ...
def add(self, key, timestamp, value, **kwargs): ...
def create(
self,
key: _Key,
retention_msecs: int | None = ...,
uncompressed: bool | None = ...,
labels: dict[str, str] | None = ...,
chunk_size: int | None = ...,
duplicate_policy: str | None = ...,
): ...
def alter(
self,
key: _Key,
retention_msecs: int | None = ...,
labels: dict[str, str] | None = ...,
chunk_size: int | None = ...,
duplicate_policy: str | None = ...,
): ...
def add(
self,
key: _Key,
timestamp: int | str,
value: float,
retention_msecs: int | None = ...,
uncompressed: bool | None = ...,
labels: dict[str, str] | None = ...,
chunk_size: int | None = ...,
duplicate_policy: str | None = ...,
): ...
def madd(self, ktv_tuples): ...
def incrby(self, key, value, **kwargs): ...
def decrby(self, key, value, **kwargs): ...
def incrby(
self,
key: _Key,
value: float,
timestamp: int | str | None = ...,
retention_msecs: int | None = ...,
uncompressed: bool | None = ...,
labels: dict[str, str] | None = ...,
chunk_size: int | None = ...,
): ...
def decrby(
self,
key: _Key,
value: float,
timestamp: int | str | None = ...,
retention_msecs: int | None = ...,
uncompressed: bool | None = ...,
labels: dict[str, str] | None = ...,
chunk_size: int | None = ...,
): ...
def delete(self, key, from_time, to_time): ...
def createrule(self, source_key, dest_key, aggregation_type, bucket_size_msec): ...
def createrule(
self, source_key: _Key, dest_key: _Key, aggregation_type: str, bucket_size_msec: int, align_timestamp: int | None = ...
): ...
def deleterule(self, source_key, dest_key): ...
def range(
self,
key,
from_time,
to_time,
count: Any | None = ...,
aggregation_type: Any | None = ...,
bucket_size_msec: int = ...,
filter_by_ts: Any | None = ...,
filter_by_min_value: Any | None = ...,
filter_by_max_value: Any | None = ...,
align: Any | None = ...,
key: _Key,
from_time: int | str,
to_time: int | str,
count: int | None = ...,
aggregation_type: str | None = ...,
bucket_size_msec: int | None = ...,
filter_by_ts: list[int] | None = ...,
filter_by_min_value: int | None = ...,
filter_by_max_value: int | None = ...,
align: int | str | None = ...,
latest: bool | None = ...,
bucket_timestamp: str | None = ...,
empty: bool | None = ...,
): ...
def revrange(
self,
key,
from_time,
to_time,
count: Any | None = ...,
aggregation_type: Any | None = ...,
bucket_size_msec: int = ...,
filter_by_ts: Any | None = ...,
filter_by_min_value: Any | None = ...,
filter_by_max_value: Any | None = ...,
align: Any | None = ...,
key: _Key,
from_time: int | str,
to_time: int | str,
count: int | None = ...,
aggregation_type: str | None = ...,
bucket_size_msec: int | None = ...,
filter_by_ts: list[int] | None = ...,
filter_by_min_value: int | None = ...,
filter_by_max_value: int | None = ...,
align: int | str | None = ...,
latest: bool | None = ...,
bucket_timestamp: str | None = ...,
empty: bool | None = ...,
): ...
def mrange(
self,
from_time,
to_time,
filters,
count: Any | None = ...,
aggregation_type: Any | None = ...,
bucket_size_msec: int = ...,
with_labels: bool = ...,
filter_by_ts: Any | None = ...,
filter_by_min_value: Any | None = ...,
filter_by_max_value: Any | None = ...,
groupby: Any | None = ...,
reduce: Any | None = ...,
select_labels: Any | None = ...,
align: Any | None = ...,
from_time: int | str,
to_time: int | str,
filters: list[str],
count: int | None = ...,
aggregation_type: str | None = ...,
bucket_size_msec: int | None = ...,
with_labels: bool | None = ...,
filter_by_ts: list[int] | None = ...,
filter_by_min_value: int | None = ...,
filter_by_max_value: int | None = ...,
groupby: str | None = ...,
reduce: str | None = ...,
select_labels: list[str] | None = ...,
align: int | str | None = ...,
latest: bool | None = ...,
bucket_timestamp: str | None = ...,
empty: bool | None = ...,
): ...
def mrevrange(
self,
from_time,
to_time,
filters,
count: Any | None = ...,
aggregation_type: Any | None = ...,
bucket_size_msec: int = ...,
with_labels: bool = ...,
filter_by_ts: Any | None = ...,
filter_by_min_value: Any | None = ...,
filter_by_max_value: Any | None = ...,
groupby: Any | None = ...,
reduce: Any | None = ...,
select_labels: Any | None = ...,
align: Any | None = ...,
from_time: int | str,
to_time: int | str,
filters: list[str],
count: int | None = ...,
aggregation_type: str | None = ...,
bucket_size_msec: int | None = ...,
with_labels: bool | None = ...,
filter_by_ts: list[int] | None = ...,
filter_by_min_value: int | None = ...,
filter_by_max_value: int | None = ...,
groupby: str | None = ...,
reduce: str | None = ...,
select_labels: list[str] | None = ...,
align: int | str | None = ...,
latest: bool | None = ...,
bucket_timestamp: str | None = ...,
empty: bool | None = ...,
): ...
def get(self, key: _Key, latest: bool | None = ...): ...
def mget(
self, filters: list[str], with_labels: bool | None = ..., select_labels: list[str] | None = ..., latest: bool | None = ...
): ...
def get(self, key): ...
def mget(self, filters, with_labels: bool = ...): ...
def info(self, key): ...
def queryindex(self, filters): ...