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)