Package io.kroxylicious.proxy.internal.net

Class NetworkBindRequest

java.lang.Object

io.kroxylicious.proxy.internal.net.NetworkBindingOperation<io.netty.channel.Channel>

io.kroxylicious.proxy.internal.net.NetworkBindRequest

public class NetworkBindRequest
extends NetworkBindingOperation<io.netty.channel.Channel>

Request for a network endpoint to be bound.

Field Summary

Fields inherited from class io.kroxylicious.proxy.internal.net.NetworkBindingOperation

tls

Constructor Summary

Constructors

Constructor	Description
NetworkBindRequest(CompletableFuture<io.netty.channel.Channel> future, Endpoint endpoint)

Method Summary

Modifier and Type	Method	Description
Optional<String>	getBindingAddress()
CompletableFuture<io.netty.channel.Channel>	getFuture()	The future that signals the completion of the network binding operation.
void	performBindingOperation(io.netty.bootstrap.ServerBootstrap serverBootstrap, ExecutorService executorService)	Performs the binding operation.
int	port()	The port associated with the binding operation.

Methods inherited from class io.kroxylicious.proxy.internal.net.NetworkBindingOperation

tls

Methods inherited from class java.lang.Object

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

Constructor Details

NetworkBindRequest

public NetworkBindRequest(CompletableFuture<io.netty.channel.Channel> future,
 Endpoint endpoint)

Method Details

getBindingAddress

public Optional<String> getBindingAddress()

port

public int port()

Description copied from class: NetworkBindingOperation

The port associated with the binding operation.

Specified by:

port in class NetworkBindingOperation<io.netty.channel.Channel>

Returns:

port

getFuture

public CompletableFuture<io.netty.channel.Channel> getFuture()

Description copied from class: NetworkBindingOperation

The future that signals the completion of the network binding operation.

Specified by:

getFuture in class NetworkBindingOperation<io.netty.channel.Channel>

Returns:

completable future

performBindingOperation

public void performBindingOperation(io.netty.bootstrap.ServerBootstrap serverBootstrap,
 ExecutorService executorService)

Description copied from class: NetworkBindingOperation

Performs the binding operation. Implementations must organise of the future provided by NetworkBindingOperation.getFuture() to be CompletableFuture.complete(Object) when the binding operation completes successfully. If the binding operations fails, the future must be CompletableFuture.completeExceptionally(Throwable).
If the implementation makes use of FutureListener, the implementation of the GenericFutureListener.operationComplete(Future) method must delegate work to the executorService rather than occupy the Netty owned worker thread.

Specified by:

performBindingOperation in class NetworkBindingOperation<io.netty.channel.Channel>

Parameters:

serverBootstrap - server bootstrap on which the binding operations must be performed.

executorService - executor service