1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
|
Author: Thomas Goirand <zigo@debian.org>
Date: Tue, 01 Jul 2025 10:37:09 +0200
Description: Expose rabbit_qos_prefetch_count
The option was supported by puppet-oslo but was not configurable via
this module.
Change-Id: I113bbcf632bbd8dd645b0dc2dda48fda21f9d4e8
Forwarded: https://review.opendev.org/c/openstack/puppet-cloudkitty/+/953857
Last-Update: 2025-07-01
Index: puppet-module-cloudkitty/manifests/init.pp
===================================================================
--- puppet-module-cloudkitty.orig/manifests/init.pp
+++ puppet-module-cloudkitty/manifests/init.pp
@@ -37,6 +37,10 @@
# will be run through a green thread.
# Defaults to $facts['os_service_default']
#
+# [*rabbit_qos_prefetch_count*]
+# (Optional) Specifies the number of messages to prefetch.
+# Defaults to $facts['os_service_default']
+#
# [*rabbit_quorum_queue*]
# (Optional) Use quorum queues in RabbitMQ.
# Defaults to $facts['os_service_default']
@@ -223,6 +227,7 @@ class cloudkitty(
$rabbit_heartbeat_rate = $facts['os_service_default'],
$rabbit_heartbeat_in_pthread = $facts['os_service_default'],
$rabbit_ha_queues = $facts['os_service_default'],
+ $rabbit_qos_prefetch_count = $facts['os_service_default'],
$rabbit_quorum_queue = $facts['os_service_default'],
$rabbit_transient_queues_ttl = $facts['os_service_default'],
$rabbit_transient_quorum_queue = $facts['os_service_default'],
@@ -286,6 +291,7 @@ class cloudkitty(
heartbeat_timeout_threshold => $rabbit_heartbeat_timeout_threshold,
heartbeat_rate => $rabbit_heartbeat_rate,
heartbeat_in_pthread => $rabbit_heartbeat_in_pthread,
+ rabbit_qos_prefetch_count => $rabbit_qos_prefetch_count,
kombu_ssl_version => $kombu_ssl_version,
kombu_ssl_keyfile => $kombu_ssl_keyfile,
kombu_ssl_certfile => $kombu_ssl_certfile,
Index: puppet-module-cloudkitty/releasenotes/notes/rabbit_qos_prefetch_count-55d76ced5e1d735f.yaml
===================================================================
--- /dev/null
+++ puppet-module-cloudkitty/releasenotes/notes/rabbit_qos_prefetch_count-55d76ced5e1d735f.yaml
@@ -0,0 +1,4 @@
+---
+features:
+ - |
+ The new ``cloudkitty::rabbit_qos_prefetch_count`` parameter has been added.
Index: puppet-module-cloudkitty/spec/classes/cloudkitty_init_spec.rb
===================================================================
--- puppet-module-cloudkitty.orig/spec/classes/cloudkitty_init_spec.rb
+++ puppet-module-cloudkitty/spec/classes/cloudkitty_init_spec.rb
@@ -44,6 +44,7 @@ describe 'cloudkitty' do
:rabbit_ha_queues => '<SERVICE DEFAULT>',
:rabbit_retry_interval => '<SERVICE DEFAULT>',
:rabbit_quorum_queue => '<SERVICE DEFAULT>',
+ :rabbit_qos_prefetch_count => '<SERVICE DEFAULT>',
:rabbit_transient_quorum_queue => '<SERVICE DEFAULT>',
:rabbit_transient_queues_ttl => '<SERVICE DEFAULT>',
:rabbit_quorum_delivery_limit => '<SERVICE DEFAULT>',
@@ -82,6 +83,7 @@ describe 'cloudkitty' do
:rabbit_heartbeat_rate => 10,
:rabbit_heartbeat_in_pthread => true,
:rabbit_quorum_queue => true,
+ :rabbit_qos_prefetch_count => 10,
:rabbit_transient_quorum_queue => false,
:rabbit_transient_queues_ttl => 60,
:rabbit_quorum_delivery_limit => 3,
@@ -123,6 +125,7 @@ describe 'cloudkitty' do
:kombu_compression => 'gzip',
:rabbit_ha_queues => true,
:rabbit_quorum_queue => true,
+ :rabbit_qos_prefetch_count => 10,
:rabbit_transient_quorum_queue => false,
:rabbit_transient_queues_ttl => 60,
:rabbit_quorum_delivery_limit => 3,
|
