Create a new RedisTimeSeries client.
(self, client=None, **kwargs)
| 49 | """ |
| 50 | |
| 51 | def __init__(self, client=None, **kwargs): |
| 52 | """Create a new RedisTimeSeries client.""" |
| 53 | # Set the module commands' callbacks |
| 54 | _MODULE_CALLBACKS = { |
| 55 | ALTER_CMD: bool_ok, |
| 56 | CREATE_CMD: bool_ok, |
| 57 | CREATERULE_CMD: bool_ok, |
| 58 | DELETERULE_CMD: bool_ok, |
| 59 | } |
| 60 | |
| 61 | _RESP2_MODULE_CALLBACKS = { |
| 62 | DEL_CMD: int, |
| 63 | GET_CMD: parse_get, |
| 64 | INFO_CMD: TSInfo, |
| 65 | MGET_CMD: parse_m_get, |
| 66 | MRANGE_CMD: parse_m_range, |
| 67 | MREVRANGE_CMD: parse_m_range, |
| 68 | QUERYINDEX_CMD: parse_to_list, |
| 69 | RANGE_CMD: parse_range, |
| 70 | REVRANGE_CMD: parse_range, |
| 71 | } |
| 72 | _RESP3_MODULE_CALLBACKS = {} |
| 73 | _RESP2_UNIFIED_MODULE_CALLBACKS = { |
| 74 | DEL_CMD: int, |
| 75 | GET_CMD: parse_get_unified, |
| 76 | INFO_CMD: TSInfo, |
| 77 | MGET_CMD: parse_m_get_unified, |
| 78 | MRANGE_CMD: parse_m_range_unified, |
| 79 | MREVRANGE_CMD: parse_m_range_unified, |
| 80 | RANGE_CMD: parse_range_unified, |
| 81 | REVRANGE_CMD: parse_range_unified, |
| 82 | } |
| 83 | _RESP3_UNIFIED_MODULE_CALLBACKS = { |
| 84 | DEL_CMD: int, |
| 85 | GET_CMD: parse_get_unified, |
| 86 | INFO_CMD: TSInfo, |
| 87 | MGET_CMD: parse_m_get_unified, |
| 88 | MRANGE_CMD: parse_m_range_unified, |
| 89 | MREVRANGE_CMD: parse_m_range_unified, |
| 90 | RANGE_CMD: parse_range_unified, |
| 91 | REVRANGE_CMD: parse_range_unified, |
| 92 | } |
| 93 | _RESP3_TO_RESP2_LEGACY_MODULE_CALLBACKS = { |
| 94 | DEL_CMD: int, |
| 95 | GET_CMD: parse_get, |
| 96 | INFO_CMD: TSInfo, |
| 97 | MGET_CMD: parse_m_get_resp3_to_resp2_legacy, |
| 98 | MRANGE_CMD: parse_m_range_resp3_to_resp2_legacy, |
| 99 | MREVRANGE_CMD: parse_m_range_resp3_to_resp2_legacy, |
| 100 | QUERYINDEX_CMD: parse_to_list, |
| 101 | RANGE_CMD: parse_range, |
| 102 | REVRANGE_CMD: parse_range, |
| 103 | } |
| 104 | |
| 105 | self.client = client |
| 106 | self.execute_command = client.execute_command |
| 107 | |
| 108 | self._MODULE_CALLBACKS = apply_module_callbacks( |
nothing calls this directly
no test coverage detected