feat(transport/grpc): support custom healthcheck

[perriea]

Description (what this PR does / why we need it):

Currently, it is not possible to define custom health checks. This PR should solve that.

Which issue(s) this PR fixes (resolves / be part of):

resolves #1397

[shenqidebaozi]

You can use it as an extension configuration instead of a default parameter. Your modifications introduce incompatible changes.

[codecov-commenter]

Codecov Report

Merging #2541 (eb224fa) into main (c530d63) will decrease coverage by 0.06%.
The diff coverage is 40.00%.

@@            Coverage Diff             @@
##             main    #2541      +/-   ##
==========================================
- Coverage   85.23%   85.16%   -0.07%     
==========================================
  Files          88       88              
  Lines        3826     3830       +4     
==========================================
+ Hits         3261     3262       +1     
- Misses        391      394       +3     
  Partials      174      174              

Impacted Files	Coverage Δ
transport/grpc/server.go	83.33% <40.00%> (-2.54%)	⬇️

Help us with your feedback. Take ten seconds to tell us how you rate us. Have a feature suggestion? Share it here.

[perriea]

@shenqidebaozi It's better now ? :)
I can create an example in https://github.com/go-kratos/examples, if you want.

// NewGRPCServer new a gRPC server.
func NewGRPCServer(c *conf.Server, greeter *service.SplitsService, ghealth *service.HealthService, logger hclog.Logger) *grpc.Server {
	var (
		log  hclog.Logger = logger.Named("NewGRPCServer")
		opts              = []grpc.ServerOption{
			grpc.CustomHealth(),
			grpc.Middleware(
				metadata.Server(),
				recovery.Recovery(),
				validate.Validator(),
				metrics.Server(
					metrics.WithSeconds(prom.NewHistogram(_metricSeconds)),
					metrics.WithRequests(prom.NewCounter(_metricRequests)),
				),
			),
		}
	)

	if c.Grpc.Network != "" {
		opts = append(opts, grpc.Network(c.Grpc.Network))
	}

	if c.Grpc.Hostname != "" {
		opts = append(opts, grpc.Address(c.Grpc.Hostname))
	}

	if c.Grpc.Timeout != nil {
		opts = append(opts, grpc.Timeout(c.Grpc.Timeout.AsDuration()))
	}

	srv := grpc.NewServer(opts...)
	srv.Use("/splits.v1.Splits/*", auth.MiddlewareOptions(log, c.Keycloak))
	srv.Use("/grpc.health.v1.Health/*")

	v1.RegisterSplitsServer(srv, greeter)
	grpc_health_v1.RegisterHealthServer(srv, ghealth)

	return srv
}

[shenqidebaozi]

@shenqidebaozi It's better now ? :) I can create an example in https://github.com/go-kratos/examples, if you want.

// NewGRPCServer new a gRPC server.
func NewGRPCServer(c *conf.Server, greeter *service.SplitsService, ghealth *service.HealthService, logger hclog.Logger) *grpc.Server {
	var (
		log  hclog.Logger = logger.Named("NewGRPCServer")
		opts              = []grpc.ServerOption{
			grpc.CustomHealth(),
			grpc.Middleware(
				metadata.Server(),
				recovery.Recovery(),
				validate.Validator(),
				metrics.Server(
					metrics.WithSeconds(prom.NewHistogram(_metricSeconds)),
					metrics.WithRequests(prom.NewCounter(_metricRequests)),
				),
			),
		}
	)

	if c.Grpc.Network != "" {
		opts = append(opts, grpc.Network(c.Grpc.Network))
	}

	if c.Grpc.Hostname != "" {
		opts = append(opts, grpc.Address(c.Grpc.Hostname))
	}

	if c.Grpc.Timeout != nil {
		opts = append(opts, grpc.Timeout(c.Grpc.Timeout.AsDuration()))
	}

	srv := grpc.NewServer(opts...)
	srv.Use("/splits.v1.Splits/*", auth.MiddlewareOptions(log, c.Keycloak))
	srv.Use("/grpc.health.v1.Health/*")

	v1.RegisterSplitsServer(srv, greeter)
	grpc_health_v1.RegisterHealthServer(srv, ghealth)

	return srv
}

@perriea This looks good. Can you submit it as well?

[shenqidebaozi]

LGTM