diff --git a/manifests/agent/polling.pp b/manifests/agent/polling.pp index 5d5d51fc..94da16ae 100644 --- a/manifests/agent/polling.pp +++ b/manifests/agent/polling.pp @@ -54,6 +54,10 @@ # This is used only if manage_polling is true. # Defaults to undef # +# [*batch_size*] +# (Optional) Batch size of samples to send to notification agent. +# Defaults to $::os_service_default +# # DEPRECATED PARAMETERS # # [*coordination_url*] @@ -72,6 +76,7 @@ class ceilometer::agent::polling ( $polling_interval = 600, $polling_meters = $::ceilometer::params::polling_meters, $polling_config = undef, + $batch_size = $::os_service_default, # DEPRECATED PARAMETERS $coordination_url = undef, ) inherits ceilometer { @@ -135,6 +140,10 @@ class ceilometer::agent::polling ( } } + ceilometer_config { + 'polling/batch_size': value => $batch_size + } + if $manage_service { if $enabled { $service_ensure = 'running' diff --git a/releasenotes/notes/polling-batch_size-95f15dc9d96b96b4.yaml b/releasenotes/notes/polling-batch_size-95f15dc9d96b96b4.yaml new file mode 100644 index 00000000..403871e5 --- /dev/null +++ b/releasenotes/notes/polling-batch_size-95f15dc9d96b96b4.yaml @@ -0,0 +1,5 @@ +--- +features: + - | + The ``ceilometer::agent::polling`` class now suppports the new + ``batch_size`` parameter. diff --git a/spec/classes/ceilometer_agent_polling_spec.rb b/spec/classes/ceilometer_agent_polling_spec.rb index 0b8ee22a..6d4492f1 100644 --- a/spec/classes/ceilometer_agent_polling_spec.rb +++ b/spec/classes/ceilometer_agent_polling_spec.rb @@ -48,6 +48,7 @@ describe 'ceilometer::agent::polling' do :tag => 'ceilometer-service', )} + it { should contain_ceilometer_config('polling/batch_size').with_value('') } it { should_not contain_file('polling') } end @@ -219,6 +220,14 @@ sources: it { should contain_ceilometer_config('coordination/backend_url').with_value('redis://localhost:6379') } end + + context 'when batch_size is set' do + before do + params.merge!( :batch_size => 50 ) + end + + it { should contain_ceilometer_config('polling/batch_size').with_value(50) } + end end on_supported_os({