From d236b6ce1ee0ac7aa7bbe26570fbac16657b01a2 Mon Sep 17 00:00:00 2001 From: Vibhu Pandey Date: Mon, 16 Jun 2025 00:02:17 +0530 Subject: [PATCH] feat(statsreporter): add stats for telemetry.*.last_observed.time (#8251) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit ## 📄 Summary - add stats for telemetry.*.last_observed.time --- .../analyticsstatsreporter/provider.go | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/pkg/statsreporter/analyticsstatsreporter/provider.go b/pkg/statsreporter/analyticsstatsreporter/provider.go index e3adbd83a2dc..af4f63386f9c 100644 --- a/pkg/statsreporter/analyticsstatsreporter/provider.go +++ b/pkg/statsreporter/analyticsstatsreporter/provider.go @@ -216,5 +216,20 @@ func (provider *provider) collectOrg(ctx context.Context, orgID valuer.UUID) map stats["telemetry.metrics.count"] = metrics } + var tracesLastSeenAt time.Time + if err := provider.telemetryStore.ClickhouseDB().QueryRow(ctx, "SELECT max(timestamp) FROM signoz_traces.distributed_signoz_index_v3").Scan(&tracesLastSeenAt); err == nil { + stats["telemetry.traces.last_observed.time"] = tracesLastSeenAt.UTC() + } + + var logsLastSeenAt time.Time + if err := provider.telemetryStore.ClickhouseDB().QueryRow(ctx, "SELECT fromUnixTimestamp64Nano(max(timestamp)) FROM signoz_logs.distributed_logs_v2").Scan(&logsLastSeenAt); err == nil { + stats["telemetry.logs.last_observed.time"] = logsLastSeenAt.UTC() + } + + var metricsLastSeenAt time.Time + if err := provider.telemetryStore.ClickhouseDB().QueryRow(ctx, "SELECT toDateTime(max(unix_milli) / 1000) FROM signoz_metrics.distributed_samples_v4").Scan(&metricsLastSeenAt); err == nil { + stats["telemetry.metrics.last_observed.time"] = metricsLastSeenAt.UTC() + } + return stats }