Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for grpchealth (0.14 sec)

  1. 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)
  2. 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)
Back to top