Skip to content

Commit acd8911

Browse files
committed
address comments adding telemetry for throttle
1 parent 4c71b9a commit acd8911

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

source/plugins/go/src/telemetry.go

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -312,6 +312,16 @@ func SendContainerLogPluginMetrics(telemetryPushIntervalProperty string) {
312312
telemetryDimensions["PromFbitBufferSize"] = os.Getenv("AZMON_FBIT_BUFFER_SIZE")
313313
telemetryDimensions["PromFbitMemBufLimit"] = os.Getenv("AZMON_FBIT_MEM_BUF_LIMIT")
314314

315+
if IsNetworkFlowLogsEnabled {
316+
telemetryDimensions["NetworkFlowLogsEnabled"] = "true"
317+
telemetryDimensions["NetworkFlowLogsThrottleRate"] = os.Getenv("NETWORKFLOW_LOGS_THROTTLE_RATE")
318+
telemetryDimensions["NetworkFlowLogsThrottleWindow"] = os.Getenv("NETWORKFLOW_LOGS_THROTTLE_WINDOW")
319+
telemetryDimensions["NetworkFlowLogsThrottleInterval"] = os.Getenv("NETWORKFLOW_LOGS_THROTTLE_INTERVAL")
320+
telemetryDimensions["NetworkFlowLogsThrottlePrint"] = os.Getenv("NETWORKFLOW_LOGS_THROTTLE_PRINT")
321+
} else {
322+
telemetryDimensions["NetworkFlowLogsEnabled"] = "false"
323+
}
324+
315325
SendEvent(eventNameDaemonSetHeartbeat, telemetryDimensions)
316326
flushRateMetric := appinsights.NewMetricTelemetry(metricNameAvgFlushRate, flushRate)
317327
TelemetryClient.Track(flushRateMetric)

0 commit comments

Comments
 (0)