add metric rpc.server.duration for stream request

Signed-off-by: Ziqi Zhao <zhaoziqi9146@gmail.com>

instrumentation/google.golang.org/grpc/otelgrpc/interceptor.go

@@ -429,6 +429,7 @@ func StreamServerInterceptor(opts ...Option) grpc.StreamServerInterceptor {
 		info *grpc.StreamServerInfo,
 		handler grpc.StreamHandler,
 	) error {
+		requestStartTime := time.Now()
 		ctx := ss.Context()
 		i := &InterceptorInfo{
 			StreamServerInfo: info,
@@ -458,14 +459,24 @@ func StreamServerInterceptor(opts ...Option) grpc.StreamServerInterceptor {
 		)
 		defer span.End()
 
-		err := handler(srv, wrapServerStream(ctx, ss))
+		meter := cfg.MeterProvider.Meter(
+			instrumentationName,
+			metric.WithInstrumentationVersion(SemVersion()),
+		)
+		rpcServerDuration, _ := meter.SyncFloat64().Histogram("rpc.server.duration")
 
+		err := handler(srv, wrapServerStream(ctx, ss))
+		elapsedTime := float64(time.Since(requestStartTime)) / float64(time.Millisecond)
 		if err != nil {
 			s, _ := status.FromError(err)
 			span.SetStatus(codes.Error, s.Message())
 			span.SetAttributes(statusCodeAttr(s.Code()))
+			attr = append(attr, semconv.RPCGRPCStatusCodeKey.Int64(int64(s.Code())))
+			rpcServerDuration.Record(ctx, elapsedTime, attr...)
 		} else {
 			span.SetAttributes(statusCodeAttr(grpc_codes.OK))
+			attr = append(attr, semconv.RPCGRPCStatusCodeOk)
+			rpcServerDuration.Record(ctx, elapsedTime, attr...)
 		}
 
 		return err