|
OpenNMS API 1.1.3 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.opennms.netmgt.collectd.Collectd
Field Summary | |
private static java.lang.String |
LOG4J_CATEGORY
Log4j category |
private java.util.List |
m_collectableServices
List of all CollectableService objects. |
private BroadcastEventProcessor |
m_receiver
Reference to the event processor |
private Scheduler |
m_scheduler
Reference to the collection scheduler |
private static java.util.Map |
m_serviceIds
Holds map of service names to service identifiers |
private static Collectd |
m_singleton
Singleton instance of the Collectd class |
private int |
m_status
Status of the Collectd instance. |
private static java.util.Map |
m_svcCollectors
Map of all available ServiceCollector objects indexed by service name |
private static java.lang.String |
SQL_RETRIEVE_INTERFACES
SQL used to retrieve all the interfaces which support a particular service. |
private static java.lang.String |
SQL_RETRIEVE_SERVICE_IDS
SQL used to retrieve all the service id's and names from the database. |
Fields inherited from interface org.opennms.core.fiber.PausableFiber |
PAUSE_PENDING, PAUSED, RESUME_PENDING |
Fields inherited from interface org.opennms.core.fiber.Fiber |
RUNNING, START_PENDING, STARTING, STATUS_NAMES, STOP_PENDING, STOPPED |
Constructor Summary | |
private |
Collectd()
Constructor. |
Method Summary | |
private boolean |
alreadyScheduled(java.lang.String ipAddress,
java.lang.String pkgName)
Returns true if specified address/pkg pair is already represented in the collectable services list. |
static Collectd |
getInstance()
Returns singleton instance of the collection daemon. |
java.lang.String |
getName()
Return sthe name of the collection daemon. |
Scheduler |
getScheduler()
Returns reference to the scheduler |
ServiceCollector |
getServiceCollector(java.lang.String svcName)
Returns the loaded ServiceCollector for the specified service name. |
int |
getStatus()
Returns current status of the collection daemon. |
void |
init()
Responsible for starting the collection daemon. |
void |
pause()
Responsible for pausing the collection daemon. |
void |
resume()
Responsible for resuming the collection daemon. |
private void |
scheduleExistingInterfaces()
Schedule existing interfaces for data collection. |
(package private) void |
scheduleInterface(int nodeId,
java.lang.String ipAddress,
java.lang.String svcName,
boolean existing)
This method is responsible for scheduling the specified node/address/svcname tuple for data collection. |
void |
start()
Responsible for starting the collection daemon. |
void |
stop()
Responsible for stopping the collection daemon. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
private static final java.lang.String LOG4J_CATEGORY
private static final java.lang.String SQL_RETRIEVE_INTERFACES
private static final java.lang.String SQL_RETRIEVE_SERVICE_IDS
private static final Collectd m_singleton
private static final java.util.Map m_serviceIds
private java.util.List m_collectableServices
private Scheduler m_scheduler
private int m_status
private BroadcastEventProcessor m_receiver
private static java.util.Map m_svcCollectors
Constructor Detail |
private Collectd()
Method Detail |
public void init()
public void start()
start
in interface Fiber
public void stop()
stop
in interface Fiber
public void pause()
pause
in interface PausableFiber
public void resume()
resume
in interface PausableFiber
public int getStatus()
getStatus
in interface Fiber
Fiber
.public java.lang.String getName()
getName
in interface Fiber
Fiber
.public static Collectd getInstance()
public Scheduler getScheduler()
public ServiceCollector getServiceCollector(java.lang.String svcName)
svcName
- Service name to lookup.
private void scheduleExistingInterfaces() throws java.sql.SQLException
java.sql.SQLException
- if database errors encountered.void scheduleInterface(int nodeId, java.lang.String ipAddress, java.lang.String svcName, boolean existing)
nodeId
- Node idipAddress
- IP addresssvcName
- Service nameexisting
- True if called by scheduleExistingInterfaces(), false otheriwseprivate boolean alreadyScheduled(java.lang.String ipAddress, java.lang.String pkgName)
|
OpenNMS API 1.1.3 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |