Package io.envoyproxy.envoy.service.health.v3

Class HealthDiscoveryServiceGrpc.HealthDiscoveryServiceBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<HealthDiscoveryServiceGrpc.HealthDiscoveryServiceBlockingStub>

io.envoyproxy.envoy.service.health.v3.HealthDiscoveryServiceGrpc.HealthDiscoveryServiceBlockingStub

Enclosing class:

HealthDiscoveryServiceGrpc

public static final class HealthDiscoveryServiceGrpc.HealthDiscoveryServiceBlockingStub
extends io.grpc.stub.AbstractBlockingStub<HealthDiscoveryServiceGrpc.HealthDiscoveryServiceBlockingStub>

A stub to allow clients to do synchronous rpc calls to service HealthDiscoveryService.

 HDS is Health Discovery Service. It compliments Envoy’s health checking
 service by designating this Envoy to be a healthchecker for a subset of hosts
 in the cluster. The status of these health checks will be reported to the
 management server, where it can be aggregated etc and redistributed back to
 Envoy through EDS.
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
protected HealthDiscoveryServiceGrpc.HealthDiscoveryServiceBlockingStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
HealthCheckSpecifier	fetchHealthCheck(HealthCheckRequestOrEndpointHealthResponse request)	TODO(htuch): Unlike the gRPC version, there is no stream-based binding of request/response.

Methods inherited from class io.grpc.stub.AbstractBlockingStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

build

protected HealthDiscoveryServiceGrpc.HealthDiscoveryServiceBlockingStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<HealthDiscoveryServiceGrpc.HealthDiscoveryServiceBlockingStub>

fetchHealthCheck

public HealthCheckSpecifier fetchHealthCheck(HealthCheckRequestOrEndpointHealthResponse request)

 TODO(htuch): Unlike the gRPC version, there is no stream-based binding of
 request/response. Should we add an identifier to the HealthCheckSpecifier
 to bind with the response?