1 # -*- coding: utf-8 -*-
2 # Description: memcached netdata python.d module
3 # Author: Pawel Krupa (paulfantom)
5 from base import SocketService
7 # default module values (can be overridden per job in `config`)
12 # default job configuration (overridden by python.d.plugin)
13 # config = {'local': {
14 # 'update_every': update_every,
16 # 'priority': priority,
17 # 'host': 'localhost',
22 ORDER = ['cache', 'net', 'connections', 'items', 'evicted_reclaimed',
23 'get', 'get_rate', 'set_rate', 'delete', 'cas', 'increment', 'decrement', 'touch', 'touch_rate']
27 'options': [None, 'Cache Size', 'kilobytes', 'Cache', 'memcached.cache', 'line'],
29 ['bytes', 'used', 'absolute', 1, 1024],
30 ['limit_maxbytes', 'total', 'absolute', 1, 1024]
33 'options': [None, 'Network', 'kilobytes/s', 'Network', 'memcached.net', 'line'],
35 ['bytes_read', 'read', 'incremental', 1, 1024],
36 ['bytes_written', 'written', 'incremental', 1, 1024]
39 'options': [None, 'Connections', 'connections/s', 'Cluster', 'memcached.connections', 'line'],
41 ['curr_connections', 'current', 'incremental'],
42 ['rejected_connections', 'rejected', 'incremental'],
43 ['total_connections', 'total', 'incremental']
46 'options': [None, 'Items', 'items', 'Cluster', 'memcached.items', 'line'],
48 ['curr_items', 'current', 'absolute'],
49 ['total_items', 'total', 'absolute']
51 'evicted_reclaimed': {
52 'options': [None, 'Items', 'items', 'Evicted and Reclaimed', 'memcached.evicted_reclaimed', 'line'],
54 ['evictions', 'evicted', 'absolute'],
55 ['reclaimed', 'reclaimed', 'absolute']
58 'options': [None, 'Requests', 'requests', 'GET', 'memcached.get', 'stacked'],
60 ['get_hits', 'hits', 'percent-of-absolute-row'],
61 ['get_misses', 'misses', 'percent-of-absolute-row']
64 'options': [None, 'Rate', 'requests/s', 'GET', 'memcached.get_rate', 'line'],
66 ['cmd_get', 'rate', 'incremental']
69 'options': [None, 'Rate', 'requests/s', 'SET', 'memcached.set_rate', 'line'],
71 ['cmd_set', 'rate', 'incremental']
74 'options': [None, 'Requests', 'requests', 'DELETE', 'memcached.delete', 'stacked'],
76 ['delete_hits', 'hits', 'percent-of-absolute-row'],
77 ['delete_misses', 'misses', 'percent-of-absolute-row'],
80 'options': [None, 'Requests', 'requests', 'CAS', 'memcached.cas', 'stacked'],
82 ['cas_hits', 'hits', 'percent-of-absolute-row'],
83 ['cas_misses', 'misses', 'percent-of-absolute-row'],
84 ['cas_badval', 'bad value', 'percent-of-absolute-row']
87 'options': [None, 'Requests', 'requests', 'Increment', 'memcached.increment', 'stacked'],
89 ['incr_hits', 'hits', 'percent-of-absolute-row'],
90 ['incr_misses', 'misses', 'percent-of-absolute-row']
93 'options': [None, 'Requests', 'requests', 'Decrement', 'memcached.decrement', 'stacked'],
95 ['decr_hits', 'hits', 'percent-of-absolute-row'],
96 ['decr_misses', 'misses', 'percent-of-absolute-row']
99 'options': [None, 'Requests', 'requests', 'Touch', 'memcached.touch', 'stacked'],
101 ['touch_hits', 'hits', 'percent-of-absolute-row'],
102 ['touch_misses', 'misses', 'percent-of-absolute-row']
105 'options': [None, 'Rate', 'requests/s', 'Touch', 'memcached.touch_rate', 'line'],
107 ['cmd_touch', 'rate', 'incremental']
112 class Service(SocketService):
113 def __init__(self, configuration=None, name=None):
114 SocketService.__init__(self, configuration=configuration, name=name)
115 self.request = "stats\r\n"
116 self.host = "localhost"
118 self._keep_alive = True
119 self.unix_socket = None
121 self.definitions = CHARTS
129 raw = self._get_raw_data().split("\n")
130 except AttributeError:
131 self.error("no data received")
133 if raw[0].startswith('ERROR'):
134 self.error("Memcached returned ERROR")
138 if line.startswith('STAT'):
140 t = line[5:].split(' ')
141 data[t[0]] = int(t[1])
142 except (IndexError, ValueError):
145 data['hit_rate'] = int((data['keyspace_hits'] / float(data['keyspace_hits'] + data['keyspace_misses'])) * 100)
150 self.error("received data doesn't have needed records")
155 def _check_raw_data(self, data):
156 if data.endswith('END\r\n'):
163 Parse configuration, check if memcached is available
169 self.chart_name += "_" + self.name
170 data = self._get_data()