|
OpenNMS API 1.2.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 boolean |
m_schedulingCompleted
Indicates if scheduling of existing interfaces has been completed |
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. |
private ReadyRunnable |
buildSchedule(org.apache.log4j.Category log)
|
private void |
buildServiceIdMap(org.apache.log4j.Category log)
|
private void |
createEventProcessor(org.apache.log4j.Category log)
|
private void |
createScheduler(org.apache.log4j.Category log,
CollectdConfiguration config)
|
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. |
private void |
instantiateCollectors(org.apache.log4j.Category log,
CollectdConfiguration config)
|
boolean |
isSchedulingCompleted()
|
private void |
loadConfigFactory(org.apache.log4j.Category log)
|
private void |
loadscheduledOutagesConfigFactory(org.apache.log4j.Category log)
|
void |
pause()
Responsible for pausing the collection daemon. |
void |
refreshServicePackages()
|
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 |
setSchedulingCompleted(boolean schedulingCompleted)
|
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
private boolean m_schedulingCompleted
Constructor Detail |
private Collectd()
Method Detail |
public void init()
private void createEventProcessor(org.apache.log4j.Category log)
private ReadyRunnable buildSchedule(org.apache.log4j.Category log)
private void createScheduler(org.apache.log4j.Category log, CollectdConfiguration config)
private void buildServiceIdMap(org.apache.log4j.Category log)
private void instantiateCollectors(org.apache.log4j.Category log, CollectdConfiguration config)
private void loadscheduledOutagesConfigFactory(org.apache.log4j.Category log)
private void loadConfigFactory(org.apache.log4j.Category log)
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)
public boolean isSchedulingCompleted()
public void setSchedulingCompleted(boolean schedulingCompleted)
schedulingCompleted
- The schedulingCompleted to set.public void refreshServicePackages()
|
OpenNMS API 1.2.3 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |