public interface IApplication
IApplication
interface lets you access a given topology resources.String getShortName()
EClusterType getType() throws ConfigurationException
ConfigurationException
String getCluster() throws ConfigurationException
ConfigurationException
ISettingsMap getSettingsMap()
IEntity getEntity()
ITenant getTenant()
String getReloadAction()
boolean isStormApplication() throws ConfigurationException
ConfigurationException
- is the application has a wrong runtime or type settingsboolean isSparkStreamingApplication() throws ConfigurationException
ConfigurationException
- is the application has a wrong runtime or type settingsboolean isShivaApplication() throws ConfigurationException
ConfigurationException
- is the application has a wrong runtime or type settingsboolean isOneShot()
String getFullName() throws ConfigurationException
Watchout this method requires a valid cluster to be configured in your application. A checked exception is thrown if you refer to one not known from your platform properties.
ConfigurationException
String getTenantName()
List<String> getShivaTags()
List<String> getApplyResolverOn()
String getShivaCommand()
List<String> getShivaArgs()
List<String> getShivaResources()
String getShivaCronSchedule()
ISettingsMap getExitSettingsOrDefault(ISettingsMap defaultExitCondition) throws ConfigurationException
In channel structure it is not allowed, the applications are either periodic or ever running, but have never their exit managed by the platform.
exit:
{
type: default
condition: {
failure:
{
acks_greater_or_equal_to: 0
inactive_for_more_than: 5s
}
success:
{
fails_greater_or_equal_to: 0
}
}
defaultExitCondition
- the ones to return if none is foundConfigurationException
- if a channel express one, or if it is invalidString getVersion()
IApplication setExitRequest(IExitRequest request)
request
- the requested wish to exitIExitRequest getExitRequest()
ISettingsMap getEnv()
IApplication setEnv(String name, String value)
name
- value
- String getUUID()
IApplication setApplicationUUID(String string)
string
- void audit() throws ConfigurationException
ConfigurationException
Copyright © 2014–2022. All rights reserved.