T
- type of the gateway to retrievepublic abstract class LeaderGatewayRetriever<T extends RpcGateway> extends LeaderRetriever implements GatewayRetriever<T>
RpcGateway
.log
Constructor and Description |
---|
LeaderGatewayRetriever() |
Modifier and Type | Method and Description |
---|---|
protected abstract CompletableFuture<T> |
createGateway(CompletableFuture<Tuple2<String,UUID>> leaderFuture) |
CompletableFuture<T> |
getFuture()
Get future of object to retrieve.
|
void |
notifyNewLeaderAddress(CompletableFuture<Tuple2<String,UUID>> newLeaderAddressFuture) |
getLeaderFuture, getLeaderNow, handleError, notifyLeaderAddress
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getNow
public CompletableFuture<T> getFuture()
GatewayRetriever
getFuture
in interface GatewayRetriever<T extends RpcGateway>
public void notifyNewLeaderAddress(CompletableFuture<Tuple2<String,UUID>> newLeaderAddressFuture)
notifyNewLeaderAddress
in class LeaderRetriever
protected abstract CompletableFuture<T> createGateway(CompletableFuture<Tuple2<String,UUID>> leaderFuture)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.