es_gc_count

#!/usr/bin/env python
# -*- coding: utf-8 -*-

##############################################
# Munin plugin for Elasticsearch monitoring  #
# by Andrii Gakhov <andrii.gakhov@gmail.com> #
##############################################

import json
import urllib3

from munin import MuninPlugin


class ESGarbageCollectionCountPlugin(MuninPlugin):
    category = 'Elasticsearch'
    args = '--base 1000 --lower-limit 0'
    vlabel = 'Number of garbage collections'
    info = 'Show garbage collection counts'

    @property
    def title(self):
        return 'Elasticsearch Garbage Collection count'

    @property
    def fields(self):
        fields = [
            ('total', dict(
                label='total',
                type='GAUGE',
            )),
            ('young', dict(
                label='young generation',
                type='GAUGE',
            )),
            ('old', dict(
                label='old generation',
                type='GAUGE',
            ))
        ]
        return fields

    def __init__(self):
        super(ESGarbageCollectionCountPlugin, self).__init__()
        self.es_host = 'http://localhost:9200'
        self.http = urllib3.PoolManager()

    def execute(self):
        return self._get_gc_stats()

    def _get_gc_stats(self):
        url = '{}/_nodes/_local/jvm/stats'.format(self.es_host)
        response = self.http.request('GET', url)

        if response.status != 200:
            return None

        data = json.loads(response.data)
        if not data.get('nodes', {}).values():
            return None

        stats = data['nodes'].values()[0].get('jvm', {}).get('gc', {})
        return {
            'total': stats.get('collection_count'),
            'new': stats.get('collectors', {}).get(
                'ParNew', {}).get('collection_count'),
            'old': stats.get('collectors', {}).get(
                'ConcurrentMarkSweep', {}).get('collection_count'),
        }

if __name__ == '__main__':
    ESGarbageCollectionCountPlugin().run()