Parameterise sync-gateway commands

- also add default ycsb workload path to workload a

Change-Id: I812577cda4cd1805367b22250cfd8fdeae388838
Reviewed-on: https://review.couchbase.org/c/perfrunner/+/191025
Tested-by: Build Bot <[email protected]>
Reviewed-by: Dragos Petru Taraban <[email protected]>

Author: sudosalim

perfrunner/settings.py

@@ -1143,6 +1143,7 @@ class PhaseSettings:
     CONNSTR_PARAMS = "{'ipv6': 'allow', 'enable_tracing': 'false'}"
 
     YCSB_CLIENT = 'couchbase2'
+    YCSB_DEFAULT_WORKLOAD_PATH = 'workloads/workloada'
 
     DURABILITY = None
 
@@ -1329,7 +1330,7 @@ def __init__(self, options: dict):
         self.syncgateway_settings = None
 
         # YCSB settings
-        self.workload_path = options.get('workload_path')
+        self.workload_path = options.get('workload_path', self.YCSB_DEFAULT_WORKLOAD_PATH)
         self.recorded_load_cache_size = int(options.get('recorded_load_cache_size',
                                                         self.RECORDED_LOAD_CACHE_SIZE))
         self.inserts_per_workerinstance = int(options.get('inserts_per_workerinstance',

perfrunner/workloads/syncgateway.py

@@ -308,7 +308,7 @@
                         "-p syncgateway.retrydelay={retry_interval} " \
                         "-p syncgateway.grantaccessinscan={grant_access_in_scan}"
 
-E2E_CB_MULTI_LOAD_DOCS_CMD = " load couchbase2 -s -P workloads/syncgateway_blank " \
+E2E_CB_MULTI_LOAD_DOCS_CMD = " load {ycsb_command} -s -P {workload} " \
                              "-p requestdistribution=sequential " \
                              "-p recordcount={total_docs} " \
                              "-p dataintegrity={data_integrity} " \
@@ -338,7 +338,7 @@
                              "-p core_workload_insertion_retry_interval={retry_interval} " \
                              "-p exportfile={exportfile}"
 
-E2E_CB_MULTI_RUN_TEST_CMD = " run couchbase2 -s -P workloads/syncgateway_blank " \
+E2E_CB_MULTI_RUN_TEST_CMD = " run {ycsb_command} -s -P {workload} " \
                              "-p requestdistribution=sequential " \
                              "-p operationcount={operations} " \
                              "-p recordcount={total_docs} " \
@@ -1039,7 +1039,8 @@ def syncgateway_e2e_multi_cb_load_docs(
         total_docs += docs
         insert_offset += docs
     params = E2E_CB_MULTI_LOAD_DOCS_CMD.format(
-        workload=sgs.workload,
+        ycsb_command=workload_settings.ycsb_client,
+        workload=workload_settings.workload_path,
         host=cluster.servers[0],
         bucket=target.bucket,
         threads=sgs.threads_per_instance,
@@ -1085,7 +1086,8 @@ def syncgateway_e2e_multi_cb_run_test(
         total_docs += docs
         insert_offset += docs
     params = E2E_CB_MULTI_RUN_TEST_CMD.format(
-        workload=sgs.workload,
+        ycsb_command=workload_settings.ycsb_client,
+        workload=workload_settings.workload_path,
         host=cluster.servers[0],
         bucket=target.bucket,
         threads=sgs.threads_per_instance,