Internal compressed query message helper.
(
options: int,
collection_name: str,
num_to_skip: int,
num_to_return: int,
query: Mapping[str, Any],
field_selector: Optional[Mapping[str, Any]],
opts: CodecOptions[Any],
ctx: Union[SnappyContext, ZlibContext, ZstdContext],
)
| 455 | |
| 456 | |
| 457 | def _query_compressed( |
| 458 | options: int, |
| 459 | collection_name: str, |
| 460 | num_to_skip: int, |
| 461 | num_to_return: int, |
| 462 | query: Mapping[str, Any], |
| 463 | field_selector: Optional[Mapping[str, Any]], |
| 464 | opts: CodecOptions[Any], |
| 465 | ctx: Union[SnappyContext, ZlibContext, ZstdContext], |
| 466 | ) -> tuple[int, bytes, int]: |
| 467 | """Internal compressed query message helper.""" |
| 468 | op_query, max_bson_size = _query_impl( |
| 469 | options, collection_name, num_to_skip, num_to_return, query, field_selector, opts |
| 470 | ) |
| 471 | rid, msg = _compress(2004, op_query, ctx) |
| 472 | return rid, msg, max_bson_size |
| 473 | |
| 474 | |
| 475 | def _query_uncompressed( |
no test coverage detected