forked from statsd/statsd
-
Notifications
You must be signed in to change notification settings - Fork 0
/
php-example.php
168 lines (141 loc) · 4.62 KB
/
php-example.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
<?php
/**
* Sends statistics to the stats daemon over UDP
*
**/
class StatsD {
/**
* Sets one or more timing values
*
* @param string|array $stats The metric(s) to set.
* @param float $time The elapsed time (ms) to log
**/
public static function timing($stats, $time) {
StatsD::updateStats($stats, $time, 1, 'ms');
}
/**
* Sets one or more gauges to a value
*
* @param string|array $stats The metric(s) to set.
* @param float $value The value for the stats.
**/
public static function gauge($stats, $value) {
StatsD::updateStats($stats, $value, 1, 'g');
}
/**
* A "Set" is a count of unique events.
* This data type acts like a counter, but supports counting
* of unique occurences of values between flushes. The backend
* receives the number of unique events that happened since
* the last flush.
*
* The reference use case involved tracking the number of active
* and logged in users by sending the current userId of a user
* with each request with a key of "uniques" (or similar).
*
* @param string|array $stats The metric(s) to set.
* @param float $value The value for the stats.
**/
public static function set($stats, $value) {
StatsD::updateStats($stats, $value, 1, 's');
}
/**
* Increments one or more stats counters
*
* @param string|array $stats The metric(s) to increment.
* @param float|1 $sampleRate the rate (0-1) for sampling.
* @return boolean
**/
public static function increment($stats, $sampleRate=1) {
StatsD::updateStats($stats, 1, $sampleRate, 'c');
}
/**
* Decrements one or more stats counters.
*
* @param string|array $stats The metric(s) to decrement.
* @param float|1 $sampleRate the rate (0-1) for sampling.
* @return boolean
**/
public static function decrement($stats, $sampleRate=1) {
StatsD::updateStats($stats, -1, $sampleRate, 'c');
}
/**
* Updates one or more stats.
*
* @param string|array $stats The metric(s) to update. Should be either a string or array of metrics.
* @param int|1 $delta The amount to increment/decrement each metric by.
* @param float|1 $sampleRate the rate (0-1) for sampling.
* @param string|c $metric The metric type ("c" for count, "ms" for timing, "g" for gauge, "s" for set)
* @return boolean
**/
public static function updateStats($stats, $delta=1, $sampleRate=1, $metric='c') {
if (!is_array($stats)) { $stats = array($stats); }
$data = array();
foreach($stats as $stat) {
$data[$stat] = "$delta|$metric";
}
StatsD::send($data, $sampleRate);
}
/*
* Squirt the metrics over UDP
**/
public static function send($data, $sampleRate=1) {
$config = Config::getInstance();
if (! $config->isEnabled("statsd")) { return; }
// sampling
$sampledData = array();
if ($sampleRate < 1) {
foreach ($data as $stat => $value) {
if ((mt_rand() / mt_getrandmax()) <= $sampleRate) {
$sampledData[$stat] = "$value|@$sampleRate";
}
}
} else {
$sampledData = $data;
}
if (empty($sampledData)) { return; }
// Wrap this in a try/catch - failures in any of this should be silently ignored
try {
$host = $config->getConfig("statsd.host");
$port = $config->getConfig("statsd.port");
$fp = fsockopen("udp://$host", $port, $errno, $errstr);
if (! $fp) { return; }
foreach ($sampledData as $stat => $value) {
fwrite($fp, "$stat:$value");
}
fclose($fp);
} catch (Exception $e) {
}
}
}
class Config
{
private static $_instance;
private $_data;
private function __construct()
{
$this->_data = parse_ini_file('statsd.ini', true);
}
public static function getInstance()
{
if (!self::$_instance) self::$_instance = new self();
return self::$_instance;
}
public function isEnabled($section)
{
return isset($this->_data[$section]);
}
public function getConfig($name)
{
$name_array = explode('.', $name, 2);
if (count($name_array) < 2) return;
list($section, $param) = $name_array;
if (!isset($this->_data[$section][$param])) return;
return $this->_data[$section][$param];
}
}
/* Config file example (put it into "statsd.ini"):
[statsd]
host = yourhost
port = 8125
*/