com.bigdata.journal

Class GangliaPlugIn

java.lang.Object

com.bigdata.journal.GangliaPlugIn

All Implemented Interfaces:

IPlugIn<Journal,GangliaService>

public class GangliaPlugIn
extends Object
implements IPlugIn<Journal,GangliaService>

A plugin for ganglia.

Note: This plugin will not start (and will not be loaded from the classpath) unless PlatformStatsPlugIn.Options.COLLECT_PLATFORM_STATISTICS is set to true.

Author:

Bryan Thompson

See Also:

Ganglia Integration, bigdata-ganglia is required dependency for Journal

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	GangliaPlugIn.Options Configuration options.

Constructor Summary

Constructors

Constructor and Description
GangliaPlugIn()

Method Summary

Methods

Modifier and Type	Method and Description
GangliaService	getService() Return the service.
boolean	isRunning() Return true iff the service is running.
void	startService(Journal journal) Start the service.
void	stopService(boolean immediateShutdown) Stop the service.

Methods inherited from class java.lang.Object

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

Constructor Detail

GangliaPlugIn

public GangliaPlugIn()

Method Detail

startService

public void startService(Journal journal)

Start the service.

Start embedded Ganglia peer. It will develop a snapshot of the metrics in memory for all nodes reporting in the ganglia network and will self-report metrics from the performance counter hierarchy to the ganglia network.

Specified by:

startService in interface IPlugIn<Journal,GangliaService>

stopService

public void stopService(boolean immediateShutdown)

Stop the service.

Note: The embedded GangliaService is executed on the main thread pool. We need to terminate the GangliaService in order for the thread pool to shutdown.

Specified by:

stopService in interface IPlugIn<Journal,GangliaService>

Parameters:

immediateShutdown - true if the service should be stopped immediately.

isRunning

public boolean isRunning()

Description copied from interface: IPlugIn

Return true iff the service is running.

Specified by:

isRunning in interface IPlugIn<Journal,GangliaService>

getService

public GangliaService getService()

Description copied from interface: IPlugIn

Return the service.

Specified by:

getService in interface IPlugIn<Journal,GangliaService>