From e461edee6d18e715e267c9185364d9682d053e4a Mon Sep 17 00:00:00 2001
From: Rocky <shi.yan@unimelb.edu.au>
Date: Wed, 28 Jul 2021 20:30:32 +1000
Subject: [PATCH] Add max_workers for cloudkitty processor

Change-Id: I21f41d72fcd12339724a14c1eec178e60a7870b3
---
 manifests/processor.pp                                      | 6 ++++++
 .../add_orchestration_max_workers-6fda65c3be961ff3.yaml     | 4 ++++
 spec/classes/cloudkitty_processor_spec.rb                   | 4 +++-
 3 files changed, 13 insertions(+), 1 deletion(-)
 create mode 100644 releasenotes/notes/add_orchestration_max_workers-6fda65c3be961ff3.yaml

diff --git a/manifests/processor.pp b/manifests/processor.pp
index f8aecae..cf94987 100644
--- a/manifests/processor.pp
+++ b/manifests/processor.pp
@@ -52,6 +52,10 @@
 #   (optional) Endpoint URL type
 #   Default to $::os_service_default
 #
+# [*max_workers*]
+#   (optional) Number of max workers for processor
+#   Default to $::os_service_default
+#
 class cloudkitty::processor (
   $package_ensure    = 'present',
   $manage_service    = true,
@@ -65,6 +69,7 @@ class cloudkitty::processor (
   $auth_section      = 'keystone_authtoken',
   $region_name       = $::os_service_default,
   $interface         = $::os_service_default,
+  $max_workers       = $::os_service_default,
 ) {
 
   include cloudkitty::deps
@@ -111,6 +116,7 @@ class cloudkitty::processor (
     'collector_gnocchi/auth_section': value => $auth_section;
     'collector_gnocchi/region_name':  value => $region_name;
     'collector_gnocchi/interface':    value => $interface;
+    'orchestrator/max_workers':       value => $max_workers;
   }
 
 }
diff --git a/releasenotes/notes/add_orchestration_max_workers-6fda65c3be961ff3.yaml b/releasenotes/notes/add_orchestration_max_workers-6fda65c3be961ff3.yaml
new file mode 100644
index 0000000..e5aa075
--- /dev/null
+++ b/releasenotes/notes/add_orchestration_max_workers-6fda65c3be961ff3.yaml
@@ -0,0 +1,4 @@
+---
+features:
+  - |
+    Add max_workers parameter for orchestrator.
diff --git a/spec/classes/cloudkitty_processor_spec.rb b/spec/classes/cloudkitty_processor_spec.rb
index 7da4b28..97a931e 100644
--- a/spec/classes/cloudkitty_processor_spec.rb
+++ b/spec/classes/cloudkitty_processor_spec.rb
@@ -10,7 +10,8 @@ describe 'cloudkitty::processor' do
       :wait_periods   => '1',
       :window         => '3600',
       :region_name    => 'RegionOne',
-      :interface      => 'publicURL',}
+      :interface      => 'publicURL',
+      :max_workers    => '6',}
   end
 
   shared_examples_for 'cloudkitty-processor' do
@@ -27,6 +28,7 @@ describe 'cloudkitty::processor' do
       it { is_expected.to contain_cloudkitty_config('collector_gnocchi/auth_section').with_value('keystone_authtoken') }
       it { is_expected.to contain_cloudkitty_config('collector_gnocchi/region_name').with_value( params[:region_name] ) }
       it { is_expected.to contain_cloudkitty_config('collector_gnocchi/interface').with_value( params[:interface] ) }
+      it { is_expected.to contain_cloudkitty_config('orchestrator/max_workers').with_value( params[:max_workers] ) }
 
       it 'installs cloudkitty-processor package' do
         is_expected.to contain_package('cloudkitty-processor').with(