org.springframework.cloud.dataflow.registry

Class AbstractAppRegistryCommon

java.lang.Object

org.springframework.cloud.dataflow.registry.AbstractAppRegistryCommon

All Implemented Interfaces:

AppRegistryCommon

Direct Known Subclasses:

AppRegistry, DefaultAppRegistryService

public abstract class AbstractAppRegistryCommon
extends Object
implements AppRegistryCommon

AppRegistryCommon implementation common for the Classic and the Skipper modes.

Author:

Christian Tzolov, Ilayaperumal Gopinathan, Soby Chacko

Field Summary

Fields

Modifier and Type	Field and Description
protected org.springframework.cloud.deployer.resource.maven.MavenProperties	mavenProperties
static String	METADATA_KEY_SUFFIX
protected org.springframework.core.io.ResourceLoader	resourceLoader
protected static Function<Map.Entry<Object,Object>,AbstractMap.SimpleImmutableEntry<String,URI>>	toStringAndUriFunc

Constructor Summary

Constructors

Constructor and Description
AbstractAppRegistryCommon(org.springframework.core.io.ResourceLoader resourceLoader)
AbstractAppRegistryCommon(org.springframework.core.io.ResourceLoader resourceLoader, org.springframework.cloud.deployer.resource.maven.MavenProperties mavenProperties)

Method Summary

Modifier and Type	Method and Description
org.springframework.core.io.Resource	getAppMetadataResource(AppRegistration appRegistration) Converts application's metadata URI into Spring resource object.
org.springframework.core.io.Resource	getAppResource(AppRegistration appRegistration) Converts application's URI into Spring resource object.
List<AppRegistration>	importAll(boolean overwrite, org.springframework.core.io.Resource... resources) Import bulk of applications from input load files
protected abstract boolean	isOverwrite(AppRegistration app, boolean overwrite)
protected Properties	loadProperties(org.springframework.core.io.Resource resource)
protected URI	metadataUriFromProperties(String key, Properties properties)
protected Stream<AppRegistration>	toValidAppRegistration(Map.Entry<String,URI> kv, URI metadataURI) Builds a Stream from key/value mapping.
protected URI	warnOnMalformedURI(String key, URI uri)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.cloud.dataflow.registry.AppRegistryCommon

appExist, find, find, findAll, save

Field Detail

METADATA_KEY_SUFFIX

public static final String METADATA_KEY_SUFFIX

See Also:

Constant Field Values

resourceLoader

protected org.springframework.core.io.ResourceLoader resourceLoader

mavenProperties

protected org.springframework.cloud.deployer.resource.maven.MavenProperties mavenProperties

toStringAndUriFunc

protected static final Function<Map.Entry<Object,Object>,AbstractMap.SimpleImmutableEntry<String,URI>> toStringAndUriFunc

Constructor Detail

AbstractAppRegistryCommon

public AbstractAppRegistryCommon(org.springframework.core.io.ResourceLoader resourceLoader)

AbstractAppRegistryCommon

public AbstractAppRegistryCommon(org.springframework.core.io.ResourceLoader resourceLoader,
                                 org.springframework.cloud.deployer.resource.maven.MavenProperties mavenProperties)

Method Detail

getAppResource

public org.springframework.core.io.Resource getAppResource(AppRegistration appRegistration)

Description copied from interface: AppRegistryCommon

Converts application's URI into Spring resource object. Supports File:, Http:, Maven: and Docker: schemas

Specified by:

getAppResource in interface AppRegistryCommon

Returns:

Returns Resource instance that corresponds to application's URI

getAppMetadataResource

public org.springframework.core.io.Resource getAppMetadataResource(AppRegistration appRegistration)

Description copied from interface: AppRegistryCommon

Converts application's metadata URI into Spring resource object. Supports File:, Http:, Maven: and Docker: schemas

Specified by:

getAppMetadataResource in interface AppRegistryCommon

Returns:

Returns Resource instance that corresponds to application's metdata URI

loadProperties

protected Properties loadProperties(org.springframework.core.io.Resource resource)

importAll

public List<AppRegistration> importAll(boolean overwrite,
                                       org.springframework.core.io.Resource... resources)

Description copied from interface: AppRegistryCommon

Import bulk of applications from input load files

Specified by:

importAll in interface AppRegistryCommon

Parameters:

overwrite - if set to true this command will override and existing application with same name:type:version If set to false operation will throw an exception in the application already exists.

resources - list of input load files

Returns:

list of application being imported

isOverwrite

protected abstract boolean isOverwrite(AppRegistration app,
                                       boolean overwrite)

toValidAppRegistration

protected Stream<AppRegistration> toValidAppRegistration(Map.Entry<String,URI> kv,
                                                         URI metadataURI)

Builds a Stream from key/value mapping.

Parameters:

kv - key/value representing app key (key) and app URI (value)

metadataURI - metadataUri computed from a given app key

Returns:

• valid AppRegistration as single element Stream
• silently ignores well malformed metadata entries (0 element Stream) or
• fails otherwise.

metadataUriFromProperties

protected URI metadataUriFromProperties(String key,
                                        Properties properties)

warnOnMalformedURI

protected URI warnOnMalformedURI(String key,
                                 URI uri)