org.apache.flink.runtime.webmonitor.retriever

Interface GatewayRetriever<T extends RpcGateway>

Type Parameters:

T - type of the object to retrieve

All Known Implementing Classes:

AkkaJobManagerRetriever, LeaderGatewayRetriever, RpcGatewayRetriever

public interface GatewayRetriever<T extends RpcGateway>

Generic retriever interface for RpcGateway.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<T>	getFuture() Get future of object to retrieve.
default Optional<T>	getNow() Returns the currently retrieved gateway if there is such an object.

Method Detail

getFuture

CompletableFuture<T> getFuture()

Get future of object to retrieve.

Returns:

Future object to retrieve

getNow

default Optional<T> getNow()

Returns the currently retrieved gateway if there is such an object. Otherwise it returns an empty optional.

Returns:

Optional object to retrieve