From 3ccf822d67f223441263b7429cc2a5258ad3ae42 Mon Sep 17 00:00:00 2001 From: Vibhu Pandey Date: Thu, 3 Jul 2025 19:55:12 +0530 Subject: [PATCH] fix(statsreporter): add unix timestamps for last observed time (#8426) --- pkg/statsreporter/analyticsstatsreporter/provider.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/pkg/statsreporter/analyticsstatsreporter/provider.go b/pkg/statsreporter/analyticsstatsreporter/provider.go index afc55458852a..33632eff3add 100644 --- a/pkg/statsreporter/analyticsstatsreporter/provider.go +++ b/pkg/statsreporter/analyticsstatsreporter/provider.go @@ -220,6 +220,7 @@ func (provider *provider) collectOrg(ctx context.Context, orgID valuer.UUID) map if err := provider.telemetryStore.ClickhouseDB().QueryRow(ctx, "SELECT max(timestamp) FROM signoz_traces.distributed_signoz_index_v3").Scan(&tracesLastSeenAt); err == nil { if tracesLastSeenAt.Unix() != 0 { stats["telemetry.traces.last_observed.time"] = tracesLastSeenAt.UTC() + stats["telemetry.traces.last_observed.time_unix"] = tracesLastSeenAt.Unix() } } @@ -227,6 +228,7 @@ func (provider *provider) collectOrg(ctx context.Context, orgID valuer.UUID) map if err := provider.telemetryStore.ClickhouseDB().QueryRow(ctx, "SELECT fromUnixTimestamp64Nano(max(timestamp)) FROM signoz_logs.distributed_logs_v2").Scan(&logsLastSeenAt); err == nil { if logsLastSeenAt.Unix() != 0 { stats["telemetry.logs.last_observed.time"] = logsLastSeenAt.UTC() + stats["telemetry.logs.last_observed.time_unix"] = logsLastSeenAt.Unix() } } @@ -234,6 +236,7 @@ func (provider *provider) collectOrg(ctx context.Context, orgID valuer.UUID) map if err := provider.telemetryStore.ClickhouseDB().QueryRow(ctx, "SELECT toDateTime(max(unix_milli) / 1000) FROM signoz_metrics.distributed_samples_v4").Scan(&metricsLastSeenAt); err == nil { if metricsLastSeenAt.Unix() != 0 { stats["telemetry.metrics.last_observed.time"] = metricsLastSeenAt.UTC() + stats["telemetry.metrics.last_observed.time_unix"] = metricsLastSeenAt.Unix() } }