feat: enable telemetry collection for gRPC (#738)

ory · Sep 29, 2021 · 5ac8b0c · 5ac8b0c
1 parent d371902
commit 5ac8b0c
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 3 deletions.
diff --git a/go.mod b/go.mod
@@ -36,7 +36,7 @@ require (
 	github.com/ory/herodot v0.9.6
 	github.com/ory/jsonschema/v3 v3.0.3
 	github.com/ory/keto/proto v0.0.0-00010101000000-000000000000
-	github.com/ory/x v0.0.284
+	github.com/ory/x v0.0.287
 	github.com/pelletier/go-toml v1.8.1
 	github.com/phayes/freeport v0.0.0-20180830031419-95f893ade6f2
 	github.com/pkg/errors v0.9.1

diff --git a/go.sum b/go.sum
@@ -865,8 +865,8 @@ github.com/ory/x v0.0.93/go.mod h1:lfcTaGXpTZs7IEQAW00r9EtTCOxD//SiP5uWtNiz31g=
 github.com/ory/x v0.0.110/go.mod h1:DJfkE3GdakhshNhw4zlKoRaL/ozg/lcTahA9OCih2BE=
 github.com/ory/x v0.0.127/go.mod h1:FwUujfFuCj5d+xgLn4fGMYPnzriR5bdAIulFXMtnK0M=
 github.com/ory/x v0.0.205/go.mod h1:A1s4iwmFIppRXZLF3J9GGWeY/HpREVm0Dk5z/787iek=
-github.com/ory/x v0.0.284 h1:/48+GczAw7FFTx1LFmb44FXAMaIa+Nj+sGPYi0eI2tg=
-github.com/ory/x v0.0.284/go.mod h1:APpShLyJcVzKw1kTgrHI+j/L9YM+8BRjHlcYObc7C1U=
+github.com/ory/x v0.0.287 h1:ubXxLsEOCaIX37KJnr/VgyfHQOQleNO9fmlqhcXK7hg=
+github.com/ory/x v0.0.287/go.mod h1:APpShLyJcVzKw1kTgrHI+j/L9YM+8BRjHlcYObc7C1U=
 github.com/pact-foundation/pact-go v1.0.4/go.mod h1:uExwJY4kCzNPcHRj+hCR/HBbOOIwwtUjcrb0b5/5kLM=
 github.com/parnurzeal/gorequest v0.2.15/go.mod h1:3Kh2QUMJoqw3icWAecsyzkpY7UzRfDhbRdTjtNwNiUE=
 github.com/pascaldekloe/goe v0.0.0-20180627143212-57f6aae5913c/go.mod h1:lzWF7FIEvWOWxwDKqyGYQf6ZUaNfKdP144TG7ZOy1lc=

diff --git a/internal/driver/registry_default.go b/internal/driver/registry_default.go
@@ -331,6 +331,9 @@ func (r *RegistryDefault) unaryInterceptors() []grpc.UnaryServerInterceptor {
 	if r.Tracer().IsLoaded() {
 		is = append(is, otgrpc.OpenTracingServerInterceptor(r.Tracer().Tracer()))
 	}
+	if r.sqaService != nil {
+		is = append(is, r.sqaService.UnaryInterceptor)
+	}
 	return is
 }
 
@@ -344,6 +347,9 @@ func (r *RegistryDefault) streamInterceptors() []grpc.StreamServerInterceptor {
 	if r.Tracer().IsLoaded() {
 		is = append(is, otgrpc.OpenTracingStreamServerInterceptor(r.Tracer().Tracer()))
 	}
+	if r.sqaService != nil {
+		is = append(is, r.sqaService.StreamInterceptor)
+	}
 	return is
 }