Merge pull request #991 from go-kratos/feat/delete_grpc_recovery

delete grpc recovery

transport/grpc/client.go

@@ -5,7 +5,6 @@ import (
 	"time"
 
 	"github.com/go-kratos/kratos/v2/middleware"
-	"github.com/go-kratos/kratos/v2/middleware/recovery"
 	"github.com/go-kratos/kratos/v2/registry"
 	"github.com/go-kratos/kratos/v2/transport"
 	"github.com/go-kratos/kratos/v2/transport/grpc/resolver/discovery"
@@ -85,9 +84,6 @@ func DialInsecure(ctx context.Context, opts ...ClientOption) (*grpc.ClientConn,
 func dial(ctx context.Context, insecure bool, opts ...ClientOption) (*grpc.ClientConn, error) {
 	options := clientOptions{
 		timeout: 500 * time.Millisecond,
-		middleware: middleware.Chain(
-			recovery.Recovery(),
-		),
 	}
 	for _, o := range opts {
 		o(&options)

transport/grpc/server.go

@@ -12,7 +12,6 @@ import (
 	"github.com/go-kratos/kratos/v2/internal/host"
 	"github.com/go-kratos/kratos/v2/log"
 	"github.com/go-kratos/kratos/v2/middleware"
-	"github.com/go-kratos/kratos/v2/middleware/recovery"
 	"github.com/go-kratos/kratos/v2/transport"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/health"
@@ -100,9 +99,6 @@ func NewServer(opts ...ServerOption) *Server {
 		network: "tcp",
 		address: ":0",
 		timeout: 1 * time.Second,
-		middleware: middleware.Chain(
-			recovery.Recovery(),
-		),
 		health:  health.NewServer(),
 		log:     log.NewHelper(log.DefaultLogger),
 	}

transport/http/handle.go

@@ -11,7 +11,6 @@ import (
 	"github.com/go-kratos/kratos/v2/errors"
 	"github.com/go-kratos/kratos/v2/internal/httputil"
 	"github.com/go-kratos/kratos/v2/middleware"
-	"github.com/go-kratos/kratos/v2/middleware/recovery"
 	"github.com/go-kratos/kratos/v2/transport/http/binding"
 )
 
@@ -46,7 +45,6 @@ func DefaultHandleOptions() HandleOptions {
 		Decode: DefaultRequestDecoder,
 		Encode: DefaultResponseEncoder,
 		Error:  DefaultErrorEncoder,
-		Middleware: recovery.Recovery(),
 	}
 }