Changeset View
Changeset View
Standalone View
Standalone View
swh/objstorage/replayer/tests/test_replay.py
| Show All 31 Lines | def test_is_hash_in_bytearray(haystack, needles): | ||||
| needles |= haystack # Exhaustively test for all objects in the array | needles |= haystack # Exhaustively test for all objects in the array | ||||
| for needle in needles: | for needle in needles: | ||||
| assert is_hash_in_bytearray(needle, array, len(haystack)) == ( | assert is_hash_in_bytearray(needle, array, len(haystack)) == ( | ||||
| needle in haystack | needle in haystack | ||||
| ) | ) | ||||
| def test_replay_content(kafka_server, kafka_prefix, kafka_consumer_group): | def test_replay_content(kafka_server, kafka_prefix, kafka_consumer_group): | ||||
| objstorage1 = get_objstorage(cls="memory", args={}) | objstorage1 = get_objstorage(cls="memory") | ||||
| objstorage2 = get_objstorage(cls="memory", args={}) | objstorage2 = get_objstorage(cls="memory") | ||||
| writer = KafkaJournalWriter( | writer = KafkaJournalWriter( | ||||
| brokers=[kafka_server], | brokers=[kafka_server], | ||||
| client_id="kafka_writer", | client_id="kafka_writer", | ||||
| prefix=kafka_prefix, | prefix=kafka_prefix, | ||||
| anonymize=False, | anonymize=False, | ||||
| ) | ) | ||||
| Show All 22 Lines | |||||