Package org.jrobin.core

Class Datasource

java.lang.Object

org.jrobin.core.Datasource

All Implemented Interfaces:

DsTypes, RrdUpdater

public class Datasource
extends Object
implements RrdUpdater, DsTypes

Class to represent single datasource within RRD. Each datasource object holds the following information: datasource definition (once set, never changed) and datasource state variables (changed whenever RRD gets updated).

Normally, you don't need to manipluate Datasource objects directly, it's up to JRobin framework to do it for you.

Author:

Sasa Markovic

Field Summary

Fields inherited from interface org.jrobin.core.DsTypes

DT_ABSOLUTE, DT_COUNTER, DT_DERIVE, DT_GAUGE

Constructor Summary

Constructors

Constructor	Description
Datasource(RrdDb parentDb, DataImporter reader, int dsIndex)
Datasource(RrdDb parentDb, DsDef dsDef)

Method Summary

Modifier and Type	Method	Description
(package private) void	appendXml(XmlWriter writer)
void	copyStateTo(RrdUpdater other)	Copies object's internal state to another Datasource object.
(package private) String	dump()
double	getAccumValue()	Returns value this datasource accumulated so far.
int	getDsIndex()	Returns index of this Datasource object in the RRD.
String	getDsName()	Returns datasource name.
String	getDsType()	Returns datasource type (GAUGE, COUNTER, DERIVE, ABSOLUTE).
long	getHeartbeat()	Returns datasource heartbeat
double	getLastValue()	Returns last known value of the datasource.
double	getMaxValue()	Returns maximal allowed value for this datasource.
double	getMinValue()	Returns mimimal allowed value for this datasource.
long	getNanSeconds()	Returns the number of accumulated NaN seconds.
RrdAllocator	getRrdAllocator()	Required to implement RrdUpdater interface.
RrdBackend	getRrdBackend()	Returns the underlying storage (backend) object which actually performs all I/O operations.
(package private) void	process(long newTime, double newValue)
void	setDsName(String newDsName)	Sets datasource name to a new value
void	setDsType(String newDsType)
void	setHeartbeat(long heartbeat)	Sets datasource heartbeat to a new value.
void	setMaxValue(double maxValue, boolean filterArchivedValues)	Sets maximum allowed value for this datasource.
void	setMinMaxValue(double minValue, double maxValue, boolean filterArchivedValues)	Sets min/max values allowed for this datasource.
void	setMinValue(double minValue, boolean filterArchivedValues)	Sets minimum allowed value for this datasource.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

Datasource

Datasource(RrdDb parentDb,
           DsDef dsDef)
    throws IOException

Throws:

IOException

Datasource

Datasource(RrdDb parentDb,
           DataImporter reader,
           int dsIndex)
    throws IOException,
           RrdException

Throws:

IOException

RrdException

Method Detail

dump

String dump()
     throws IOException

Throws:

IOException

getDsName

public String getDsName()
                 throws IOException

Returns datasource name.

Returns:

Datasource name

Throws:

IOException - Thrown in case of I/O error

getDsType

public String getDsType()
                 throws IOException

Returns datasource type (GAUGE, COUNTER, DERIVE, ABSOLUTE).

Returns:

Datasource type.

Throws:

IOException - Thrown in case of I/O error

getHeartbeat

public long getHeartbeat()
                  throws IOException

Returns datasource heartbeat

Returns:

Datasource heartbeat

Throws:

IOException - Thrown in case of I/O error

getMinValue

public double getMinValue()
                   throws IOException

Returns mimimal allowed value for this datasource.

Returns:

Minimal value allowed.

Throws:

IOException - Thrown in case of I/O error

getMaxValue

public double getMaxValue()
                   throws IOException

Returns maximal allowed value for this datasource.

Returns:

Maximal value allowed.

Throws:

IOException - Thrown in case of I/O error

getLastValue

public double getLastValue()
                    throws IOException

Returns last known value of the datasource.

Returns:

Last datasource value.

Throws:

IOException - Thrown in case of I/O error

getAccumValue

public double getAccumValue()
                     throws IOException

Returns value this datasource accumulated so far.

Returns:

Accumulated datasource value.

Throws:

IOException - Thrown in case of I/O error

getNanSeconds

public long getNanSeconds()
                   throws IOException

Returns the number of accumulated NaN seconds.

Returns:

Accumulated NaN seconds.

Throws:

IOException - Thrown in case of I/O error

process

void process(long newTime,
             double newValue)
      throws IOException,
             RrdException

Throws:

IOException

RrdException

appendXml

void appendXml(XmlWriter writer)
        throws IOException

Throws:

IOException

copyStateTo

public void copyStateTo(RrdUpdater other)
                 throws IOException,
                        RrdException

Copies object's internal state to another Datasource object.

Specified by:

copyStateTo in interface RrdUpdater

Parameters:

other - New Datasource object to copy state to

Throws:

IOException - Thrown in case of I/O error

RrdException - Thrown if supplied argument is not a Datasource object

getDsIndex

public int getDsIndex()
               throws IOException

Returns index of this Datasource object in the RRD.

Returns:

Datasource index in the RRD.

Throws:

IOException - Thrown in case of I/O error

setHeartbeat

public void setHeartbeat(long heartbeat)
                  throws RrdException,
                         IOException

Sets datasource heartbeat to a new value.

Parameters:

heartbeat - New heartbeat value

Throws:

IOException - Thrown in case of I/O error

RrdException - Thrown if invalid (non-positive) heartbeat value is specified.

setDsName

public void setDsName(String newDsName)
               throws RrdException,
                      IOException

Sets datasource name to a new value

Parameters:

newDsName - New datasource name

Throws:

RrdException - Thrown if invalid data source name is specified (name too long, or name already defined in the RRD

IOException - Thrown in case of I/O error

setDsType

public void setDsType(String newDsType)
               throws RrdException,
                      IOException

Throws:

RrdException

IOException

setMinValue

public void setMinValue(double minValue,
                        boolean filterArchivedValues)
                 throws IOException,
                        RrdException

Sets minimum allowed value for this datasource. If filterArchivedValues argment is set to true, all archived values less then minValue will be fixed to NaN.

Parameters:

minValue - New minimal value. Specify Double.NaN if no minimal value should be set

filterArchivedValues - true, if archived datasource values should be fixed; false, otherwise.

Throws:

IOException - Thrown in case of I/O error

RrdException - Thrown if invalid minValue was supplied (not less then maxValue)

setMaxValue

public void setMaxValue(double maxValue,
                        boolean filterArchivedValues)
                 throws IOException,
                        RrdException

Sets maximum allowed value for this datasource. If filterArchivedValues argment is set to true, all archived values greater then maxValue will be fixed to NaN.

Parameters:

maxValue - New maximal value. Specify Double.NaN if no max value should be set.

filterArchivedValues - true, if archived datasource values should be fixed; false, otherwise.

Throws:

IOException - Thrown in case of I/O error

RrdException - Thrown if invalid maxValue was supplied (not greater then minValue)

setMinMaxValue

public void setMinMaxValue(double minValue,
                           double maxValue,
                           boolean filterArchivedValues)
                    throws IOException,
                           RrdException

Sets min/max values allowed for this datasource. If filterArchivedValues argment is set to true, all archived values less then minValue or greater then maxValue will be fixed to NaN.

Parameters:

minValue - New minimal value. Specify Double.NaN if no min value should be set.

maxValue - New maximal value. Specify Double.NaN if no max value should be set.

filterArchivedValues - true, if archived datasource values should be fixed; false, otherwise.

Throws:

IOException - Thrown in case of I/O error

RrdException - Thrown if invalid min/max values were supplied

getRrdBackend

public RrdBackend getRrdBackend()

Returns the underlying storage (backend) object which actually performs all I/O operations.

Specified by:

getRrdBackend in interface RrdUpdater

Returns:

I/O backend object

getRrdAllocator

public RrdAllocator getRrdAllocator()

Required to implement RrdUpdater interface. You should never call this method directly.

Specified by:

getRrdAllocator in interface RrdUpdater

Returns:

Allocator object

toString

public String toString()

Overrides:

toString in class Object