org.apache.ambari.server.controller.internal

Class AbstractProviderModule

java.lang.Object

org.apache.ambari.server.controller.internal.AbstractProviderModule

All Implemented Interfaces:

GangliaHostProvider, ResourceProviderObserver, JMXHostProvider, ProviderModule

Direct Known Subclasses:

DefaultProviderModule, GSInstallerProviderModule

public abstract class AbstractProviderModule
extends Object
implements ProviderModule, ResourceProviderObserver, JMXHostProvider, GangliaHostProvider

An abstract provider module implementation.

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
AbstractProviderModule() Create a default provider module.

Method Summary

Modifier and Type	Method and Description
protected void	createPropertyProviders(Resource.Type type)
protected abstract ResourceProvider	createResourceProvider(Resource.Type type)
String	getGangliaCollectorHostName(String clusterName) Get the Ganglia server host name for the given cluster name.
String	getHostName(String clusterName, String componentName) Get the JMX host name for the given cluster name and component name.
String	getJMXProtocol(String clusterName, String componentName) Get the protocol for the specified cluster name and component.
String	getPort(String clusterName, String componentName) Get the port for the specified cluster name and component.
List<PropertyProvider>	getPropertyProviders(Resource.Type type) Get the list of property providers for the given resource type.
ResourceProvider	getResourceProvider(Resource.Type type) Get a resource adapter for the given resource type.
boolean	isGangliaCollectorComponentLive(String clusterName) Get the status of Ganglia server component for the given cluster name.
boolean	isGangliaCollectorHostLive(String clusterName) Get the status of Ganglia server host for the given cluster name.
protected void	putPropertyProviders(Resource.Type type, List<PropertyProvider> providers)
protected void	putResourceProvider(Resource.Type type, ResourceProvider resourceProvider)
protected void	registerResourceProvider(Resource.Type type)
void	update(ResourceProviderEvent event) Update this observer with an event from a resource provider.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

AbstractProviderModule

public AbstractProviderModule()

Create a default provider module.

Method Detail

getResourceProvider

public ResourceProvider getResourceProvider(Resource.Type type)

Description copied from interface: ProviderModule

Get a resource adapter for the given resource type.

Specified by:

getResourceProvider in interface ProviderModule

Parameters:

type - the resource type

Returns:

the resource adapter

getPropertyProviders

public List<PropertyProvider> getPropertyProviders(Resource.Type type)

Description copied from interface: ProviderModule

Get the list of property providers for the given resource type.

Specified by:

getPropertyProviders in interface ProviderModule

Parameters:

type - the resource type

Returns:

the list of property providers

update

public void update(ResourceProviderEvent event)

Description copied from interface: ResourceProviderObserver

Update this observer with an event from a resource provider.

Specified by:

update in interface ResourceProviderObserver

Parameters:

event - the event

getHostName

public String getHostName(String clusterName,
                          String componentName)
                   throws SystemException

Description copied from interface: JMXHostProvider

Get the JMX host name for the given cluster name and component name.

Specified by:

getHostName in interface JMXHostProvider

Parameters:

clusterName - the cluster name

componentName - the component name

Returns:

the JMX host name

Throws:

SystemException - if unable to get the JMX host name

getPort

public String getPort(String clusterName,
                      String componentName)
               throws SystemException

Description copied from interface: JMXHostProvider

Get the port for the specified cluster name and component.

Specified by:

getPort in interface JMXHostProvider

Parameters:

clusterName - the cluster name

componentName - the component name

Returns:

the port for the specified cluster name and component

Throws:

SystemException - if unable to get the JMX port

getGangliaCollectorHostName

public String getGangliaCollectorHostName(String clusterName)
                                   throws SystemException

Description copied from interface: GangliaHostProvider

Get the Ganglia server host name for the given cluster name.

Specified by:

getGangliaCollectorHostName in interface GangliaHostProvider

Parameters:

clusterName - the cluster name

Returns:

the Ganglia server

Throws:

SystemException - if unable to get the Ganglia server host name

isGangliaCollectorHostLive

public boolean isGangliaCollectorHostLive(String clusterName)
                                   throws SystemException

Description copied from interface: GangliaHostProvider

Get the status of Ganglia server host for the given cluster name.

Specified by:

isGangliaCollectorHostLive in interface GangliaHostProvider

Parameters:

clusterName - the cluster name

Returns:

true if heartbeat with Ganglia server host wasn't lost

Throws:

SystemException - if unable to get the status of Ganglia server host

isGangliaCollectorComponentLive

public boolean isGangliaCollectorComponentLive(String clusterName)
                                        throws SystemException

Description copied from interface: GangliaHostProvider

Get the status of Ganglia server component for the given cluster name.

Specified by:

isGangliaCollectorComponentLive in interface GangliaHostProvider

Parameters:

clusterName - the cluster name

Returns:

true if Ganglia server component is started

Throws:

SystemException - if unable to get the status of Ganglia server component

createResourceProvider

protected abstract ResourceProvider createResourceProvider(Resource.Type type)

registerResourceProvider

protected void registerResourceProvider(Resource.Type type)

putResourceProvider

protected void putResourceProvider(Resource.Type type,
                                   ResourceProvider resourceProvider)

putPropertyProviders

protected void putPropertyProviders(Resource.Type type,
                                    List<PropertyProvider> providers)

createPropertyProviders

protected void createPropertyProviders(Resource.Type type)

getJMXProtocol

public String getJMXProtocol(String clusterName,
                             String componentName)

Description copied from interface: JMXHostProvider

Get the protocol for the specified cluster name and component.

Specified by:

getJMXProtocol in interface JMXHostProvider

Parameters:

clusterName - the cluster name

componentName - the component name

Returns:

the JMX protocol for the specified cluster name and component, one of http or https