org.apache.flink.runtime.rest

Class RestServerEndpoint

java.lang.Object

org.apache.flink.runtime.rest.RestServerEndpoint

All Implemented Interfaces:

AutoCloseable, AutoCloseableAsync

Direct Known Subclasses:

WebMonitorEndpoint

public abstract class RestServerEndpoint
extends Object
implements AutoCloseableAsync

An abstract class for netty-based REST server endpoints.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RestServerEndpoint.RestHandlerUrlComparator Comparator for Rest URLs.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	log
protected Map<String,String>	responseHeaders
protected Path	uploadDir

Constructor Summary

Constructors

Constructor and Description
RestServerEndpoint(RestServerEndpointConfiguration configuration)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	closeAsync() Trigger the closing of the resource and return the corresponding close future.
String	getRestBaseUrl() Returns the base URL of the REST server endpoint.
InetSocketAddress	getServerAddress() Returns the address on which this endpoint is accepting requests.
protected abstract List<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>>	initializeHandlers(CompletableFuture<String> localAddressFuture) This method is called at the beginning of start() to setup all handlers that the REST server endpoint implementation requires.
protected CompletableFuture<Void>	shutDownInternal() Stops this REST server endpoint.
void	start() Starts this REST server endpoint.
protected abstract void	startInternal() Hook to start sub class specific services.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.util.AutoCloseableAsync

close

Field Detail

log

protected final org.slf4j.Logger log

uploadDir

protected final Path uploadDir

responseHeaders

protected final Map<String,String> responseHeaders

Constructor Detail

RestServerEndpoint

public RestServerEndpoint(RestServerEndpointConfiguration configuration)
                   throws IOException

Throws:

IOException

Method Detail

initializeHandlers

protected abstract List<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> initializeHandlers(CompletableFuture<String> localAddressFuture)

This method is called at the beginning of start() to setup all handlers that the REST server endpoint implementation requires.

Parameters:

localAddressFuture - future rest address of the RestServerEndpoint

Returns:

Collection of AbstractRestHandler which are added to the server endpoint

start

public final void start()
                 throws Exception

Starts this REST server endpoint.

Throws:

Exception - if we cannot start the RestServerEndpoint

startInternal

protected abstract void startInternal()
                               throws Exception

Hook to start sub class specific services.

Throws:

Exception - if an error occurred

getServerAddress

@Nullable
public InetSocketAddress getServerAddress()

Returns the address on which this endpoint is accepting requests.

Returns:

address on which this endpoint is accepting requests or null if none

getRestBaseUrl

public String getRestBaseUrl()

Returns the base URL of the REST server endpoint.

Returns:

REST base URL of this endpoint

closeAsync

public CompletableFuture<Void> closeAsync()

Description copied from interface: AutoCloseableAsync

Trigger the closing of the resource and return the corresponding close future.

Specified by:

closeAsync in interface AutoCloseableAsync

Returns:

Future which is completed once the resource has been closed

shutDownInternal

protected CompletableFuture<Void> shutDownInternal()

Stops this REST server endpoint.

Returns:

Future which is completed once the shut down has been finished.