x
/
fuel-plugin-lma-collector
Code Issues Proposed changes

Merge "Add new collectd decoder for InfluxDB 0.9"

This commit is contained in:
Jenkins 2015-07-29 13:41:50 +00:00 committed by Gerrit Code Review
parent b6c3f37fe3 bd31aafce6
commit a81a9a621a
4 changed files with 448 additions and 46 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
deployment_scripts/puppet/manifests/base.pp
View File

@ -162,14 +162,14 @@ case $influxdb_mode {
$collectd_read_threads = 5
}
class { 'lma_collector::collectd::base':
processes => $processes,
process_matches => $process_matches,
read_threads => $collectd_read_threads,
require => Class['lma_collector'],
}
if $lma_collector['influxdb_legacy'] {
class { 'lma_collector::collectd::base_legacy':
processes => $processes,
process_matches => $process_matches,
read_threads => $collectd_read_threads,
require => Class['lma_collector'],
}
class { 'lma_collector::influxdb_legacy':
server => $influxdb_server,
database => $influxdb_database,
@ -178,6 +178,13 @@ case $influxdb_mode {
require => Class['lma_collector'],
}
} else {
class { 'lma_collector::collectd::base':
processes => $processes,
process_matches => $process_matches,
read_threads => $collectd_read_threads,
require => Class['lma_collector'],
}
class { 'lma_collector::influxdb':
server => $influxdb_server,
database => $influxdb_database,

188
deployment_scripts/puppet/modules/lma_collector/files/plugins/decoders/collectd.lua
View File

@ -16,21 +16,30 @@ require "cjson"
local utils = require 'lma_utils'
local sep = '.'
local sep = '_'
local processes_map = {
ps_code = 'memory.code',
ps_count = 'count',
ps_code = 'memory_code',
ps_count = '',
ps_cputime = 'cputime',
ps_data = 'memory.data',
ps_disk_octets = 'disk.bytes',
ps_disk_ops = 'disk.ops',
ps_data = 'memory_data',
ps_disk_octets = 'disk_bytes',
ps_disk_ops = 'disk_ops',
ps_pagefaults = 'pagefaults',
ps_rss = 'memory.rss',
ps_rss = 'memory_rss',
ps_stacksize = 'stacksize',
ps_vm = 'memory.virtual',
ps_vm = 'memory_virtual',
}
function replace_dot_by_sep (str)
return string.gsub(str, '%.', sep)
end
function split_service_and_state(str)
local service, state = string.match(str, '^services%.(.+)%.([^.]+)$')
return replace_dot_by_sep(service), state
end
function process_message ()
local ok, samples = pcall(cjson.decode, read_message("Payload"))
if not ok then
@ -40,13 +49,18 @@ function process_message ()
for _, sample in ipairs(samples) do
local metric_prefix = sample['type']
if sample['type_instance'] ~= "" then metric_prefix = metric_prefix .. sep .. sample['type_instance'] end
if sample['type_instance'] ~= "" then
metric_prefix = metric_prefix .. sep .. sample['type_instance']
end
local metric_source = sample['plugin']
for i, value in ipairs(sample['values']) do
local skip_it = false
local metric_name = metric_prefix
if sample['dsnames'][i] ~= "value" then metric_name = metric_name .. sep .. sample['dsnames'][i] end
if sample['dsnames'][i] ~= "value" then
metric_name = metric_name .. sep .. sample['dsnames'][i]
end
local msg = {
Timestamp = sample['time'] * 1e9, -- Heka expects nanoseconds
@ -75,53 +89,76 @@ function process_message ()
else -- sample['type'] == 'df_complex'
entity = 'space'
end
msg['Fields']['name'] = 'fs' .. sep .. mount .. sep .. entity .. sep .. sample['type_instance']
msg['Fields']['device'] = '/' .. string.gsub(mount, '-', '/')
msg['Fields']['name'] = 'fs' .. sep .. entity .. sep .. sample['type_instance']
msg['Fields']['fs'] = mount
msg['Fields']['tag_fields'] = { 'fs' }
elseif metric_source == 'disk' then
msg['Fields']['name'] = metric_name
msg['Fields']['device'] = sample['plugin_instance']
msg['Fields']['name'] = 'disk' .. sep .. sample['plugin_instance'] .. sep .. metric_name
msg['Fields']['tag_fields'] = { 'device' }
elseif metric_source == 'cpu' then
msg['Fields']['device'] = 'cpu' .. sample['plugin_instance']
msg['Fields']['name'] = 'cpu' .. sep .. sample['plugin_instance'] .. sep .. sample['type_instance']
msg['Fields']['name'] = 'cpu' .. sep .. sample['type_instance']
msg['Fields']['cpu_number'] = sample['plugin_instance']
msg['Fields']['tag_fields'] = { 'cpu_number' }
elseif metric_source == 'interface' then
msg['Fields']['device'] = sample['plugin_instance']
msg['Fields']['name'] = 'net' .. sep .. sample['plugin_instance'] .. sep .. sample['type'] .. sep .. sample['dsnames'][i]
msg['Fields']['name'] = sample['type'] .. sep .. sample['dsnames'][i]
msg['Fields']['interface'] = sample['plugin_instance']
msg['Fields']['tag_fields'] = { 'interface' }
elseif metric_source == 'processes' then
if processes_map[sample['type']] then
msg['Fields']['name'] = 'lma_components' .. sep .. sample['plugin_instance'] .. sep .. processes_map[sample['type']]
-- metrics related to a specific process
msg['Fields']['service'] = sample['plugin_instance']
msg['Fields']['tag_fields'] = { 'service' }
msg['Fields']['name'] = 'lma_components'
if processes_map[sample['type']] ~= '' then
msg['Fields']['name'] = msg['Fields']['name'] .. sep .. processes_map[sample['type']]
end
if sample['dsnames'][i] ~= 'value' then
msg['Fields']['name'] = msg['Fields']['name'] .. sep .. sample['dsnames'][i]
end
-- For ps_cputime, convert it to percentage. We have number of microseconds within one second.
-- For ps_cputime, convert it to a percentage: collectd is
-- sending us the number of microseconds allocated to the
-- process as a rate so within 1 second.
if sample['type'] == 'ps_cputime' then
msg['Fields']['value'] = value / 10000
msg['Fields']['value'] = 100 * value / 1e6
end
else
-- metrics related to all processes
msg['Fields']['name'] = 'processes'
if sample['type'] == 'ps_state' then
msg['Fields']['name'] = msg['Fields']['name'] .. sep .. 'state' .. sep .. sample['type_instance']
msg['Fields']['name'] = msg['Fields']['name'] .. sep .. 'count'
msg['Fields']['state'] = sample['type_instance']
msg['Fields']['tag_fields'] = { 'state' }
else
msg['Fields']['name'] = msg['Fields']['name'] .. sep .. sample['type']
end
end
elseif metric_source == 'dbi' and sample['plugin_instance'] == 'mysql_status' then
msg['Fields']['name'] = 'mysql' .. sep .. sample['type_instance']
msg['Fields']['name'] = 'mysql' .. sep .. replace_dot_by_sep(sample['type_instance'])
elseif metric_source == 'mysql' then
if sample['type'] == 'threads' then
msg['Fields']['name'] = 'mysql_' .. metric_name
elseif sample['type'] == 'mysql_commands' then
msg['Fields']['name'] = sample['type']
msg['Fields']['statement'] = sample['type_instance']
msg['Fields']['tag_fields'] = { 'statement' }
elseif sample['type'] == 'mysql_handler' then
msg['Fields']['name'] = sample['type']
msg['Fields']['handler'] = sample['type_instance']
msg['Fields']['tag_fields'] = { 'handler' }
else
msg['Fields']['name'] = metric_name
end
elseif metric_source == 'check_openstack_api' then
-- OpenStack API metrics
-- 'plugin_instance' = <service name>
-- For OpenStack API metrics, plugin_instance = <service name>
msg['Fields']['name'] = 'openstack' .. sep .. sample['plugin_instance'] .. sep .. 'check_api'
if sample['type_instance'] ~= nil and sample['type_instance'] ~= '' then
msg['Fields']['os_region'] = sample['type_instance']
end
elseif metric_source == 'hypervisor_stats' then
-- OpenStack hypervisor metrics
-- 'type_instance' = <metric name> which can end by _MB or _GB
-- Metrics from the OpenStack hypervisor metrics where
-- type_instance = <metric name> which can end by _MB or _GB
msg['Fields']['name'] = 'openstack' .. sep .. 'nova' .. sep
local name, unit
name, unit = string.match(sample['type_instance'], '^(.+)_(.B)$')
@ -132,37 +169,110 @@ function process_message ()
msg['Fields']['name'] = msg['Fields']['name'] .. sample['type_instance']
end
elseif metric_source == 'rabbitmq_info' then
msg['Fields']['name'] = 'rabbitmq' .. sep .. sample['type_instance']
if sample['type_instance'] ~= 'consumers' and
sample['type_instance'] ~= 'messages' and
(string.match(sample['type_instance'], '%.consumers$') or
string.match(sample['type_instance'], '%.messages$') or
string.match(sample['type_instance'], '%.memory$')) then
local q, m = string.match(sample['type_instance'], '^(.+)%.([^.]+)$')
msg['Fields']['name'] = 'rabbitmq' .. sep .. m
msg['Fields']['queue'] = q
msg['Fields']['tag_fields'] = { 'queue' }
else
msg['Fields']['name'] = 'rabbitmq' .. sep .. sample['type_instance']
end
elseif metric_source == 'nova' then
msg['Fields']['name'] = 'openstack.nova' .. sep .. sample['plugin_instance'] .. sep .. sample['type_instance']
msg['Fields']['name'] = 'openstack' .. sep .. 'nova' .. sep .. replace_dot_by_sep(sample['plugin_instance'])
msg['Fields']['tag_fields'] = { 'state' }
msg['Fields']['state'] = sample['type_instance']
elseif metric_source == 'cinder' then
msg['Fields']['name'] = 'openstack.cinder' .. sep .. sample['plugin_instance'] .. sep .. sample['type_instance']
msg['Fields']['name'] = 'openstack' .. sep .. 'cinder' .. sep .. replace_dot_by_sep(sample['plugin_instance'])
msg['Fields']['tag_fields'] = { 'state' }
msg['Fields']['state'] = sample['type_instance']
elseif metric_source == 'glance' then
msg['Fields']['name'] = 'openstack.glance' .. sep .. sample['type_instance']
-- TODO(pasquier-s): check if the collectd plugin can send state as type_instance
local resource, visibility, state = string.match(sample['type_instance'], '^([^.]+)%.([^.]+)%.(.+)$')
msg['Fields']['name'] = 'openstack' .. sep .. 'glance' .. sep .. replace_dot_by_sep(resource)
msg['Fields']['tag_fields'] = { 'state', 'visibility' }
msg['Fields']['state'] = state
msg['Fields']['visibility'] = visibility
elseif metric_source == 'keystone' then
msg['Fields']['name'] = 'openstack.keystone' .. sep .. sample['type_instance']
-- TODO(pasquier-s): check if the collectd plugin can send state as type_instance
if sample['type_instance'] == 'roles' then
msg['Fields']['name'] = 'openstack' .. sep .. 'keystone' .. sep .. sample['type_instance']
else
local resource, state = string.match(sample['type_instance'], '^([^.]+)%.(.+)$')
msg['Fields']['name'] = 'openstack' .. sep .. 'keystone' .. sep .. replace_dot_by_sep(resource)
msg['Fields']['tag_fields'] = { 'state' }
msg['Fields']['state'] = state
end
elseif metric_source == 'neutron' then
msg['Fields']['name'] = 'openstack.neutron' .. sep .. sample['type_instance']
if sample['type_instance'] == 'networks' or sample['type_instance'] == 'ports' or sample['type_instance'] == 'routers' or sample['type_instance'] == 'floatingips' then
skip_it = true
elseif sample['type_instance'] == 'subnets' then
msg['Fields']['name'] = 'openstack' .. sep .. 'neutron' .. sep .. 'subnets'
elseif string.match(sample['type_instance'], '^ports') then
local resource, owner, state = string.match(sample['type_instance'], '^([^.]+)%.([^.]+)%.(.+)$')
msg['Fields']['name'] = 'openstack' .. sep .. 'neutron' .. sep .. replace_dot_by_sep(resource)
msg['Fields']['tag_fields'] = { 'owner', 'state' }
msg['Fields']['owner'] = owner
msg['Fields']['state'] = state
else
local resource, owner = string.match(sample['type_instance'], '^([^.]+)%.(.+)$')
msg['Fields']['name'] = 'openstack' .. sep .. 'neutron' .. sep .. replace_dot_by_sep(resource)
msg['Fields']['tag_fields'] = { 'state' }
msg['Fields']['state'] = state
end
elseif metric_source == 'memcached' then
msg['Fields']['name'] = 'memcached' .. sep .. string.gsub(metric_name, 'memcached_', '')
elseif metric_source == 'haproxy' then
msg['Fields']['name'] = 'haproxy' .. sep .. sample['type_instance']
if not string.match(sample['type_instance'], '^frontend') and
not string.match(sample['type_instance'], '^backend') then
msg['Fields']['name'] = 'haproxy' .. sep .. sample['type_instance']
elseif string.match(sample['type_instance'], '^[^.]+%.[^.]+$') then
skip_it = true
else
local side, name, m, state = string.match(sample['type_instance'], '^([^.]+)%.([^.]+)%.([^.]+)%.([^.]+)$')
if not side then
side, name, m = string.match(sample['type_instance'], '^([^.]+)%.([^.]+)%.([^.]+)$')
end
msg['Fields']['name'] = 'haproxy' .. sep .. side .. sep .. m
msg['Fields']['tag_fields'] = { side } -- backend or frontend
msg['Fields'][side] = name
if state then
msg['Fields']['tag_fields'][2] = 'state'
msg['Fields']['state'] = state
end
end
elseif metric_source == 'apache' then
metric_name = string.gsub(metric_name, 'apache_', '')
msg['Fields']['name'] = 'apache' .. sep .. string.gsub(metric_name, 'scoreboard', 'workers')
elseif metric_source == 'ceph' then
msg['Fields']['name'] = 'ceph' .. sep .. sample['plugin_instance'] .. sep .. sample['type_instance']
elseif metric_source == 'dbi' and sample['plugin_instance'] == 'services_nova' then
msg['Fields']['name'] = 'openstack.nova' .. sep .. sample['type_instance']
local service, state = split_service_and_state(sample['type_instance'])
msg['Fields']['name'] = 'openstack' .. sep .. 'nova' .. sep .. 'services'
msg['Fields']['tag_fields'] = { 'service', 'state' }
msg['Fields']['service'] = service
msg['Fields']['state'] = state
elseif metric_source == 'dbi' and sample['plugin_instance'] == 'services_cinder' then
msg['Fields']['name'] = 'openstack.cinder' .. sep .. sample['type_instance']
msg['Fields']['name'] = 'openstack' .. sep .. 'cinder' .. sep .. 'services'
msg['Fields']['tag_fields'] = { 'service', 'state' }
msg['Fields']['service'] = service
msg['Fields']['state'] = state
elseif metric_source == 'dbi' and sample['plugin_instance'] == 'agents_neutron' then
msg['Fields']['name'] = 'openstack.neutron' .. sep .. sample['type_instance']
msg['Fields']['name'] = 'openstack' .. sep .. 'neutron' .. sep .. 'agents'
msg['Fields']['tag_fields'] = { 'service', 'state' }
msg['Fields']['service'] = service
msg['Fields']['state'] = state
else
msg['Fields']['name'] = metric_name
msg['Fields']['name'] = replace_dot_by_sep(metric_name)
end
if not skip_it then
utils.inject_tags(msg)
inject_message(msg)
end
utils.inject_tags(msg)
inject_message(msg)
end
end

170
deployment_scripts/puppet/modules/lma_collector/files/plugins/decoders/collectd_legacy.lua Normal file
View File

@ -0,0 +1,170 @@
-- Copyright 2015 Mirantis, Inc.
--
-- Licensed under the Apache License, Version 2.0 (the "License");
-- you may not use this file except in compliance with the License.
-- You may obtain a copy of the License at
--
-- http://www.apache.org/licenses/LICENSE-2.0
--
-- Unless required by applicable law or agreed to in writing, software
-- distributed under the License is distributed on an "AS IS" BASIS,
-- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-- See the License for the specific language governing permissions and
-- limitations under the License.
require "string"
require "cjson"
local utils = require 'lma_utils'
local sep = '.'
local processes_map = {
ps_code = 'memory.code',
ps_count = 'count',
ps_cputime = 'cputime',
ps_data = 'memory.data',
ps_disk_octets = 'disk.bytes',
ps_disk_ops = 'disk.ops',
ps_pagefaults = 'pagefaults',
ps_rss = 'memory.rss',
ps_stacksize = 'stacksize',
ps_vm = 'memory.virtual',
}
function process_message ()
local ok, samples = pcall(cjson.decode, read_message("Payload"))
if not ok then
-- TODO: log error
return -1
end
for _, sample in ipairs(samples) do
local metric_prefix = sample['type']
if sample['type_instance'] ~= "" then metric_prefix = metric_prefix .. sep .. sample['type_instance'] end
local metric_source = sample['plugin']
for i, value in ipairs(sample['values']) do
local metric_name = metric_prefix
if sample['dsnames'][i] ~= "value" then metric_name = metric_name .. sep .. sample['dsnames'][i] end
local msg = {
Timestamp = sample['time'] * 1e9, -- Heka expects nanoseconds
Hostname = sample['host'],
Logger = "collectd",
Payload = cjson.encode(sample),
Severity = 6,
Type = "metric",
Fields = {
hostname = sample['host'],
interval = sample['interval'],
source = metric_source,
type = sample['dstypes'][i],
value = value,
}
}
-- Normalize metric name, unfortunately collectd plugins aren't
-- always consistent on metric namespaces so we need a few if/else
-- statements to cover all cases.
if metric_source == 'df' then
local mount = sample['plugin_instance']
local entity
if sample['type'] == 'df_inodes' then
entity = 'inodes'
else -- sample['type'] == 'df_complex'
entity = 'space'
end
msg['Fields']['name'] = 'fs' .. sep .. mount .. sep .. entity .. sep .. sample['type_instance']
msg['Fields']['device'] = '/' .. string.gsub(mount, '-', '/')
elseif metric_source == 'disk' then
msg['Fields']['device'] = sample['plugin_instance']
msg['Fields']['name'] = 'disk' .. sep .. sample['plugin_instance'] .. sep .. metric_name
elseif metric_source == 'cpu' then
msg['Fields']['device'] = 'cpu' .. sample['plugin_instance']
msg['Fields']['name'] = 'cpu' .. sep .. sample['plugin_instance'] .. sep .. sample['type_instance']
elseif metric_source == 'interface' then
msg['Fields']['device'] = sample['plugin_instance']
msg['Fields']['name'] = 'net' .. sep .. sample['plugin_instance'] .. sep .. sample['type'] .. sep .. sample['dsnames'][i]
elseif metric_source == 'processes' then
if processes_map[sample['type']] then
msg['Fields']['name'] = 'lma_components' .. sep .. sample['plugin_instance'] .. sep .. processes_map[sample['type']]
if sample['dsnames'][i] ~= 'value' then
msg['Fields']['name'] = msg['Fields']['name'] .. sep .. sample['dsnames'][i]
end
-- For ps_cputime, convert it to percentage. We have number of microseconds within one second.
if sample['type'] == 'ps_cputime' then
msg['Fields']['value'] = value / 10000
end
else
msg['Fields']['name'] = 'processes'
if sample['type'] == 'ps_state' then
msg['Fields']['name'] = msg['Fields']['name'] .. sep .. 'state' .. sep .. sample['type_instance']
else
msg['Fields']['name'] = msg['Fields']['name'] .. sep .. sample['type']
end
end
elseif metric_source == 'dbi' and sample['plugin_instance'] == 'mysql_status' then
msg['Fields']['name'] = 'mysql' .. sep .. sample['type_instance']
elseif metric_source == 'mysql' then
if sample['type'] == 'threads' then
msg['Fields']['name'] = 'mysql_' .. metric_name
else
msg['Fields']['name'] = metric_name
end
elseif metric_source == 'check_openstack_api' then
-- OpenStack API metrics
-- 'plugin_instance' = <service name>
msg['Fields']['name'] = 'openstack' .. sep .. sample['plugin_instance'] .. sep .. 'check_api'
if sample['type_instance'] ~= nil and sample['type_instance'] ~= '' then
msg['Fields']['os_region'] = sample['type_instance']
end
elseif metric_source == 'hypervisor_stats' then
-- OpenStack hypervisor metrics
-- 'type_instance' = <metric name> which can end by _MB or _GB
msg['Fields']['name'] = 'openstack' .. sep .. 'nova' .. sep
local name, unit
name, unit = string.match(sample['type_instance'], '^(.+)_(.B)$')
if name then
msg['Fields']['name'] = msg['Fields']['name'] .. name
msg.Fields['value'] = {value = msg.Fields['value'], representation = unit}
else
msg['Fields']['name'] = msg['Fields']['name'] .. sample['type_instance']
end
elseif metric_source == 'rabbitmq_info' then
msg['Fields']['name'] = 'rabbitmq' .. sep .. sample['type_instance']
elseif metric_source == 'nova' then
msg['Fields']['name'] = 'openstack.nova' .. sep .. sample['plugin_instance'] .. sep .. sample['type_instance']
elseif metric_source == 'cinder' then
msg['Fields']['name'] = 'openstack.cinder' .. sep .. sample['plugin_instance'] .. sep .. sample['type_instance']
elseif metric_source == 'glance' then
msg['Fields']['name'] = 'openstack.glance' .. sep .. sample['type_instance']
elseif metric_source == 'keystone' then
msg['Fields']['name'] = 'openstack.keystone' .. sep .. sample['type_instance']
elseif metric_source == 'neutron' then
msg['Fields']['name'] = 'openstack.neutron' .. sep .. sample['type_instance']
elseif metric_source == 'memcached' then
msg['Fields']['name'] = 'memcached' .. sep .. string.gsub(metric_name, 'memcached_', '')
elseif metric_source == 'haproxy' then
msg['Fields']['name'] = 'haproxy' .. sep .. sample['type_instance']
elseif metric_source == 'apache' then
metric_name = string.gsub(metric_name, 'apache_', '')
msg['Fields']['name'] = 'apache' .. sep .. string.gsub(metric_name, 'scoreboard', 'workers')
elseif metric_source == 'ceph' then
msg['Fields']['name'] = 'ceph' .. sep .. sample['plugin_instance'] .. sep .. sample['type_instance']
elseif metric_source == 'dbi' and sample['plugin_instance'] == 'services_nova' then
msg['Fields']['name'] = 'openstack.nova' .. sep .. sample['type_instance']
elseif metric_source == 'dbi' and sample['plugin_instance'] == 'services_cinder' then
msg['Fields']['name'] = 'openstack.cinder' .. sep .. sample['type_instance']
elseif metric_source == 'dbi' and sample['plugin_instance'] == 'agents_neutron' then
msg['Fields']['name'] = 'openstack.neutron' .. sep .. sample['type_instance']
else
msg['Fields']['name'] = metric_name
end
utils.inject_tags(msg)
inject_message(msg)
end
end
return 0
end

115
deployment_scripts/puppet/modules/lma_collector/manifests/collectd/base_legacy.pp Normal file
View File

@ -0,0 +1,115 @@
# Copyright 2015 Mirantis, Inc.
#
# Licensed under the Apache License, Version 2.0 (the "License"); you may
# not use this file except in compliance with the License. You may obtain
# a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
# License for the specific language governing permissions and limitations
# under the License.
#
class lma_collector::collectd::base_legacy (
$processes = undef,
$process_matches = undef,
$queue_limit = $lma_collector::params::collectd_queue_limit,
$read_threads = $lma_collector::params::collectd_read_threads,
){
include lma_collector::params
include lma_collector::service
$port = $lma_collector::params::collectd_port
class { '::collectd':
purge => true,
recurse => true,
purge_config => true,
fqdnlookup => false,
interval => $lma_collector::params::collectd_interval,
threads => $read_threads,
write_queue_limit_low => $lma_collector::params::collectd_queue_limit,
write_queue_limit_high => $lma_collector::params::collectd_queue_limit,
}
class { 'collectd::plugin::logfile':
log_level => 'warning',
log_file => $lma_collector::params::collectd_logfile,
}
$urls = {
"http://127.0.0.1:${port}" => {
'format' => 'JSON',
storerates => true
}
}
if $::osfamily == 'RedHat' {
# collectd Puppet manifest is broken for RedHat derivatives as it tries to
# install the collectd-write_http package which doesn't exist (for CentOS
# at least)
collectd::plugin {'write_http':
ensure => present,
content => template('collectd/plugin/write_http.conf.erb'),
}
}
else {
class { 'collectd::plugin::write_http':
urls => $urls,
}
}
class { 'collectd::plugin::cpu':
}
# TODO: pass this list as a parameter or add a custom fact
class { 'collectd::plugin::df':
mountpoints => ['/', '/boot'],
}
$block_devices = join(split($::blockdevices, ','), '|')
class { 'collectd::plugin::disk':
disks => [ "/^${ block_devices }$/" ],
}
class { 'collectd::plugin::interface':
interfaces => grep(split($::interfaces, ','), '^eth\d+$')
}
class { 'collectd::plugin::load':
}
class { 'collectd::plugin::memory':
}
class { 'collectd::plugin::processes':
processes => $processes,
process_matches => $process_matches,
}
class { 'collectd::plugin::swap':
}
class { 'collectd::plugin::users':
}
file { '/etc/logrotate.d/collectd':
ensure => present,
content => "${lma_collector::params::collectd_logfile} {\n daily\n missingok\n}"
}
heka::decoder::sandbox { 'collectd':
config_dir => $lma_collector::params::config_dir,
filename => "${lma_collector::params::plugins_dir}/decoders/collectd_legacy.lua" ,
notify => Class['lma_collector::service'],
}
heka::input::httplisten { 'collectd':
config_dir => $lma_collector::params::config_dir,
address => '127.0.0.1',
port => $port,
decoder => 'collectd',
require => Heka::Decoder::Sandbox['collectd'],
notify => Class['lma_collector::service'],
}
}