- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for grpchealth (0.16 sec)
-
pkg/test/echo/server/endpoint/grpc.go
"google.golang.org/grpc/admin" "google.golang.org/grpc/credentials" "google.golang.org/grpc/credentials/insecure" xdscreds "google.golang.org/grpc/credentials/xds" "google.golang.org/grpc/health" grpcHealth "google.golang.org/grpc/health/grpc_health_v1" "google.golang.org/grpc/keepalive" "google.golang.org/grpc/metadata" "google.golang.org/grpc/peer" "google.golang.org/grpc/reflection" "google.golang.org/grpc/xds"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Sep 25 17:30:37 UTC 2023 - 8.7K bytes - Viewed (0) -
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)