io.micronaut.configuration.ribbon

Class RibbonLoadBalancer

java.lang.Object

io.micronaut.configuration.ribbon.RibbonLoadBalancer

All Implemented Interfaces:

com.netflix.loadbalancer.ILoadBalancer, LoadBalancer

public class RibbonLoadBalancer
extends Object
implements LoadBalancer, com.netflix.loadbalancer.ILoadBalancer

A LoadBalancer that is also a Ribbon ILoadBalancer.

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor and Description
RibbonLoadBalancer(com.netflix.client.config.IClientConfig niwsClientConfig, com.netflix.loadbalancer.ServerList serverList, com.netflix.loadbalancer.ServerListFilter serverListFilter, com.netflix.loadbalancer.IRule rule, com.netflix.loadbalancer.IPing ping) Constructor.

Method Summary

Modifier and Type	Method and Description
void	addServers(List<com.netflix.loadbalancer.Server> newServers)
com.netflix.loadbalancer.Server	chooseServer(Object key)
protected com.netflix.loadbalancer.ILoadBalancer	createLoadBalancer(com.netflix.client.config.IClientConfig clientConfig, com.netflix.loadbalancer.IRule rule, com.netflix.loadbalancer.IPing ping, com.netflix.loadbalancer.ServerListFilter serverListFilter, com.netflix.loadbalancer.ServerList<com.netflix.loadbalancer.Server> serverList) Creates the ILoadBalancer to use.
List<com.netflix.loadbalancer.Server>	getAllServers()
com.netflix.client.config.IClientConfig	getClientConfig()
com.netflix.loadbalancer.ILoadBalancer	getLoadBalancer()
com.netflix.loadbalancer.LoadBalancerContext	getLoadBalancerContext()
List<com.netflix.loadbalancer.Server>	getReachableServers()
List<com.netflix.loadbalancer.Server>	getServerList(boolean availableOnly)
void	markServerDown(com.netflix.loadbalancer.Server server)
Publisher<ServiceInstance>	select(Object discriminator)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.http.client.LoadBalancer

empty, fixed, select

Constructor Detail

RibbonLoadBalancer

public RibbonLoadBalancer(com.netflix.client.config.IClientConfig niwsClientConfig,
                          com.netflix.loadbalancer.ServerList serverList,
                          com.netflix.loadbalancer.ServerListFilter serverListFilter,
                          com.netflix.loadbalancer.IRule rule,
                          com.netflix.loadbalancer.IPing ping)

Constructor.

Parameters:

niwsClientConfig - niwsClientConfig

serverList - serverList

serverListFilter - serverListFilter

rule - rule

ping - ping

Method Detail

getClientConfig

public com.netflix.client.config.IClientConfig getClientConfig()

Returns:

The IClientConfig used to construct this load balancer

getLoadBalancer

public com.netflix.loadbalancer.ILoadBalancer getLoadBalancer()

Returns:

The underlying load balancer

getLoadBalancerContext

public com.netflix.loadbalancer.LoadBalancerContext getLoadBalancerContext()

Returns:

A LoadBalancerContext for this load balancer

select

public Publisher<ServiceInstance> select(Object discriminator)

Specified by:

select in interface LoadBalancer

Parameters:

discriminator - An object used to discriminate the server to select. Usually the service ID

Returns:

The selected ServiceInstance

addServers

public void addServers(List<com.netflix.loadbalancer.Server> newServers)

Specified by:

addServers in interface com.netflix.loadbalancer.ILoadBalancer

chooseServer

public com.netflix.loadbalancer.Server chooseServer(Object key)

Specified by:

chooseServer in interface com.netflix.loadbalancer.ILoadBalancer

markServerDown

public void markServerDown(com.netflix.loadbalancer.Server server)

Specified by:

markServerDown in interface com.netflix.loadbalancer.ILoadBalancer

getServerList

public List<com.netflix.loadbalancer.Server> getServerList(boolean availableOnly)

Specified by:

getServerList in interface com.netflix.loadbalancer.ILoadBalancer

getReachableServers

public List<com.netflix.loadbalancer.Server> getReachableServers()

Specified by:

getReachableServers in interface com.netflix.loadbalancer.ILoadBalancer

getAllServers

public List<com.netflix.loadbalancer.Server> getAllServers()

Specified by:

getAllServers in interface com.netflix.loadbalancer.ILoadBalancer

createLoadBalancer

protected com.netflix.loadbalancer.ILoadBalancer createLoadBalancer(com.netflix.client.config.IClientConfig clientConfig,
                                                                    com.netflix.loadbalancer.IRule rule,
                                                                    com.netflix.loadbalancer.IPing ping,
                                                                    com.netflix.loadbalancer.ServerListFilter serverListFilter,
                                                                    com.netflix.loadbalancer.ServerList<com.netflix.loadbalancer.Server> serverList)

Creates the ILoadBalancer to use. Defaults to ZoneAwareLoadBalancer. Subclasses can override to provide custom behaviour

Parameters:

clientConfig - The client config

rule - The IRule

ping - THe IPing

serverListFilter - The ServerListFilter

serverList - The ServerList

Returns:

The ILoadBalancer instance. Never null