- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for grpchealth (0.14 sec)
-
pilot/cmd/pilot-agent/status/server_test.go
appServer := grpc.NewServer() healthServer := health.NewServer() healthServer.SetServingStatus("serving-svc", grpcHealth.HealthCheckResponse_SERVING) healthServer.SetServingStatus("unknown-svc", grpcHealth.HealthCheckResponse_UNKNOWN) healthServer.SetServingStatus("not-serving-svc", grpcHealth.HealthCheckResponse_NOT_SERVING) grpcHealth.RegisterHealthServer(appServer, healthServer) listener, err := net.Listen("tcp", ":0") if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 42.6K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/server.go
return } defer conn.Close() var svc string if prober.GRPC.Service != nil { svc = *prober.GRPC.Service } grpcClient := grpcHealth.NewHealthClient(conn) resp, err := grpcClient.Check(ctx, &grpcHealth.HealthCheckRequest{ Service: svc, }) // the error handling is referenced from https://github.com/kubernetes/kubernetes/blob/v1.23.1/pkg/probe/grpc/grpc.go#L88-L106 if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 31.1K bytes - Viewed (1)