@@ -246,16 +246,16 @@ func (app *App) Start() (err error) {
246
246
/* UPLOADER end */
247
247
248
248
/* RECEIVER start */
249
- if conf .Tcp .Enabled {
249
+ if conf .TCP .Enabled {
250
250
app .TCP , err = receiver .New (
251
- "tcp://" + conf .Tcp .Listen ,
251
+ "tcp://" + conf .TCP .Listen ,
252
252
app .Config .TagDesc ,
253
253
receiver .ParseThreads (runtime .GOMAXPROCS (- 1 )* 2 ),
254
254
receiver .WriteChan (app .writeChan ),
255
- receiver .DropFuture (uint32 (conf .Tcp .DropFuture .Value ().Seconds ())),
256
- receiver .DropPast (uint32 (conf .Tcp .DropPast .Value ().Seconds ())),
257
- receiver .DropLongerThan (conf .Tcp .DropLongerThan ),
258
- receiver .ReadTimeout (uint32 (conf .Tcp .ReadTimeout .Value ().Seconds ())),
255
+ receiver .DropFuture (uint32 (conf .TCP .DropFuture .Value ().Seconds ())),
256
+ receiver .DropPast (uint32 (conf .TCP .DropPast .Value ().Seconds ())),
257
+ receiver .DropLongerThan (conf .TCP .DropLongerThan ),
258
+ receiver .ReadTimeout (uint32 (conf .TCP .ReadTimeout .Value ().Seconds ())),
259
259
)
260
260
261
261
if err != nil {
@@ -265,15 +265,15 @@ func (app *App) Start() (err error) {
265
265
http .HandleFunc ("/debug/receive/tcp/dropped/" , app .TCP .DroppedHandler )
266
266
}
267
267
268
- if conf .Udp .Enabled {
268
+ if conf .UDP .Enabled {
269
269
app .UDP , err = receiver .New (
270
- "udp://" + conf .Udp .Listen ,
270
+ "udp://" + conf .UDP .Listen ,
271
271
app .Config .TagDesc ,
272
272
receiver .ParseThreads (runtime .GOMAXPROCS (- 1 )* 2 ),
273
273
receiver .WriteChan (app .writeChan ),
274
- receiver .DropFuture (uint32 (conf .Udp .DropFuture .Value ().Seconds ())),
275
- receiver .DropPast (uint32 (conf .Udp .DropPast .Value ().Seconds ())),
276
- receiver .DropLongerThan (conf .Udp .DropLongerThan ),
274
+ receiver .DropFuture (uint32 (conf .UDP .DropFuture .Value ().Seconds ())),
275
+ receiver .DropPast (uint32 (conf .UDP .DropPast .Value ().Seconds ())),
276
+ receiver .DropLongerThan (conf .UDP .DropLongerThan ),
277
277
)
278
278
279
279
if err != nil {
@@ -335,15 +335,15 @@ func (app *App) Start() (err error) {
335
335
http .HandleFunc ("/debug/receive/prometheus/dropped/" , app .Prometheus .DroppedHandler )
336
336
}
337
337
338
- if conf .TelegrafHttpJson .Enabled {
338
+ if conf .TelegrafHTTPJSON .Enabled {
339
339
app .TelegrafHttpJson , err = receiver .New (
340
- "telegraf+http+json://" + conf .TelegrafHttpJson .Listen ,
340
+ "telegraf+http+json://" + conf .TelegrafHTTPJSON .Listen ,
341
341
app .Config .TagDesc ,
342
342
receiver .WriteChan (app .writeChan ),
343
- receiver .DropFuture (uint32 (conf .TelegrafHttpJson .DropFuture .Value ().Seconds ())),
344
- receiver .DropPast (uint32 (conf .TelegrafHttpJson .DropPast .Value ().Seconds ())),
345
- receiver .DropLongerThan (conf .TelegrafHttpJson .DropLongerThan ),
346
- receiver .ConcatChar (conf .TelegrafHttpJson .Concat ),
343
+ receiver .DropFuture (uint32 (conf .TelegrafHTTPJSON .DropFuture .Value ().Seconds ())),
344
+ receiver .DropPast (uint32 (conf .TelegrafHTTPJSON .DropPast .Value ().Seconds ())),
345
+ receiver .DropLongerThan (conf .TelegrafHTTPJSON .DropLongerThan ),
346
+ receiver .ConcatChar (conf .TelegrafHTTPJSON .Concat ),
347
347
)
348
348
349
349
if err != nil {
0 commit comments