Package org.opennms.netmgt.rrd
Class MultiOutputRrdStrategy
- java.lang.Object
-
- org.opennms.netmgt.rrd.MultiOutputRrdStrategy
-
- All Implemented Interfaces:
RrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
public class MultiOutputRrdStrategy extends java.lang.Object implements RrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
MultiOutputRrdStrategy class.
- Version:
- $Id: $
- Author:
- ranger
-
-
Constructor Summary
Constructors Constructor Description MultiOutputRrdStrategy()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
closeFile(java.util.List<java.lang.Object> rrd)
closeFilejava.util.List<java.lang.Object>
createDefinition(java.lang.String creator, java.lang.String directory, java.lang.String rrdName, int step, java.util.List<RrdDataSource> dataSources, java.util.List<java.lang.String> rraList)
Create a round robin database definition from the supplied parameters.void
createFile(java.util.List<java.lang.Object> rrdDef)
Creates the round robin database defined by the supplied definition.java.io.InputStream
createGraph(java.lang.String command, java.io.File workDir)
Creates an InputStream representing the bytes of a graph created from round robin data.RrdGraphDetails
createGraphReturnDetails(java.lang.String command, java.io.File workDir)
Creates an RrdGraphDetails object representing the graph created from round robin data.java.lang.Double
fetchLastValue(java.lang.String rrdFile, java.lang.String ds, int interval)
Fetches the last value from the round robin database with the given name.java.lang.Double
fetchLastValue(java.lang.String rrdFile, java.lang.String ds, java.lang.String consolidationFunction, int interval)
Fetches the last value from the round robin database with the given name.java.lang.Double
fetchLastValueInRange(java.lang.String rrdFile, java.lang.String ds, int interval, int range)
Fetches the last value from the round robin database with the given name within a time range.java.lang.String
getDefaultFileExtension()
getDefaultFileExtensionjava.util.List<RrdStrategy<java.lang.Object,java.lang.Object>>
getDelegates()
getDelegatesint
getFetchStrategyIndex()
getFetchStrategyIndexint
getGraphLeftOffset()
getGraphLeftOffsetint
getGraphRightOffset()
getGraphRightOffsetint
getGraphStrategyIndex()
getGraphStrategyIndexint
getGraphTopOffsetWithText()
getGraphTopOffsetWithTextjava.lang.String
getStats()
getStatsjava.util.List<java.lang.Object>
openFile(java.lang.String fileName)
Opens the round robin database with the supplied name.void
promoteEnqueuedFiles(java.util.Collection<java.lang.String> rrdFiles)
In the event that this is a queuing implementation of the RrdStrategy.void
setConfigurationProperties(java.util.Properties configurationParameters)
setConfigurationPropertiesvoid
setDelegates(java.util.List<RrdStrategy<java.lang.Object,java.lang.Object>> delegates)
setDelegatesvoid
setFetchStrategyIndex(int fetchStrategyIndex)
setFetchStrategyIndexvoid
setGraphStrategyIndex(int graphStrategyIndex)
setGraphStrategyIndexvoid
updateFile(java.util.List<java.lang.Object> rrd, java.lang.String owner, java.lang.String data)
Updates the supplied round robin database with the given timestamp:value point
-
-
-
Method Detail
-
setConfigurationProperties
public void setConfigurationProperties(java.util.Properties configurationParameters)
setConfigurationProperties
- Specified by:
setConfigurationProperties
in interfaceRrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
- Parameters:
configurationParameters
- aProperties
object.
-
getDelegates
public java.util.List<RrdStrategy<java.lang.Object,java.lang.Object>> getDelegates()
getDelegates
- Returns:
- a
List
object.
-
setDelegates
public void setDelegates(java.util.List<RrdStrategy<java.lang.Object,java.lang.Object>> delegates)
setDelegates
- Parameters:
delegates
- aList
object.
-
getGraphStrategyIndex
public int getGraphStrategyIndex()
getGraphStrategyIndex
- Returns:
- a int.
-
setGraphStrategyIndex
public void setGraphStrategyIndex(int graphStrategyIndex)
setGraphStrategyIndex
- Parameters:
graphStrategyIndex
- a int.
-
getFetchStrategyIndex
public int getFetchStrategyIndex()
getFetchStrategyIndex
- Returns:
- a int.
-
setFetchStrategyIndex
public void setFetchStrategyIndex(int fetchStrategyIndex)
setFetchStrategyIndex
- Parameters:
fetchStrategyIndex
- a int.
-
closeFile
public void closeFile(java.util.List<java.lang.Object> rrd) throws java.lang.Exception
closeFile
- Specified by:
closeFile
in interfaceRrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
- Parameters:
rrd
- aList
object.- Throws:
java.lang.Exception
- if any.
-
createDefinition
public java.util.List<java.lang.Object> createDefinition(java.lang.String creator, java.lang.String directory, java.lang.String rrdName, int step, java.util.List<RrdDataSource> dataSources, java.util.List<java.lang.String> rraList) throws java.lang.Exception
Create a round robin database definition from the supplied parameters. This definition is used in the createFile call to create the actual file.- Specified by:
createDefinition
in interfaceRrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
- Parameters:
creator
- - A string representing who is creating this file for use in log msgsdirectory
- - The directory to create the file inrrdName
- - The name to use for the round robin databasestep
- - the step for the databasedataSources
- - the data sources to use for round robin databaserraList
- - a List of the round robin archives to create in the database. defines after which time the data is condensed to a defined lower step- Returns:
- an object representing the definition of an round robin database. Can be null if the database exists already.
- Throws:
java.lang.Exception
- If an error occurs while creating the definition
-
createFile
public void createFile(java.util.List<java.lang.Object> rrdDef) throws java.lang.Exception
Creates the round robin database defined by the supplied definition. Should be able to handle rrdDef being null.- Specified by:
createFile
in interfaceRrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
- Parameters:
rrdDef
- an round robin database definition created using the createDefinition call.- Throws:
java.lang.Exception
- if an error occurs create the file
-
createGraph
public java.io.InputStream createGraph(java.lang.String command, java.io.File workDir) throws java.io.IOException, RrdException
Creates an InputStream representing the bytes of a graph created from round robin data. It accepts an rrdtool graph command. The underlying implementation converts this command to a format appropriate for it .- Specified by:
createGraph
in interfaceRrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
- Parameters:
command
- the command needed to create the graphworkDir
- the directory that all referenced files are relative to- Returns:
- an input stream representing the bytes of a graph image as a PNG file
- Throws:
java.io.IOException
- if an IOError occursRrdException
- if an RRD error occurs
-
createGraphReturnDetails
public RrdGraphDetails createGraphReturnDetails(java.lang.String command, java.io.File workDir) throws java.io.IOException, RrdException
Creates an RrdGraphDetails object representing the graph created from round robin data. It accepts an rrdtool graph command. The underlying implementation converts this command to a format appropriate for it .- Specified by:
createGraphReturnDetails
in interfaceRrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
- Parameters:
command
- the command needed to create the graphworkDir
- the directory that all referenced files are relative to- Returns:
- details for the graph including an InputStream, any PRINTed lines, and graph dimensions.
- Throws:
java.io.IOException
- if an IOError occursRrdException
- if an RRD error occurs
-
fetchLastValue
public java.lang.Double fetchLastValue(java.lang.String rrdFile, java.lang.String ds, int interval) throws java.lang.NumberFormatException, RrdException
Fetches the last value from the round robin database with the given name. The interval passed in should be the interval associated with the round robin database.- Specified by:
fetchLastValue
in interfaceRrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
- Parameters:
rrdFile
- a name the represents a round robin databaseds
- a name the represents a data source to be usedinterval
- a step interval of the round robin database- Returns:
- The last value as a Double (if the last value didn't exist returns a Double.NaN)
- Throws:
java.lang.NumberFormatException
- if any.RrdException
- if any.
-
fetchLastValue
public java.lang.Double fetchLastValue(java.lang.String rrdFile, java.lang.String ds, java.lang.String consolidationFunction, int interval) throws java.lang.NumberFormatException, RrdException
Fetches the last value from the round robin database with the given name. The interval passed in should be the interval associated with the round robin database.- Specified by:
fetchLastValue
in interfaceRrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
- Parameters:
rrdFile
- a name the represents a round robin databaseds
- a name the represents a data source to be usedconsolidationFunction
- aString
object.interval
- a step interval of the round robin database- Returns:
- The last value as a Double (if the last value didn't exist returns a Double.NaN)
- Throws:
java.lang.NumberFormatException
- if any.RrdException
- if any.
-
fetchLastValueInRange
public java.lang.Double fetchLastValueInRange(java.lang.String rrdFile, java.lang.String ds, int interval, int range) throws java.lang.NumberFormatException, RrdException
Fetches the last value from the round robin database with the given name within a time range. The interval passed in should be the interval associated with the round robin database. The range should be the amount of "lag" acceptable for an update to be considered valid. Range must be a multiple of the RRD interval.- Specified by:
fetchLastValueInRange
in interfaceRrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
- Parameters:
rrdFile
- a name the represents a round robin databaseds
- a name the represents a data source to be usedinterval
- a step interval of the round robin databaserange
- an acceptable range for which the last value will be returned- Returns:
- The last value as a Double (if the last value didn't exist returns a Double.NaN)
- Throws:
java.lang.NumberFormatException
- if any.RrdException
- if any.
-
getDefaultFileExtension
public java.lang.String getDefaultFileExtension()
getDefaultFileExtension
- Specified by:
getDefaultFileExtension
in interfaceRrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
- Returns:
- a
String
object.
-
getGraphLeftOffset
public int getGraphLeftOffset()
getGraphLeftOffset
- Specified by:
getGraphLeftOffset
in interfaceRrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
- Returns:
- a int.
-
getGraphRightOffset
public int getGraphRightOffset()
getGraphRightOffset
- Specified by:
getGraphRightOffset
in interfaceRrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
- Returns:
- a int.
-
getGraphTopOffsetWithText
public int getGraphTopOffsetWithText()
getGraphTopOffsetWithText
- Specified by:
getGraphTopOffsetWithText
in interfaceRrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
- Returns:
- a int.
-
getStats
public java.lang.String getStats()
getStats
- Specified by:
getStats
in interfaceRrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
- Returns:
- a
String
object.
-
openFile
public java.util.List<java.lang.Object> openFile(java.lang.String fileName) throws java.lang.Exception
Opens the round robin database with the supplied name. It is assumed the name refers to a round robin database appropriate for this strategy implementation- Specified by:
openFile
in interfaceRrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
- Parameters:
fileName
- the name of the associated rrd file- Returns:
- an open rrd reference that can by used in calls to updateFile and closeFile
- Throws:
java.lang.Exception
- if an error occurs opening the file
-
promoteEnqueuedFiles
public void promoteEnqueuedFiles(java.util.Collection<java.lang.String> rrdFiles)
In the event that this is a queuing implementation of the RrdStrategy. This method causes all queued but not yet written data to be to the rrd files as soon as possible.- Specified by:
promoteEnqueuedFiles
in interfaceRrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
- Parameters:
rrdFiles
- aCollection
object.
-
updateFile
public void updateFile(java.util.List<java.lang.Object> rrd, java.lang.String owner, java.lang.String data) throws java.lang.Exception
Updates the supplied round robin database with the given timestamp:value point- Specified by:
updateFile
in interfaceRrdStrategy<java.util.List<java.lang.Object>,java.util.List<java.lang.Object>>
- Parameters:
rrd
- an rrd object created using openFileowner
- the owner of the rrddata
- a string of the form: - Throws:
java.lang.Exception
- if an error occurs updating the file
-
-