From cef6fdb7b6258f524bcc51916e19447b69236948 Mon Sep 17 00:00:00 2001 From: Raja Subramanian Date: Fri, 24 Oct 2025 23:15:23 +0530 Subject: [PATCH] Correct direction for request/response for prom counters. (#4027) * Correct direction for request/response for prom counters. I think I had it reversed. * clean up * clean up --- pkg/routing/signal.go | 4 ++-- pkg/service/signal.go | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/routing/signal.go b/pkg/routing/signal.go index 4aaa9a877..caec171b3 100644 --- a/pkg/routing/signal.go +++ b/pkg/routing/signal.go @@ -133,8 +133,8 @@ func (r *signalClient) StartParticipantSignal( resChan, signalResponseMessageReader{}, r.config, - prometheus.RecordSignalRequestSuccess, - prometheus.RecordSignalRequestFailure, + prometheus.RecordSignalResponseSuccess, + prometheus.RecordSignalResponseFailure, ) l.Debugw("signal stream closed", "error", err) diff --git a/pkg/service/signal.go b/pkg/service/signal.go index f6c9316eb..648fec84d 100644 --- a/pkg/service/signal.go +++ b/pkg/service/signal.go @@ -168,8 +168,8 @@ func (r *signalService) RelaySignal(stream psrpc.ServerStream[*rpc.RelaySignalRe reqChan, signalRequestMessageReader{}, r.config, - prometheus.RecordSignalResponseSuccess, - prometheus.RecordSignalResponseFailure, + prometheus.RecordSignalRequestSuccess, + prometheus.RecordSignalRequestFailure, ) l.Debugw("signal stream closed", "error", err)