Package com.predic8.membrane.core.resolver

Class ResolverMap

java.lang.Object

com.predic8.membrane.core.resolver.ResolverMap

All Implemented Interfaces:

Resolver, Cloneable

public class ResolverMap
extends Object
implements Cloneable, Resolver

A ResolverMap consists of a list of SchemaResolvers.

It is itself a Resolver: Requests to resolve a URL are delegated to the corresponding SchemaResolver child depending on the URL's schema.

Note that this class is not thread-safe! The ResolverMap is setup during Membrane's single-threaded startup and is only used read-only thereafter.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	ResolverMap.ExternalResolverConverter

Constructor Summary

Constructors

Constructor	Description
ResolverMap()
ResolverMap(TimerManager timerManager, HttpClientFactory httpClientFactory, KubernetesClientFactory kubernetesClientFactory)

Method Summary

Modifier and Type	Method	Description
void	addRuleResolver(Router r)
void	addSchemaResolver(SchemaResolver sr)
ResolverMap	clone()
static String	combine(String... locations)	First param is the parent.
List<String>	getChildren(String uri)	Returns the list of child resources of the resource identified by the URL.
EtcdResolver	getEtcdResolver()
SchemaResolver	getFileSchemaResolver()
HTTPSchemaResolver	getHTTPSchemaResolver()
KubernetesSchemaResolver	getKubernetesSchemaResolver()
long	getTimestamp(String uri)	Returns the modification date of the resource.
void	observeChange(String uri, ExceptionThrowingConsumer<InputStream> consumer)	Calls the consumer when the InputStream for the requested URL changes.
InputStream	resolve(String uri)	Returns the InputStream for the requested URL.
void	setEtcdResolver(EtcdResolver etcdResolver)
ResolverMap.ExternalResolverConverter	toExternalResolver()
LSResourceResolver	toLSResourceResolver()

Methods inherited from class java.lang.Object

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

Constructor Details

ResolverMap

public ResolverMap()

ResolverMap

public ResolverMap(TimerManager timerManager,
 HttpClientFactory httpClientFactory,
 KubernetesClientFactory kubernetesClientFactory)

Method Details

combine

public static String combine(String... locations)

First param is the parent. The following params will be combined to one path e.g. "/foo/bar", "baz/x.yaml" ", "soo" => "/foo/bar/baz/soo"

Parameters:

locations - List of relative paths

Returns:

combined path

clone

public ResolverMap clone()

Overrides:

clone in class Object

addSchemaResolver

public void addSchemaResolver(SchemaResolver sr)

addRuleResolver

public void addRuleResolver(Router r)

getTimestamp

public long getTimestamp(String uri)
                  throws FileNotFoundException

Description copied from interface: Resolver

Returns the modification date of the resource.

Specified by:

getTimestamp in interface Resolver

Returns:

0 if the resolver does not support this functionality.

Throws:

FileNotFoundException - if the resource identified by the URL does not exist.

resolve

public InputStream resolve(String uri)
                    throws ResourceRetrievalException

Description copied from interface: Resolver

Returns the InputStream for the requested URL.

Specified by:

resolve in interface Resolver

Throws:

ResourceRetrievalException - if the resource identified by the URL does not exist.

observeChange

public void observeChange(String uri,
 ExceptionThrowingConsumer<InputStream> consumer)
                   throws ResourceRetrievalException

Description copied from interface: Resolver

Calls the consumer when the InputStream for the requested URL changes.

Specified by:

observeChange in interface Resolver

Throws:

ResourceRetrievalException - if the resource identified by the URL does not exist.

getChildren

public List<String> getChildren(String uri)
                         throws FileNotFoundException

Description copied from interface: Resolver

Returns the list of child resources of the resource identified by the URL.

For example, a list of filenames in the directory identified by the URL.

Specified by:

getChildren in interface Resolver

Returns:

null if the resolver does not support this functionality.

Throws:

FileNotFoundException - if the resource identified by the URL does not exist.

getHTTPSchemaResolver

public HTTPSchemaResolver getHTTPSchemaResolver()

getFileSchemaResolver

public SchemaResolver getFileSchemaResolver()

toLSResourceResolver

public LSResourceResolver toLSResourceResolver()

toExternalResolver

public ResolverMap.ExternalResolverConverter toExternalResolver()

getEtcdResolver

public EtcdResolver getEtcdResolver()

setEtcdResolver

public void setEtcdResolver(EtcdResolver etcdResolver)

getKubernetesSchemaResolver

public KubernetesSchemaResolver getKubernetesSchemaResolver()