enable topic slo

Author: vgvoleg

.github/workflows/slo.yml

@@ -57,6 +57,11 @@ jobs:
               --read-timeout 1000 \
               --write-timeout 1000
             cleanup-args: grpc://localhost:2135 /Root/testdb
+          - prefix: topic
+            workload: topic-basic
+            create-args: grpc://localhost:2135 /Root/testdb --topic-path /Root/slo_topic
+            run-args: grpc://localhost:2135 /Root/testdb --topic-path /Root/slo_topic
+            cleanup-args: grpc://localhost:2135 /Root/testdb --topic-path /Root/slo_topic
 
 
     concurrency:

tests/slo/src/options.py

@@ -61,18 +61,29 @@ def make_table_cleanup_parser(subparsers):
     add_common_options(table_cleanup_parser)
 
 
+def make_topic_create_parser(subparsers):
+    topic_create_parser = subparsers.add_parser("topic-create", help="Create topic with consumer")
+    add_common_options(topic_create_parser)
+
+    topic_create_parser.add_argument("--topic-path", default="/local/slo_topic", type=str, help="Topic path")
+    topic_create_parser.add_argument("--topic-consumer", default="slo_consumer", type=str, help="Topic consumer name")
+    topic_create_parser.add_argument("--topic-min-partitions", default=1, type=int, help="Minimum active partitions")
+    topic_create_parser.add_argument("--topic-max-partitions", default=10, type=int, help="Maximum active partitions")
+    topic_create_parser.add_argument("--topic-retention-hours", default=24, type=int, help="Retention period in hours")
+
+
 def make_topic_run_parser(subparsers):
     """Создает парсер для команды topic-run - запуск SLO тестов для топиков"""
     topic_parser = subparsers.add_parser("topic-run", help="Run topic SLO workload")
     add_common_options(topic_parser)
 
+    topic_parser.add_argument("--topic-path", default="/local/slo_topic", type=str, help="Topic path")
     topic_parser.add_argument("--topic-read-rps", default=50, type=int, help="Topic read request rps")
     topic_parser.add_argument("--topic-read-timeout", default=5000, type=int, help="Topic read timeout [ms]")
     topic_parser.add_argument("--topic-write-rps", default=20, type=int, help="Topic write request rps")
     topic_parser.add_argument("--topic-write-timeout", default=10000, type=int, help="Topic write timeout [ms]")
     topic_parser.add_argument("--topic-read-threads", default=1, type=int, help="Number of threads for topic reading")
     topic_parser.add_argument("--topic-write-threads", default=1, type=int, help="Number of threads for topic writing")
-    topic_parser.add_argument("--topic-path", default="/local/slo_topic", type=str, help="Topic path")
     topic_parser.add_argument("--topic-consumer", default="slo_consumer", type=str, help="Topic consumer name")
     topic_parser.add_argument("--topic-message-size", default=100, type=int, help="Topic message size in bytes")
     topic_parser.add_argument("--topic-min-partitions", default=1, type=int, help="Minimum active partitions")
@@ -85,17 +96,6 @@ def make_topic_run_parser(subparsers):
     topic_parser.add_argument("--report-period", default=1000, type=int, help="Prometheus push period in [ms]")
 
 
-def make_topic_create_parser(subparsers):
-    topic_create_parser = subparsers.add_parser("topic-create", help="Create topic with consumer")
-    add_common_options(topic_create_parser)
-
-    topic_create_parser.add_argument("--topic-path", default="/local/slo_topic", type=str, help="Topic path")
-    topic_create_parser.add_argument("--topic-consumer", default="slo_consumer", type=str, help="Topic consumer name")
-    topic_create_parser.add_argument("--topic-min-partitions", default=1, type=int, help="Minimum active partitions")
-    topic_create_parser.add_argument("--topic-max-partitions", default=10, type=int, help="Maximum active partitions")
-    topic_create_parser.add_argument("--topic-retention-hours", default=24, type=int, help="Retention period in hours")
-
-
 def make_topic_cleanup_parser(subparsers):
     topic_cleanup_parser = subparsers.add_parser("topic-cleanup", help="Drop topic")
     add_common_options(topic_cleanup_parser)