diff --git a/go.mod b/go.mod index a2589a3..515b311 100644 --- a/go.mod +++ b/go.mod @@ -7,7 +7,7 @@ require ( github.com/grpc-ecosystem/grpc-gateway/v2 v2.12.0 github.com/improbable-eng/grpc-web v0.15.0 github.com/prometheus/client_golang v1.13.0 - github.com/rookie-ninja/rk-entry/v2 v2.2.16 + github.com/rookie-ninja/rk-entry/v2 v2.2.18 github.com/rookie-ninja/rk-logger v1.2.13 github.com/rookie-ninja/rk-query v1.2.14 github.com/soheilhy/cmux v0.1.5 diff --git a/go.sum b/go.sum index 435e343..07bc028 100644 --- a/go.sum +++ b/go.sum @@ -465,8 +465,8 @@ github.com/rogpeppe/fastuuid v0.0.0-20150106093220-6724a57986af/go.mod h1:XWv6So github.com/rogpeppe/fastuuid v1.2.0/go.mod h1:jVj6XXZzXRy/MSR5jhDC/2q6DgLz+nrA6LYCDYWNEvQ= github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4= github.com/rogpeppe/go-internal v1.6.1 h1:/FiVV8dS/e+YqF2JvO3yXRFbBLTIuSDkuC7aBOAvL+k= -github.com/rookie-ninja/rk-entry/v2 v2.2.16 h1:NorgaMxWbqdOGhdIv0bZeloWBJ5lyKQO6bJBlcuYsc8= -github.com/rookie-ninja/rk-entry/v2 v2.2.16/go.mod h1:P/Fd6Oyvvx0ITbEU2lzO3KkQ9miWVwd84aPaC0LMD0o= +github.com/rookie-ninja/rk-entry/v2 v2.2.18 h1:eGByO/Ycb6BbSsdrfIJwfxy9cdjM+5So7JHaBu6bMko= +github.com/rookie-ninja/rk-entry/v2 v2.2.18/go.mod h1:P/Fd6Oyvvx0ITbEU2lzO3KkQ9miWVwd84aPaC0LMD0o= github.com/rookie-ninja/rk-logger v1.2.13 h1:ERxeNZUmszlY4xehHcJRXECPtbjYIXzN8yRIyYyLGsg= github.com/rookie-ninja/rk-logger v1.2.13/go.mod h1:0ZiGn1KsHKOmCv+FHMH7k40DWYSJcj5yIR3EYcjlnLs= github.com/rookie-ninja/rk-query v1.2.14 h1:aYNyMXixpsEYRfEOz9Npt5QG3A6BQlo9vKjYc78x7bc= diff --git a/middleware/timeout/server_interceptor.go b/middleware/timeout/server_interceptor.go index 7e8da86..a9c3abe 100644 --- a/middleware/timeout/server_interceptor.go +++ b/middleware/timeout/server_interceptor.go @@ -60,6 +60,9 @@ func StreamServerInterceptor(opts ...rkmidtimeout.Option) grpc.StreamServerInter rkgrpcmid.AddToServerContextPayload(wrappedStream.WrappedContext, rkmid.EntryNameKey, set.GetEntryName()) beforeCtx := set.BeforeCtx(nil, rkgrpcctx.GetEvent(wrappedStream.WrappedContext)) + + beforeCtx.Input.UrlPath = info.FullMethod + toCtx := &streamTimeoutCtx{ srv: srv, stream: stream,