io.micronaut.http.client

Class DefaultLoadBalancerResolver

java.lang.Object

io.micronaut.http.client.DefaultLoadBalancerResolver

All Implemented Interfaces:

LoadBalancerResolver

@Singleton
public class DefaultLoadBalancerResolver
extends Object
implements LoadBalancerResolver

Abstraction over LoadBalancer lookup. The strategy is as follows:

• If a reference starts with '/' then we attempt to look up the EmbeddedServer
• If the reference contains a '/' assume it is a URL and try to create a URL reference to it
• Otherwise delegate to the DiscoveryClient to attempt to resolve the URIs

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor and Description
DefaultLoadBalancerResolver(BeanContext beanContext, List<ServiceInstanceList> serviceInstanceLists) The default server loadbalance resolver.
DefaultLoadBalancerResolver(BeanContext beanContext, ServiceInstanceList... serviceInstanceLists) The default server loadbalance resolver.

Method Summary

Modifier and Type	Method and Description
Optional<? extends LoadBalancer>	resolve(String... serviceReferences) Resolve a LoadBalancer for the given references.
protected Optional<? extends LoadBalancer>	resolveLoadBalancerForServiceID(String serviceID)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultLoadBalancerResolver

public DefaultLoadBalancerResolver(BeanContext beanContext,
                                   ServiceInstanceList... serviceInstanceLists)

The default server loadbalance resolver.

Parameters:

beanContext - The bean context

serviceInstanceLists - Any other providers

DefaultLoadBalancerResolver

@Inject
public DefaultLoadBalancerResolver(BeanContext beanContext,
                                           List<ServiceInstanceList> serviceInstanceLists)

The default server loadbalance resolver.

Parameters:

beanContext - The bean context

serviceInstanceLists - Any other providers

Method Detail

resolve

public Optional<? extends LoadBalancer> resolve(String... serviceReferences)

Description copied from interface: LoadBalancerResolver

Resolve a LoadBalancer for the given references.

Specified by:

resolve in interface LoadBalancerResolver

Parameters:

serviceReferences - The references. These could be service IDs or fully HTTP URLs

Returns:

A LoadBalancer or empty of non can be resolved

resolveLoadBalancerForServiceID

protected Optional<? extends LoadBalancer> resolveLoadBalancerForServiceID(String serviceID)

Parameters:

serviceID - The service Id

Returns:

An Optional with the load balancer