(self, r)
| 2630 | # SCAN COMMANDS |
| 2631 | @skip_if_server_version_lt("2.8.0") |
| 2632 | def test_cluster_scan(self, r): |
| 2633 | r.set("a", 1) |
| 2634 | r.set("b", 2) |
| 2635 | r.set("c", 3) |
| 2636 | |
| 2637 | for target_nodes, nodes in zip( |
| 2638 | ["primaries", "replicas"], [r.get_primaries(), r.get_replicas()] |
| 2639 | ): |
| 2640 | cursors, keys = r.scan(target_nodes=target_nodes) |
| 2641 | assert sorted(keys) == [b"a", b"b", b"c"] |
| 2642 | assert sorted(cursors.keys()) == sorted(node.name for node in nodes) |
| 2643 | assert all(cursor == 0 for cursor in cursors.values()) |
| 2644 | |
| 2645 | cursors, keys = r.scan(match="a*", target_nodes=target_nodes) |
| 2646 | assert sorted(keys) == [b"a"] |
| 2647 | assert sorted(cursors.keys()) == sorted(node.name for node in nodes) |
| 2648 | assert all(cursor == 0 for cursor in cursors.values()) |
| 2649 | |
| 2650 | @skip_if_server_version_lt("6.0.0") |
| 2651 | def test_cluster_scan_type(self, r): |
nothing calls this directly
no test coverage detected