mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-12 19:02:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

test/pylib: rest_client: add get_injection()

Browse Source 
The /v2/error_injection/{injection} endpoint now has a GET method too,
expose this.

(cherry picked from commit 0c61b1822c)
This commit is contained in:
Botond Dénes
2024-05-16 03:05:40 -04:00
committed by Mergify
parent bb18a8152e
commit d4563e2b28
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
test/pylib/rest_client.py
View File

@@ -230,6 +230,14 @@ class ScyllaRESTAPIClient():
await self.client.post(f"/v2/error_injection/injection/{injection}",
host=node_ip, params={"one_shot": str(one_shot)}, json={ key: str(value) for key, value in parameters.items() })
async def get_injection(self, node_ip: str, injection: str) -> list[dict[str, Any]]:
"""Read the state of the error injection named `injection` on `node_ip`.
The returned information includes whether the error injections is
active, as well as any parameters it might have.
Note: this only has an effect in specific build modes: debug,dev,sanitize.
"""
return await self.client.get_json(f"/v2/error_injection/injection/{injection}", host=node_ip)
async def move_tablet(self, node_ip: str, ks: str, table: str, src_host: HostID, src_shard: int, dst_host: HostID, dst_shard: int, token: int) -> None:
await self.client.post(f"/storage_service/tablets/move", host=node_ip, params={
"ks": ks,