Add Heka params to set maximum message injection

This add these Heka configuration options in global.toml
If not provided, use the Heka default values which are currently:
* max_process_inject = 1
* max_timer_inject = 10

Change-Id: If1995fa505aec6ff3000af33c548730dd06d1046
This commit is contained in:
Swann Croiset 2015-07-02 12:35:19 +02:00
parent cb6d6353bc
commit bb6c74b246
3 changed files with 16 additions and 0 deletions

View File

@ -41,6 +41,12 @@
# [*max_message_size*]
# The maxium Heka message size in bytes (default: undef to use default Heka value).
#
# [*max_process_inject*]
# The maximum number of messages that a sandbox filters ProcessMessage function can inject in a single call (default: undef to use default Heka value).
#
# [*max_timer_inject*]
# The maximum number of messages that a sandbox filters TimerEvent function can inject in a single call (default: undef to use default Heka value).
#
# [*dashboard_address*]
# The listening adddress for the Heka dashboard (default: undef).
#
@ -74,6 +80,8 @@ class heka (
$hostname = $heka::params::hostname,
$maxprocs = $heka::params::maxprocs,
$max_message_size = $heka::params::max_message_size,
$max_process_inject = $heka::params::max_process_inject,
$max_timer_inject = $heka::params::max_timer_inject,
$dashboard_address = $heka::params::dashboard_address,
$dashboard_port = $heka::params::dashboard_port,
$pre_script = undef,

View File

@ -22,6 +22,8 @@ class heka::params {
$hostname = undef
$maxprocs = $::processorcount
$max_message_size = undef
$max_process_inject = undef
$max_timer_inject = undef
$dashboard_address = undef
$dashboard_port = '4352'
$internal_statistics = false

View File

@ -7,3 +7,9 @@ hostname="<%= @hostname %>"
<% if @max_message_size -%>
max_message_size = <%= @max_message_size %>
<% end -%>
<% if @max_process_inject -%>
max_process_inject = <%= @max_process_inject %>
<% end -%>
<% if @max_timer_inject -%>
max_timer_inject = <%= @max_timer_inject %>
<% end -%>