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
int	getHowOftenCheckingServerInMillis()
String	getName() Returns load balancer name.
Iterator<Socket>	getOpenedSocketIteratorToAllMicroservicesByName(String microserviceName, PortType portType)
Socket	getOpenSocket(String microserviceName, PortType portType) get proper socket based on current load balancer settings
int	getServerAmountBasedOnServiceRepository(String microserviceName)
OUTPUT	sendAndReceiveWithoutSocketManaging(Socket clientSocket, INPUT input) send message by proper socket getting from Socket getOpenSocket(PortType portType) throws JLupinNotConnectedWithServerException method
byte[]	sendJLupinInputParameterAndGetOutputParameterAsByteArrayWithSocketManaging(String microserviceName, byte[][] jlupinInputParameterAsByteArray, PortType portType) Send serialized JLupinInputParameter to provided microservice to provided port.
void	start() Starts internal resources for load balancing.
void	stop() Stops internal resources for load balancing.

Method Detail

sendJLupinInputParameterAndGetOutputParameterAsByteArrayWithSocketManaging

byte[] sendJLupinInputParameterAndGetOutputParameterAsByteArrayWithSocketManaging(String microserviceName,
                                                                                  byte[][] jlupinInputParameterAsByteArray,
                                                                                  PortType portType)
                                                                           throws JLupinLoadBalancerException,
                                                                                  JLupinNotConnectedWithServerException

Send serialized JLupinInputParameter to provided microservice to provided port.

Parameters:

microserviceName - name of microservice to handle onSuccess

jlupinInputParameterAsByteArray - serialized JLupinInputParameter

portType - type of port on which send data

Returns:

serialized JLupinOutputParameter

Throws:

JLupinLoadBalancerException - on execution error

JLupinNotConnectedWithServerException - on connection error

getOpenSocket

Socket getOpenSocket(String microserviceName,
                     PortType portType)
              throws JLupinNotConnectedWithServerException,
                     com.jlupin.interfaces.balancer.exception.JLupinNoAvailableServerToConnectException

get proper socket based on current load balancer settings

Parameters:

microserviceName -

portType -

Returns:

Throws:

JLupinNotConnectedWithServerException

com.jlupin.interfaces.balancer.exception.JLupinNoAvailableServerToConnectException

sendAndReceiveWithoutSocketManaging

OUTPUT sendAndReceiveWithoutSocketManaging(Socket clientSocket,
                                           INPUT input)
                                    throws JLupinLoadBalancerException

send message by proper socket getting from Socket getOpenSocket(PortType portType) throws JLupinNotConnectedWithServerException method

Parameters:

clientSocket -

input -

Returns:

Throws:

JLupinLoadBalancerException

getOpenedSocketIteratorToAllMicroservicesByName

Iterator<Socket> getOpenedSocketIteratorToAllMicroservicesByName(String microserviceName,
                                                                 PortType portType)

Parameters:

microserviceName -

Returns:

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)