- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for grpchealth (0.14 sec)
-
pkg/probe/grpc/grpc_test.go
func (s successServerMock) Check(context.Context, *grpchealth.HealthCheckRequest) (*grpchealth.HealthCheckResponse, error) { return &grpchealth.HealthCheckResponse{ Status: grpchealth.HealthCheckResponse_SERVING, }, nil } func (s successServerMock) Watch(_ *grpchealth.HealthCheckRequest, stream grpchealth.Health_WatchServer) error { return stream.Send(&grpchealth.HealthCheckResponse{ Status: grpchealth.HealthCheckResponse_SERVING, }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 20 00:23:53 UTC 2021 - 5.7K bytes - Viewed (0) -
pkg/probe/grpc/grpc.go
} } defer func() { _ = conn.Close() }() client := grpchealth.NewHealthClient(conn) resp, err := client.Check(metadata.NewOutgoingContext(ctx, make(metadata.MD)), &grpchealth.HealthCheckRequest{ Service: service, }) if err != nil { stat, ok := status.FromError(err) if ok { switch stat.Code() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 25 19:28:03 UTC 2023 - 4K bytes - Viewed (0) -
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)