From aae835fd2fdede5776f1e7b5967c6a32e0b14dc4 Mon Sep 17 00:00:00 2001 From: r-dilip Date: Mon, 15 Oct 2018 14:50:12 -0700 Subject: [PATCH] Sending an event every 5 mins(Heartbeat) --- installer/conf/td-agent-bit.conf | 2 -- source/code/go/src/plugins/telemetry.go | 7 ++++--- 2 files changed, 4 insertions(+), 5 deletions(-) diff --git a/installer/conf/td-agent-bit.conf b/installer/conf/td-agent-bit.conf index b01b3a352..2553f405f 100644 --- a/installer/conf/td-agent-bit.conf +++ b/installer/conf/td-agent-bit.conf @@ -12,8 +12,6 @@ Parser docker Mem_Buf_Limit 30m Path_Key filepath - Buffer_Chunk_Size 1m - Buffer_Max_Size 1m Skip_Long_Lines On [OUTPUT] diff --git a/source/code/go/src/plugins/telemetry.go b/source/code/go/src/plugins/telemetry.go index 621d88eec..b1bc4439b 100644 --- a/source/code/go/src/plugins/telemetry.go +++ b/source/code/go/src/plugins/telemetry.go @@ -36,8 +36,8 @@ const ( metricNameAvgFlushRate = "ContainerLogAvgRecordsFlushedPerSec" defaultTelemetryPushIntervalSeconds = 300 - // EventNameContainerLogInit name of the event - EventNameContainerLogInit = "ContainerLogPluginInitialized" + eventNameContainerLogInit = "ContainerLogPluginInitialized" + eventNameDaemonSetHeartbeat = "ContainerLogDaemonSetHeartbeatEvent" ) // Initialize initializes the telemetry artifacts @@ -111,9 +111,10 @@ func SendContainerLogFlushRateMetric(telemetryPushIntervalProperty string, agent runtime.Goexit() } - SendEvent(EventNameContainerLogInit, make(map[string]string)) + SendEvent(eventNameContainerLogInit, make(map[string]string)) for ; true; <-ContainerLogTelemetryTicker.C { + SendEvent(eventNameDaemonSetHeartbeat, make(map[string]string)) DataUpdateMutex.Lock() flushRate := FlushedRecordsCount / FlushedRecordsTimeTaken * 1000 Log("Flushed Records : %f Time Taken : %f flush Rate : %f", FlushedRecordsCount, FlushedRecordsTimeTaken, flushRate)