public class SingleNodeClient extends java.lang.Object implements GrpcClient
| Constructor and Description |
|---|
SingleNodeClient(java.lang.String host,
int port,
Timeouts timeouts,
io.grpc.netty.shaded.io.netty.handler.ssl.SslContext context,
long keepAliveTimeoutInMs,
long keepAliveIntervalInMs) |
| Modifier and Type | Method and Description |
|---|---|
<A> java.util.concurrent.CompletableFuture<A> |
run(java.util.function.Function<io.grpc.ManagedChannel,java.util.concurrent.CompletableFuture<A>> action) |
void |
shutdown() |
public SingleNodeClient(java.lang.String host,
int port,
Timeouts timeouts,
io.grpc.netty.shaded.io.netty.handler.ssl.SslContext context,
long keepAliveTimeoutInMs,
long keepAliveIntervalInMs)
public <A> java.util.concurrent.CompletableFuture<A> run(java.util.function.Function<io.grpc.ManagedChannel,java.util.concurrent.CompletableFuture<A>> action)
run in interface GrpcClientpublic void shutdown()
throws java.lang.InterruptedException
shutdown in interface GrpcClientjava.lang.InterruptedException