org.springframework.cloud.dataflow.registry

Class AppRegistry

java.lang.Object

org.springframework.cloud.dataflow.registry.AbstractAppRegistryCommon

org.springframework.cloud.dataflow.registry.AppRegistry

All Implemented Interfaces:

AppRegistryCommon

public class AppRegistry
extends AbstractAppRegistryCommon
implements AppRegistryCommon

Convenience wrapper for the UriRegistry that operates on higher level AppRegistration objects and supports on-demand loading of Resources.

Stores AppRegistration with up to two keys:

• <type>.<name>: URI for the actual app
• <type>.<name>.metadata: Optional URI for the app metadata

Author:

Mark Fisher, Gunnar Hillert, Thomas Risberg, Eric Bottard, Ilayaperumal Gopinathan, Oleg Zhurakousky, Christian Tzolov

Field Summary

Fields inherited from class org.springframework.cloud.dataflow.registry.AbstractAppRegistryCommon

mavenProperties, METADATA_KEY_SUFFIX, resourceLoader, toStringAndUriFunc

Constructor Summary

Constructors

Constructor and Description
AppRegistry(org.springframework.cloud.deployer.resource.registry.UriRegistry uriRegistry, org.springframework.core.io.ResourceLoader resourceLoader)
AppRegistry(org.springframework.cloud.deployer.resource.registry.UriRegistry uriRegistry, org.springframework.core.io.ResourceLoader resourceLoader, org.springframework.cloud.deployer.resource.maven.MavenProperties mavenProperties)

Method Summary

Modifier and Type	Method and Description
boolean	appExist(String name, ApplicationType type) Checks if an application with such name and type exists and is set as default.
void	delete(String name, ApplicationType type) Deletes an AppRegistration.
AppRegistration	find(String name, ApplicationType type)
List<AppRegistration>	findAll()
org.springframework.data.domain.Page<AppRegistration>	findAll(org.springframework.data.domain.Pageable pageable)
protected boolean	isOverwrite(AppRegistration app, boolean overwrite)
AppRegistration	save(AppRegistration app) Save an AppRegistration instance.
AppRegistration	save(String name, ApplicationType type, URI uri, URI metadataUri)
Stream<AppRegistration>	toValidAppRegistration(Map.Entry<String,URI> kv, URI metadataURI) Builds a Stream from key/value mapping.

Methods inherited from class org.springframework.cloud.dataflow.registry.AbstractAppRegistryCommon

getAppMetadataResource, getAppResource, importAll, loadProperties, metadataUriFromProperties, warnOnMalformedURI

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

find, getAppMetadataResource, getAppResource, importAll

Constructor Detail

AppRegistry

public AppRegistry(org.springframework.cloud.deployer.resource.registry.UriRegistry uriRegistry,
                   org.springframework.core.io.ResourceLoader resourceLoader)

AppRegistry

public AppRegistry(org.springframework.cloud.deployer.resource.registry.UriRegistry uriRegistry,
                   org.springframework.core.io.ResourceLoader resourceLoader,
                   org.springframework.cloud.deployer.resource.maven.MavenProperties mavenProperties)

Method Detail

find

public AppRegistration find(String name,
                            ApplicationType type)

Specified by:

find in interface AppRegistryCommon

Parameters:

name - application name

type - application typ

Returns:

the application with those name and type and default version

findAll

public List<AppRegistration> findAll()

Specified by:

findAll in interface AppRegistryCommon

Returns:

returns all AppRegistration's including multiple version for the same application.

findAll

public org.springframework.data.domain.Page<AppRegistration> findAll(org.springframework.data.domain.Pageable pageable)

save

public AppRegistration save(String name,
                            ApplicationType type,
                            URI uri,
                            URI metadataUri)

toValidAppRegistration

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

Description copied from class: AbstractAppRegistryCommon

Builds a Stream from key/value mapping.

Overrides:

toValidAppRegistration in class AbstractAppRegistryCommon

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.

isOverwrite

protected boolean isOverwrite(AppRegistration app,
                              boolean overwrite)

Specified by:

isOverwrite in class AbstractAppRegistryCommon

save

public AppRegistration save(AppRegistration app)

Description copied from interface: AppRegistryCommon

Save an AppRegistration instance.

Specified by:

save in interface AppRegistryCommon

Parameters:

app - appRegistration to save

Returns:

the saved appRegistration

delete

public void delete(String name,
                   ApplicationType type)

Deletes an AppRegistration. If the AppRegistration does not exist, a NoSuchAppRegistrationException will be thrown.

Parameters:

name - Name of the AppRegistration to delete

type - Type of the AppRegistration to delete

appExist

public boolean appExist(String name,
                        ApplicationType type)

Description copied from interface: AppRegistryCommon

Checks if an application with such name and type exists and is set as default.

Specified by:

appExist in interface AppRegistryCommon

Parameters:

name - applicaiton name

type - applicaiton type

Returns:

true if a default application with this name and type exists.