openstack/puppet-cloudkitty
Code Issues Proposed changes

Add support for [orchestrator] max_workers_reprocessing

Browse Source 
... to control the number of processes the orchestrator service may
spawn.

Change-Id: Ibcb3f2444d8fa203efc557eb8c75aece863d167e
Signed-off-by: Takashi Kajinami <kajinamit@oss.nttdata.com>
This commit is contained in:
Takashi Kajinami
2025-09-08 21:09:01 +09:00
parent d93fcb505d
commit c1d9151756
3 changed files with 24 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
manifests/orchestrator.pp
View File

@@ -9,7 +9,11 @@
# Defaults to $facts['os_service_default'] # Defaults to $facts['os_service_default']
# #
# [*max_workers*] # [*max_workers*]
# (Optional) Maximal number of workers to run. # (Optional) Maximum number of workers to execute the rating process.
# Defaults to $facts['os_service_default']
#
# [*max_workers_reprocessing*]
# (Optional) Maximum number of workers to execute the reprocessing.
# Defaults to $facts['os_service_default'] # Defaults to $facts['os_service_default']
# #
# [*max_threads*] # [*max_threads*]
@@ -17,9 +21,10 @@
# Defaults to $facts['os_service_default'] # Defaults to $facts['os_service_default']
# #
class cloudkitty::orchestrator ( class cloudkitty::orchestrator (
$coordination_url = $facts['os_service_default'], $coordination_url = $facts['os_service_default'],
$max_workers = $facts['os_service_default'], $max_workers = $facts['os_service_default'],
$max_threads = $facts['os_service_default'] $max_workers_reprocessing = $facts['os_service_default'],
$max_threads = $facts['os_service_default']
) { ) {
include cloudkitty::deps include cloudkitty::deps
@@ -33,8 +38,9 @@ class cloudkitty::orchestrator (
Oslo::Coordination['cloudkitty_config'] -> Anchor['cloudkitty::service::begin'] Oslo::Coordination['cloudkitty_config'] -> Anchor['cloudkitty::service::begin']
cloudkitty_config { cloudkitty_config {
'orchestrator/coordination_url': value => $coordination_url, secret => true; 'orchestrator/coordination_url': value => $coordination_url, secret => true;
'orchestrator/max_workers': value => $max_workers; 'orchestrator/max_workers': value => $max_workers;
'orchestrator/max_threads': value => $max_threads; 'orchestrator/max_workers_reprocessing': value => $max_workers_reprocessing;
'orchestrator/max_threads': value => $max_threads;
} }
} }

5
releasenotes/notes/max_workers_reprocessing-dd0b413efd72cd7d.yaml Normal file
View File

@@ -0,0 +1,5 @@
---
features:
- |
The new ``cloudkitty::orchestrator::max_workers_reprocessing`` parmaeter
has been added.

9
spec/classes/cloudkitty_orchestrator_spec.rb
View File

@@ -15,6 +15,7 @@ describe 'cloudkitty::orchestrator' do
:manage_config => false, :manage_config => false,
) )
is_expected.to contain_cloudkitty_config('orchestrator/max_workers').with_value('<SERVICE DEFAULT>') is_expected.to contain_cloudkitty_config('orchestrator/max_workers').with_value('<SERVICE DEFAULT>')
is_expected.to contain_cloudkitty_config('orchestrator/max_workers_reprocessing').with_value('<SERVICE DEFAULT>')
is_expected.to contain_cloudkitty_config('orchestrator/max_threads').with_value('<SERVICE DEFAULT>') is_expected.to contain_cloudkitty_config('orchestrator/max_threads').with_value('<SERVICE DEFAULT>')
end end
end end
@@ -22,9 +23,10 @@ describe 'cloudkitty::orchestrator' do
context 'with parameters set' do context 'with parameters set' do
let :params do let :params do
{ {
:coordination_url => 'etcd3+http://127.0.0.1:2379', :coordination_url => 'etcd3+http://127.0.0.1:2379',
:max_workers => 4, :max_workers => 4,
:max_threads => 20, :max_workers_reprocessing => 5,
:max_threads => 20,
} }
end end
@@ -36,6 +38,7 @@ describe 'cloudkitty::orchestrator' do
:manage_config => false, :manage_config => false,
) )
is_expected.to contain_cloudkitty_config('orchestrator/max_workers').with_value(4) is_expected.to contain_cloudkitty_config('orchestrator/max_workers').with_value(4)
is_expected.to contain_cloudkitty_config('orchestrator/max_workers_reprocessing').with_value(5)
is_expected.to contain_cloudkitty_config('orchestrator/max_threads').with_value(20) is_expected.to contain_cloudkitty_config('orchestrator/max_threads').with_value(20)
end end
end end