- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for grpchealth (0.26 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)