Lines Matching refs:buffer
18 func appendHeader(buffer []byte, namespace string, name string) []byte {
20 buffer = append(buffer, namespace...)
22 buffer = append(buffer, name...)
23 buffer = append(buffer, ':')
24 return buffer
27 func appendRate(buffer []byte, rate float64) []byte {
29 buffer = append(buffer, "|@"...)
30 buffer = strconv.AppendFloat(buffer, rate, 'f', -1, 64)
32 return buffer
35 func appendWithoutNewlines(buffer []byte, s string) []byte {
38 return append(buffer, s...)
43 buffer = append(buffer, b)
46 return buffer
49 func appendTags(buffer []byte, globalTags []string, tags []string) []byte {
51 return buffer
53 buffer = append(buffer, "|#"...)
58 buffer = append(buffer, tagSeparatorSymbol...)
60 buffer = appendWithoutNewlines(buffer, tag)
65 buffer = append(buffer, tagSeparatorSymbol...)
67 buffer = appendWithoutNewlines(buffer, tag)
70 return buffer
73 func appendTagsAggregated(buffer []byte, globalTags []string, tags string) []byte {
75 return buffer
78 buffer = append(buffer, "|#"...)
83 buffer = append(buffer, tagSeparatorSymbol...)
85 buffer = appendWithoutNewlines(buffer, tag)
90 buffer = append(buffer, tagSeparatorSymbol...)
92 buffer = appendWithoutNewlines(buffer, tags)
94 return buffer
97 func appendFloatMetric(buffer []byte, typeSymbol []byte, namespace string, globalTags []string, nam…
98 buffer = appendHeader(buffer, namespace, name)
99 buffer = strconv.AppendFloat(buffer, value, 'f', precision, 64)
100 buffer = append(buffer, '|')
101 buffer = append(buffer, typeSymbol...)
102 buffer = appendRate(buffer, rate)
103 buffer = appendTags(buffer, globalTags, tags)
104 return buffer
107 func appendIntegerMetric(buffer []byte, typeSymbol []byte, namespace string, globalTags []string, n…
108 buffer = appendHeader(buffer, namespace, name)
109 buffer = strconv.AppendInt(buffer, value, 10)
110 buffer = append(buffer, '|')
111 buffer = append(buffer, typeSymbol...)
112 buffer = appendRate(buffer, rate)
113 buffer = appendTags(buffer, globalTags, tags)
114 return buffer
117 func appendStringMetric(buffer []byte, typeSymbol []byte, namespace string, globalTags []string, na…
118 buffer = appendHeader(buffer, namespace, name)
119 buffer = append(buffer, value...)
120 buffer = append(buffer, '|')
121 buffer = append(buffer, typeSymbol...)
122 buffer = appendRate(buffer, rate)
123 buffer = appendTags(buffer, globalTags, tags)
124 return buffer
127 func appendGauge(buffer []byte, namespace string, globalTags []string, name string, value float64, …
128 return appendFloatMetric(buffer, gaugeSymbol, namespace, globalTags, name, value, tags, rate, -1)
131 func appendCount(buffer []byte, namespace string, globalTags []string, name string, value int64, ta…
132 return appendIntegerMetric(buffer, countSymbol, namespace, globalTags, name, value, tags, rate)
135 func appendHistogram(buffer []byte, namespace string, globalTags []string, name string, value float…
136 …return appendFloatMetric(buffer, histogramSymbol, namespace, globalTags, name, value, tags, rate, …
139 func appendDistribution(buffer []byte, namespace string, globalTags []string, name string, value fl…
140 …return appendFloatMetric(buffer, distributionSymbol, namespace, globalTags, name, value, tags, rat…
143 func appendSet(buffer []byte, namespace string, globalTags []string, name string, value string, tag…
144 return appendStringMetric(buffer, setSymbol, namespace, globalTags, name, value, tags, rate)
147 func appendTiming(buffer []byte, namespace string, globalTags []string, name string, value float64,…
148 return appendFloatMetric(buffer, timingSymbol, namespace, globalTags, name, value, tags, rate, 6)
155 func appendEscapedEventText(buffer []byte, text string) []byte {
158 buffer = append(buffer, b)
160 buffer = append(buffer, "\\n"...)
163 return buffer
166 func appendEvent(buffer []byte, event Event, globalTags []string) []byte {
169 buffer = append(buffer, "_e{"...)
170 buffer = strconv.AppendInt(buffer, int64(len(event.Title)), 10)
171 buffer = append(buffer, tagSeparatorSymbol...)
172 buffer = strconv.AppendInt(buffer, int64(escapedTextLen), 10)
173 buffer = append(buffer, "}:"...)
174 buffer = append(buffer, event.Title...)
175 buffer = append(buffer, '|')
177 buffer = appendEscapedEventText(buffer, event.Text)
179 buffer = append(buffer, event.Text...)
183 buffer = append(buffer, "|d:"...)
184 buffer = strconv.AppendInt(buffer, int64(event.Timestamp.Unix()), 10)
188 buffer = append(buffer, "|h:"...)
189 buffer = append(buffer, event.Hostname...)
193 buffer = append(buffer, "|k:"...)
194 buffer = append(buffer, event.AggregationKey...)
198 buffer = append(buffer, "|p:"...)
199 buffer = append(buffer, event.Priority...)
203 buffer = append(buffer, "|s:"...)
204 buffer = append(buffer, event.SourceTypeName...)
208 buffer = append(buffer, "|t:"...)
209 buffer = append(buffer, string(event.AlertType)...)
212 buffer = appendTags(buffer, globalTags, event.Tags)
213 return buffer
216 func appendEscapedServiceCheckText(buffer []byte, text string) []byte {
219 buffer = append(buffer, "\\n"...)
221 buffer = append(buffer, "m\\:"...)
224 buffer = append(buffer, text[i])
227 return buffer
230 func appendServiceCheck(buffer []byte, serviceCheck ServiceCheck, globalTags []string) []byte {
231 buffer = append(buffer, "_sc|"...)
232 buffer = append(buffer, serviceCheck.Name...)
233 buffer = append(buffer, '|')
234 buffer = strconv.AppendInt(buffer, int64(serviceCheck.Status), 10)
237 buffer = append(buffer, "|d:"...)
238 buffer = strconv.AppendInt(buffer, int64(serviceCheck.Timestamp.Unix()), 10)
242 buffer = append(buffer, "|h:"...)
243 buffer = append(buffer, serviceCheck.Hostname...)
246 buffer = appendTags(buffer, globalTags, serviceCheck.Tags)
249 buffer = append(buffer, "|m:"...)
250 buffer = appendEscapedServiceCheckText(buffer, serviceCheck.Message)
252 return buffer
255 func appendSeparator(buffer []byte) []byte {
256 return append(buffer, '\n')