Lines Matching refs:buffer

17 func appendHeader(buffer []byte, namespace string, name string) []byte {
19 		buffer = append(buffer, namespace...)
21 	buffer = append(buffer, name...)
22 	buffer = append(buffer, ':')
23 	return buffer
26 func appendRate(buffer []byte, rate float64) []byte {
28 		buffer = append(buffer, "|@"...)
29 		buffer = strconv.AppendFloat(buffer, rate, 'f', -1, 64)
31 	return buffer
34 func appendWithoutNewlines(buffer []byte, s string) []byte {
37 		return append(buffer, s...)
42 			buffer = append(buffer, b)
45 	return buffer
48 func appendTags(buffer []byte, globalTags []string, tags []string) []byte {
50 		return buffer
52 	buffer = append(buffer, "|#"...)
57 			buffer = append(buffer, ',')
59 		buffer = appendWithoutNewlines(buffer, tag)
64 			buffer = append(buffer, ',')
66 		buffer = appendWithoutNewlines(buffer, tag)
69 	return buffer
72 func appendFloatMetric(buffer []byte, typeSymbol []byte, namespace string, globalTags []string, nam…
73 	buffer = appendHeader(buffer, namespace, name)
74 	buffer = strconv.AppendFloat(buffer, value, 'f', precision, 64)
75 	buffer = append(buffer, '|')
76 	buffer = append(buffer, typeSymbol...)
77 	buffer = appendRate(buffer, rate)
78 	buffer = appendTags(buffer, globalTags, tags)
79 	return buffer
82 func appendIntegerMetric(buffer []byte, typeSymbol []byte, namespace string, globalTags []string, n…
83 	buffer = appendHeader(buffer, namespace, name)
84 	buffer = strconv.AppendInt(buffer, value, 10)
85 	buffer = append(buffer, '|')
86 	buffer = append(buffer, typeSymbol...)
87 	buffer = appendRate(buffer, rate)
88 	buffer = appendTags(buffer, globalTags, tags)
89 	return buffer
92 func appendStringMetric(buffer []byte, typeSymbol []byte, namespace string, globalTags []string, na…
93 	buffer = appendHeader(buffer, namespace, name)
94 	buffer = append(buffer, value...)
95 	buffer = append(buffer, '|')
96 	buffer = append(buffer, typeSymbol...)
97 	buffer = appendRate(buffer, rate)
98 	buffer = appendTags(buffer, globalTags, tags)
99 	return buffer
102 func appendGauge(buffer []byte, namespace string, globalTags []string, name string, value float64, …
103 	return appendFloatMetric(buffer, gaugeSymbol, namespace, globalTags, name, value, tags, rate, -1)
106 func appendCount(buffer []byte, namespace string, globalTags []string, name string, value int64, ta…
107 	return appendIntegerMetric(buffer, countSymbol, namespace, globalTags, name, value, tags, rate)
110 func appendHistogram(buffer []byte, namespace string, globalTags []string, name string, value float…
111 …return appendFloatMetric(buffer, histogramSymbol, namespace, globalTags, name, value, tags, rate, …
114 func appendDistribution(buffer []byte, namespace string, globalTags []string, name string, value fl…
115 …return appendFloatMetric(buffer, distributionSymbol, namespace, globalTags, name, value, tags, rat…
118 func appendSet(buffer []byte, namespace string, globalTags []string, name string, value string, tag…
119 	return appendStringMetric(buffer, setSymbol, namespace, globalTags, name, value, tags, rate)
122 func appendTiming(buffer []byte, namespace string, globalTags []string, name string, value float64,…
123 	return appendFloatMetric(buffer, timingSymbol, namespace, globalTags, name, value, tags, rate, 6)
130 func appendEscapedEventText(buffer []byte, text string) []byte {
133 			buffer = append(buffer, b)
135 			buffer = append(buffer, "\\n"...)
138 	return buffer
141 func appendEvent(buffer []byte, event Event, globalTags []string) []byte {
144 	buffer = append(buffer, "_e{"...)
145 	buffer = strconv.AppendInt(buffer, int64(len(event.Title)), 10)
146 	buffer = append(buffer, ',')
147 	buffer = strconv.AppendInt(buffer, int64(escapedTextLen), 10)
148 	buffer = append(buffer, "}:"...)
149 	buffer = append(buffer, event.Title...)
150 	buffer = append(buffer, '|')
152 		buffer = appendEscapedEventText(buffer, event.Text)
154 		buffer = append(buffer, event.Text...)
158 		buffer = append(buffer, "|d:"...)
159 		buffer = strconv.AppendInt(buffer, int64(event.Timestamp.Unix()), 10)
163 		buffer = append(buffer, "|h:"...)
164 		buffer = append(buffer, event.Hostname...)
168 		buffer = append(buffer, "|k:"...)
169 		buffer = append(buffer, event.AggregationKey...)
173 		buffer = append(buffer, "|p:"...)
174 		buffer = append(buffer, event.Priority...)
178 		buffer = append(buffer, "|s:"...)
179 		buffer = append(buffer, event.SourceTypeName...)
183 		buffer = append(buffer, "|t:"...)
184 		buffer = append(buffer, string(event.AlertType)...)
187 	buffer = appendTags(buffer, globalTags, event.Tags)
188 	return buffer
191 func appendEscapedServiceCheckText(buffer []byte, text string) []byte {
194 			buffer = append(buffer, "\\n"...)
196 			buffer = append(buffer, "m\\:"...)
199 			buffer = append(buffer, text[i])
202 	return buffer
205 func appendServiceCheck(buffer []byte, serviceCheck ServiceCheck, globalTags []string) []byte {
206 	buffer = append(buffer, "_sc|"...)
207 	buffer = append(buffer, serviceCheck.Name...)
208 	buffer = append(buffer, '|')
209 	buffer = strconv.AppendInt(buffer, int64(serviceCheck.Status), 10)
212 		buffer = append(buffer, "|d:"...)
213 		buffer = strconv.AppendInt(buffer, int64(serviceCheck.Timestamp.Unix()), 10)
217 		buffer = append(buffer, "|h:"...)
218 		buffer = append(buffer, serviceCheck.Hostname...)
221 	buffer = appendTags(buffer, globalTags, serviceCheck.Tags)
224 		buffer = append(buffer, "|m:"...)
225 		buffer = appendEscapedServiceCheckText(buffer, serviceCheck.Message)
227 	return buffer
230 func appendSeparator(buffer []byte) []byte {
231 	return append(buffer, '\n')