Skip to content

Commit 0e438ff

Browse files
Added consumer-id to self contained coordinator. Enables multi consumers (#110)
* Fixed self_contained_coordinator r.ping() using 6379 port and not redis_proc_start_port * Bumping version from 0.1.33 to 0.1.34 * Added consumer-id to self contained coordinator. Enables multi consumers * Bumping version from 0.1.34 to 0.1.35
1 parent 13540c8 commit 0e438ff

File tree

4 files changed

+24
-6
lines changed

4 files changed

+24
-6
lines changed

poetry.lock

Lines changed: 4 additions & 4 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
[tool.poetry]
22
name = "redis-benchmarks-specification"
3-
version = "0.1.34"
3+
version = "0.1.35"
44
description = "The Redis benchmarks specification describes the cross-language/tools requirements and expectations to foster performance and observability standards around redis related technologies. Members from both industry and academia, including organizations and individuals are encouraged to contribute."
55
authors = ["filipecosta90 <[email protected]>","Redis Performance Group <[email protected]>"]
66
readme = "Readme.md"

redis_benchmarks_specification/__self_contained_coordinator__/args.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,13 @@ def create_self_contained_coordinator_args(project_name):
5252
type=str,
5353
default=">",
5454
)
55+
parser.add_argument(
56+
"--consumer-id",
57+
type=int,
58+
default=1,
59+
help="Consumer id for consumer group for platform",
60+
)
61+
5562
parser.add_argument(
5663
"--setups-folder",
5764
type=str,

redis_benchmarks_specification/__self_contained_coordinator__/self_contained_coordinator.py

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -182,6 +182,10 @@ def main():
182182
datasink_push_results_redistimeseries = args.datasink_push_results_redistimeseries
183183
grafana_profile_dashboard = args.grafana_profile_dashboard
184184

185+
# Consumer id
186+
consumer_pos = args.consumer_pos
187+
logging.info("Consumer pos {}".format(consumer_pos))
188+
185189
profilers_list = []
186190
profilers_enabled = args.enable_profilers
187191
if profilers_enabled:
@@ -214,6 +218,7 @@ def main():
214218
grafana_profile_dashboard,
215219
cpuset_start_pos,
216220
redis_proc_start_port,
221+
consumer_pos,
217222
)
218223

219224

@@ -260,12 +265,18 @@ def self_contained_coordinator_blocking_read(
260265
grafana_profile_dashboard="",
261266
cpuset_start_pos=0,
262267
redis_proc_start_port=6379,
268+
consumer_pos=1,
263269
):
264270
num_process_streams = 0
265271
num_process_test_suites = 0
266272
overall_result = False
267273
consumer_name = "{}-self-contained-proc#{}".format(
268-
get_runners_consumer_group_name(platform_name), "1"
274+
get_runners_consumer_group_name(platform_name), consumer_pos
275+
)
276+
logging.info(
277+
"Consuming from group {}. Consumer id {}".format(
278+
get_runners_consumer_group_name(platform_name), consumer_name
279+
)
269280
)
270281
newTestInfo = conn.xreadgroup(
271282
get_runners_consumer_group_name(platform_name),

0 commit comments

Comments
 (0)