From 2622feeab27e8ef79e84fcbc1302867f7c9e3fca Mon Sep 17 00:00:00 2001 From: Brandon Allard Date: Thu, 19 Oct 2023 15:49:32 -0400 Subject: [PATCH] rptest: add cloud_storage_cache_chunk_size config to SISettings --- tests/rptest/services/redpanda.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/tests/rptest/services/redpanda.py b/tests/rptest/services/redpanda.py index 859f830c17e9f..02d068cb38904 100644 --- a/tests/rptest/services/redpanda.py +++ b/tests/rptest/services/redpanda.py @@ -371,6 +371,7 @@ def __init__(self, test_context, *, log_segment_size: int = 16 * 1000000, + cloud_storage_cache_chunk_size: Optional[int] = None, cloud_storage_credentials_source: str = 'config_file', cloud_storage_access_key: str = 'panda-user', cloud_storage_secret_key: str = 'panda-secret', @@ -431,6 +432,7 @@ def __init__(self, assert False, f"Unexpected value provided for 'cloud_storage_type' injected arg: {self.cloud_storage_type}" self.log_segment_size = log_segment_size + self.cloud_storage_cache_chunk_size = cloud_storage_cache_chunk_size self.cloud_storage_cache_size = cloud_storage_cache_size self.cloud_storage_cache_max_objects = cloud_storage_cache_max_objects self.cloud_storage_enable_remote_read = cloud_storage_enable_remote_read @@ -538,6 +540,10 @@ def update_rp_conf(self, conf) -> dict[str, Any]: 'cloud_storage_azure_shared_key'] = self.cloud_storage_azure_shared_key conf["log_segment_size"] = self.log_segment_size + if (self.cloud_storage_cache_chunk_size): + conf[ + "cloud_storage_cache_chunk_size"] = self.cloud_storage_cache_chunk_size + conf["cloud_storage_enabled"] = True if self.cloud_storage_cache_size is None: # Default cache size for testing: large enough to enable streaming throughput up to 100MB/s, but no