Package io.envoyproxy.envoy.service.discovery.v2

Class HealthDiscoveryServiceGrpc.HealthDiscoveryServiceFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractFutureStub<HealthDiscoveryServiceGrpc.HealthDiscoveryServiceFutureStub>

io.envoyproxy.envoy.service.discovery.v2.HealthDiscoveryServiceGrpc.HealthDiscoveryServiceFutureStub

Enclosing class:

HealthDiscoveryServiceGrpc

public static final class HealthDiscoveryServiceGrpc.HealthDiscoveryServiceFutureStub
extends io.grpc.stub.AbstractFutureStub<HealthDiscoveryServiceGrpc.HealthDiscoveryServiceFutureStub>

A stub to allow clients to do ListenableFuture-style 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.HealthDiscoveryServiceFutureStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<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.AbstractFutureStub

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.HealthDiscoveryServiceFutureStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

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

fetchHealthCheck

public com.google.common.util.concurrent.ListenableFuture<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?