mirror of
https://github.com/scylladb/scylladb.git
synced 2026-04-23 01:50:35 +00:00
f3eade2f62
Drop the AGPL license in favor of a source-available license. See the blog post [1] for details. [1] https://www.scylladb.com/2024/12/18/why-were-moving-to-a-source-available-license/
86 lines
3.7 KiB
Python
86 lines
3.7 KiB
Python
#
|
|
# Copyright 2023-present ScyllaDB
|
|
#
|
|
# SPDX-License-Identifier: LicenseRef-ScyllaDB-Source-Available-1.0
|
|
#
|
|
|
|
from test.nodetool.rest_api_mock import expected_request
|
|
from test.nodetool.utils import check_nodetool_fails_with
|
|
|
|
def test_disableautocompaction(nodetool):
|
|
nodetool("disableautocompaction", expected_requests=[
|
|
expected_request("GET", "/storage_service/keyspaces", response=["ks1", "ks2"],
|
|
multiple=expected_request.MULTIPLE),
|
|
expected_request("DELETE", "/storage_service/auto_compaction/ks1"),
|
|
expected_request("DELETE", "/storage_service/auto_compaction/ks2")
|
|
])
|
|
|
|
|
|
def test_disableautocompaction_one_keyspace(nodetool):
|
|
nodetool("disableautocompaction", "ks1", expected_requests=[
|
|
expected_request("GET", "/storage_service/keyspaces", response=["ks1", "ks2"]),
|
|
expected_request("DELETE", "/storage_service/auto_compaction/ks1")
|
|
])
|
|
|
|
|
|
def test_disableautocompaction_one_table(nodetool):
|
|
nodetool("disableautocompaction", "ks1", "tbl1", expected_requests=[
|
|
expected_request("GET", "/storage_service/keyspaces", response=["ks1", "ks2"]),
|
|
expected_request("DELETE", "/storage_service/auto_compaction/ks1", params={"cf": "tbl1"})
|
|
])
|
|
|
|
|
|
def test_disableautocompaction_two_tables(nodetool):
|
|
nodetool("disableautocompaction", "ks1", "tbl1", "tbl2", expected_requests=[
|
|
expected_request("GET", "/storage_service/keyspaces", response=["ks1", "ks2"]),
|
|
expected_request("DELETE", "/storage_service/auto_compaction/ks1", params={"cf": "tbl1,tbl2"})
|
|
])
|
|
|
|
|
|
def test_disableautocompaction_none_existent_keyspace(nodetool):
|
|
check_nodetool_fails_with(
|
|
nodetool,
|
|
("disableautocompaction", "non_existent_ks"),
|
|
{"expected_requests": [expected_request("GET", "/storage_service/keyspaces", response=["ks1", "ks2"])]},
|
|
["nodetool: Keyspace [non_existent_ks] does not exist.",
|
|
"error processing arguments: keyspace non_existent_ks does not exist"])
|
|
|
|
|
|
def test_enableautocompaction(nodetool):
|
|
nodetool("enableautocompaction", expected_requests=[
|
|
expected_request("GET", "/storage_service/keyspaces", response=["ks1", "ks2"],
|
|
multiple=expected_request.MULTIPLE),
|
|
expected_request("POST", "/storage_service/auto_compaction/ks1"),
|
|
expected_request("POST", "/storage_service/auto_compaction/ks2")
|
|
])
|
|
|
|
|
|
def test_enableautocompaction_one_keyspace(nodetool):
|
|
nodetool("enableautocompaction", "ks1", expected_requests=[
|
|
expected_request("GET", "/storage_service/keyspaces", response=["ks1", "ks2"]),
|
|
expected_request("POST", "/storage_service/auto_compaction/ks1")
|
|
])
|
|
|
|
|
|
def test_enableautocompaction_one_table(nodetool):
|
|
nodetool("enableautocompaction", "ks1", "tbl1", expected_requests=[
|
|
expected_request("GET", "/storage_service/keyspaces", response=["ks1", "ks2"]),
|
|
expected_request("POST", "/storage_service/auto_compaction/ks1", params={"cf": "tbl1"})
|
|
])
|
|
|
|
|
|
def test_enableautocompaction_two_tables(nodetool):
|
|
nodetool("enableautocompaction", "ks1", "tbl1", "tbl2", expected_requests=[
|
|
expected_request("GET", "/storage_service/keyspaces", response=["ks1", "ks2"]),
|
|
expected_request("POST", "/storage_service/auto_compaction/ks1", params={"cf": "tbl1,tbl2"})
|
|
])
|
|
|
|
|
|
def test_enableautocompaction_none_existent_keyspace(nodetool):
|
|
check_nodetool_fails_with(
|
|
nodetool,
|
|
("enableautocompaction", "non_existent_ks"),
|
|
{"expected_requests": [expected_request("GET", "/storage_service/keyspaces", response=["ks1", "ks2"])]},
|
|
["nodetool: Keyspace [non_existent_ks] does not exist.",
|
|
"error processing arguments: keyspace non_existent_ks does not exist"])
|