com.jlupin.interfaces.balancer

Interface JLupinLoadBalancer<INPUT,OUTPUT>

public interface JLupinLoadBalancer<INPUT,OUTPUT>

Interface for load balancing remote method invocations.

Method Summary

Modifier and Type	Method and Description
<T> T	executeBalanceCommunication(String microserviceName, PortType portType, com.jlupin.interfaces.balancer.function.JLupinLoadBalancerCommunicationResultFunction jLupinLoadBalancerCommunicationResultFunction)
void	executeCommunicationOnAllNodes(String microserviceName, PortType portType, com.jlupin.interfaces.balancer.function.JLupinLoadBalancerCommunicationVoidFunction jLupinLoadBalancerCommunicationVoidFunction)
<T> T	executeCommunicationOnThisNode(String microserviceName, PortType portType, com.jlupin.interfaces.balancer.function.JLupinLoadBalancerCommunicationResultFunction jLupinLoadBalancerCommunicationResultFunction)
Socket	getFirstAvailableOpenSocket(String microserviceName, PortType portType)
int	getHowOftenCheckingServerInMillis()
String	getName() Returns load balancer name.
int	getServerAmountBasedOnServiceRepository(String microserviceName)
void	returnSocket(Socket socket)
void	start() Starts internal resources for load balancing.
void	stop() Stops internal resources for load balancing.

Method Detail

executeBalanceCommunication

<T> T executeBalanceCommunication(String microserviceName,
                                  PortType portType,
                                  com.jlupin.interfaces.balancer.function.JLupinLoadBalancerCommunicationResultFunction jLupinLoadBalancerCommunicationResultFunction)
                           throws JLupinLoadBalancerException,
                                  Throwable

Type Parameters:

T -

Parameters:

microserviceName -

portType -

jLupinLoadBalancerCommunicationResultFunction -

Returns:

Throws:

JLupinLoadBalancerException

Throwable

executeCommunicationOnThisNode

<T> T executeCommunicationOnThisNode(String microserviceName,
                                     PortType portType,
                                     com.jlupin.interfaces.balancer.function.JLupinLoadBalancerCommunicationResultFunction jLupinLoadBalancerCommunicationResultFunction)
                              throws JLupinLoadBalancerException,
                                     Throwable

Type Parameters:

T -

Parameters:

microserviceName -

portType -

jLupinLoadBalancerCommunicationResultFunction -

Returns:

Throws:

JLupinLoadBalancerException

Throwable

executeCommunicationOnAllNodes

void executeCommunicationOnAllNodes(String microserviceName,
                                    PortType portType,
                                    com.jlupin.interfaces.balancer.function.JLupinLoadBalancerCommunicationVoidFunction jLupinLoadBalancerCommunicationVoidFunction)
                             throws JLupinLoadBalancerException,
                                    Throwable

Parameters:

microserviceName -

portType -

jLupinLoadBalancerCommunicationVoidFunction -

Throws:

JLupinLoadBalancerException

Throwable

getFirstAvailableOpenSocket

Socket getFirstAvailableOpenSocket(String microserviceName,
                                   PortType portType)
                            throws JLupinLoadBalancerException

Parameters:

microserviceName -

portType -

Returns:

Throws:

JLupinLoadBalancerException

returnSocket

void returnSocket(Socket socket)

Parameters:

socket -

getName

String getName()

Returns load balancer name.

Returns:

name of load balancer

start

void start()

Starts internal resources for load balancing.

stop

void stop()

Stops internal resources for load balancing.

getHowOftenCheckingServerInMillis

int getHowOftenCheckingServerInMillis()

getServerAmountBasedOnServiceRepository

int getServerAmountBasedOnServiceRepository(String microserviceName)