From a29624ee427bf61f2d3e9a28a0faa473609cc67e Mon Sep 17 00:00:00 2001 From: Nikita Sobolev Date: Mon, 28 Nov 2022 09:23:51 +0300 Subject: [PATCH] [redis] update to 4.3.5 (#9284) --- stubs/redis/METADATA.toml | 2 +- stubs/redis/redis/commands/bf/commands.pyi | 10 +- .../redis/commands/timeseries/commands.pyi | 176 ++++++++++++------ 3 files changed, 124 insertions(+), 64 deletions(-) diff --git a/stubs/redis/METADATA.toml b/stubs/redis/METADATA.toml index fc9dee027..b94ebe27b 100644 --- a/stubs/redis/METADATA.toml +++ b/stubs/redis/METADATA.toml @@ -1 +1 @@ -version = "4.3.4" +version = "4.3.5" diff --git a/stubs/redis/redis/commands/bf/commands.pyi b/stubs/redis/redis/commands/bf/commands.pyi index 5036d1108..65a963d85 100644 --- a/stubs/redis/redis/commands/bf/commands.pyi +++ b/stubs/redis/redis/commands/bf/commands.pyi @@ -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: diff --git a/stubs/redis/redis/commands/timeseries/commands.pyi b/stubs/redis/redis/commands/timeseries/commands.pyi index 4a5a19af1..dc15c8506 100644 --- a/stubs/redis/redis/commands/timeseries/commands.pyi +++ b/stubs/redis/redis/commands/timeseries/commands.pyi @@ -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): ...