grpc/test/end2end_test.go

75 const defaultHealthService = "grpc.health.v1.Health"  const
2479 	te.setHealthServingStatus(defaultHealthService, healthpb.HealthCheckResponse_SERVING)
2482 	verifyHealthCheckErrCode(t, 1*time.Second, te.clientConn(), defaultHealthService, codes.OK)
2501 	te.setHealthServingStatus(defaultHealthService, healthpb.HealthCheckResponse_SERVING)
2504 …verifyHealthCheckErrCode(t, 0*time.Second, te.clientConn(), defaultHealthService, codes.DeadlineEx…
2527 	verifyHealthCheckErrCode(t, 1*time.Second, te.clientConn(), defaultHealthService, codes.NotFound)
2545 	stream1, cf1 := newHealthCheckStream(t, cc, defaultHealthService)
2549 	stream2, cf2 := newHealthCheckStream(t, cc, defaultHealthService)
2553 	te.setHealthServingStatus(defaultHealthService, healthpb.HealthCheckResponse_NOT_SERVING)
2573 	stream, cf := newHealthCheckStream(t, te.clientConn(), defaultHealthService)
2577 	te.setHealthServingStatus(defaultHealthService, healthpb.HealthCheckResponse_SERVING)
2579 	te.setHealthServingStatus(defaultHealthService, healthpb.HealthCheckResponse_SERVING)
2580 	te.setHealthServingStatus(defaultHealthService, healthpb.HealthCheckResponse_NOT_SERVING)
2597 	hs.SetServingStatus(defaultHealthService, healthpb.HealthCheckResponse_SERVING)
2601 	stream, cf := newHealthCheckStream(t, te.clientConn(), defaultHealthService)
2622 	stream, cf := newHealthCheckStream(t, te.clientConn(), defaultHealthService)
2625 	te.setHealthServingStatus(defaultHealthService, healthpb.HealthCheckResponse_SERVING)
2641 	te.setHealthServingStatus(defaultHealthService, healthpb.HealthCheckResponse_SERVING)
2644 	stream, cf := newHealthCheckStream(t, te.clientConn(), defaultHealthService)
2713 	verifyHealthCheckErrCode(t, 1*time.Second, cc, defaultHealthService, codes.NotFound)
2714 	te.setHealthServingStatus(defaultHealthService, healthpb.HealthCheckResponse_SERVING)
2715 …verifyHealthCheckStatus(t, 1*time.Second, cc, defaultHealthService, healthpb.HealthCheckResponse_S…
2716 	te.setHealthServingStatus(defaultHealthService, healthpb.HealthCheckResponse_NOT_SERVING)
2717 …verifyHealthCheckStatus(t, 1*time.Second, cc, defaultHealthService, healthpb.HealthCheckResponse_N…