(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler)
| 82 | } |
| 83 | |
| 84 | func ErrorFormatStreamInterceptor(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error { |
| 85 | err := handler(srv, stream) |
| 86 | err = handleGrpcError(stream.Context(), err, "[GRPC]"+info.FullMethod) |
| 87 | return ToGRPC(err) |
| 88 | } |
| 89 | |
| 90 | func ErrorFormatUnaryClientInterceptor() grpc.UnaryClientInterceptor { |
| 91 | return func(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error { |
nothing calls this directly
no test coverage detected
searching dependent graphs…