Skip to content

Commit

Permalink
GTW-6791 async telemetry shutdown
Browse files Browse the repository at this point in the history
GitOrigin-RevId: f36a8134d39797c0359374a94137a32f9f60dfeb
  • Loading branch information
develar authored and intellij-monorepo-bot committed Nov 23, 2023
1 parent c11dd21 commit 9492200
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -3,15 +3,14 @@ package com.intellij.tools.ide.metrics.collector.starter.collector
import com.intellij.ide.starter.ide.IDETestContext
import com.intellij.ide.starter.runner.IDERunContext
import com.intellij.tools.ide.metrics.collector.metrics.PerformanceMetrics
import com.intellij.tools.ide.metrics.collector.telemetry.getMetricsFromSpanAndChildren
import com.intellij.tools.ide.metrics.collector.telemetry.SpanFilter
import com.intellij.tools.ide.metrics.collector.telemetry.getMetricsFromSpanAndChildren

/**
* Collect spans from opentelemetry.json and convert it to metrics, understandable by IJ Perf dashboard
*/
class OpenTelemetrySpanCollector(val spanNames: List<String>) : MetricsCollector {
override fun collect(runContext: IDERunContext): List<PerformanceMetrics.Metric> {
return getMetricsFromSpanAndChildren(runContext.logsDir.resolve(IDETestContext.OPENTELEMETRY_FILE).toFile(),
SpanFilter.containsNameIn(spanNames))
return getMetricsFromSpanAndChildren(runContext.logsDir.resolve(IDETestContext.OPENTELEMETRY_FILE), SpanFilter.containsNameIn(spanNames))
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -3,10 +3,10 @@ package com.intellij.tools.ide.metrics.collector.starter.collector
import com.intellij.ide.starter.ide.IDETestContext.Companion.OPENTELEMETRY_FILE
import com.intellij.ide.starter.models.IDEStartResult
import com.intellij.tools.ide.metrics.collector.metrics.PerformanceMetrics
import com.intellij.tools.ide.metrics.collector.telemetry.getMetricsFromSpanAndChildren
import com.intellij.tools.ide.metrics.collector.telemetry.SpanFilter
import com.intellij.tools.ide.metrics.collector.telemetry.getMetricsFromSpanAndChildren

fun getMetricsFromSpanAndChildren(startResult: IDEStartResult, filter: SpanFilter): List<PerformanceMetrics.Metric> {
val opentelemetryFile = startResult.runContext.logsDir.resolve(OPENTELEMETRY_FILE).toFile()
val opentelemetryFile = startResult.runContext.logsDir.resolve(OPENTELEMETRY_FILE)
return getMetricsFromSpanAndChildren(opentelemetryFile, filter)
}

0 comments on commit 9492200

Please sign in to comment.