import "github.com/grpc-ecosystem/go-grpc-middleware/recovery"
grpc_recovery are intereceptors that recover from gRPC handler panics.
By default a panic will be converted into a gRPC error with code.Internal.
Handling can be customised by providing an alternate recovery function.
Please see examples for simple examples of use.
Click to expand code.
// Shared options for the logger, with a custom gRPC code to log level function.
opts := []grpc_recovery.Option{
grpc_recovery.WithRecoveryHandler(customFunc),
}
// Create a server. Recovery handlers should typically be last in the chain so that other middleware
// (e.g. logging) can operate on the recovered state instead of being directly affected by any panic
server := grpc.NewServer(
grpc_middleware.WithUnaryServerChain(
grpc_recovery.UnaryServerInterceptor(opts...),
),
grpc_middleware.WithStreamServerChain(
grpc_recovery.StreamServerInterceptor(opts...),
),
)
return server- func StreamServerInterceptor(opts ...Option) grpc.StreamServerInterceptor
- func UnaryServerInterceptor(opts ...Option) grpc.UnaryServerInterceptor
- type Option
- type RecoveryHandlerFunc
doc.go interceptors.go options.go
func StreamServerInterceptor(opts ...Option) grpc.StreamServerInterceptorStreamServerInterceptor returns a new streaming server interceptor for panic recovery.
func UnaryServerInterceptor(opts ...Option) grpc.UnaryServerInterceptorUnaryServerInterceptor returns a new unary server interceptor for panic recovery.
type Option func(*options)func WithRecoveryHandler(f RecoveryHandlerFunc) OptionWithRecoveryHandler customizes the function for recovering from a panic.
type RecoveryHandlerFunc func(p interface{}) (err error)RecoveryHandlerFunc is a function that recovers from the panic p by returning an error.
Generated by godoc2ghmd