public abstract class RestServerEndpoint extends Object
Modifier and Type | Field and Description |
---|---|
protected org.slf4j.Logger |
log |
static int |
MAX_REQUEST_SIZE_BYTES |
Constructor and Description |
---|
RestServerEndpoint(RestServerEndpointConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
String |
getRestAddress()
Returns the address of the REST server endpoint.
|
InetSocketAddress |
getServerAddress()
Returns the address on which this endpoint is accepting requests.
|
protected abstract Collection<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> |
initializeHandlers(CompletableFuture<String> restAddressFuture)
This method is called at the beginning of
start() to setup all handlers that the REST server endpoint
implementation requires. |
void |
shutdown(Time timeout)
Stops this REST server endpoint.
|
void |
start()
Starts this REST server endpoint.
|
public static final int MAX_REQUEST_SIZE_BYTES
protected final org.slf4j.Logger log
public RestServerEndpoint(RestServerEndpointConfiguration configuration)
protected abstract Collection<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> initializeHandlers(CompletableFuture<String> restAddressFuture)
start()
to setup all handlers that the REST server endpoint
implementation requires.restAddressFuture
- future rest address of the RestServerEndpointpublic void start() throws Exception
Exception
- if we cannot start the RestServerEndpointpublic InetSocketAddress getServerAddress()
public String getRestAddress()
public void shutdown(Time timeout)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.