AbortArchiveRequest |
Abort any pending requests for archiving this PV.
|
AbortArchiveRequestForAppliance |
Abort any pending requests for archiving this PV in this appliance.
|
AddAliasAction |
|
AddExternalArchiverServer |
Add a external Archiver Data Server into the system.
|
AddExternalArchiverServerArchives |
Add Channel Archiver archives.
|
AfterAllStreams |
If the post processor needs to send some data after all the streams have been processed, this is the hook.
|
AggregatedApplianceInfo |
Gets the optimized aggregate typeInfo information for this appliance.
|
AlarmInfo |
Get the status and severity of this event.
|
AlreadyRegisteredException |
Thrown if a PV is already registered to another appliance
|
AppendAndAliasPV |
Appends the data for an older PV into a newer PV.
|
AppendDataStateData |
Companion class to PlainPBStoragePlugin that handles the appending of event streams in a partition-aware fashion.
|
ApplianceAggregateInfo |
POJO facilitating various optimizations for BPL that uses appliance wide information.
|
ApplianceAndTotalRate |
|
ApplianceInfo |
Information specific to an appliance
|
ApplianceMetrics |
Summary appliance metrics for the engine.
|
ApplianceMetrics |
Gets the ETL appliance metrics
|
ApplianceMetrics |
Summary metrics for an appliance.
|
ApplianceMetrics |
Summary metrics for retrieval for an alliance.
|
ApplianceMetricsDetails |
Detailed appliance metrics for the engine.
|
ApplianceMetricsDetails |
Get the metrics details for an appliance for ETL.
|
ApplianceMetricsDetails |
Detailed metrics for an appliance
|
ApplianceMetricsDetails |
Detail metrics for retrieval for an alliance.
|
AppliancesList |
Parses the appliances.xml file and loads the appliances
|
ArchDBRTypes |
The various DBR types supported by the EPICS appliance archiver.
|
ArchiveChannel |
Base for archived channels.
|
ArchiveChannelObjectDetailsAction |
Use this to debug any connectivity issues in the engine.
|
ArchivedPVsAction |
Given a list of PVs, determine those that are being archived.
|
ArchivedPVsForThisApplianceAction |
Given a list of PVs, determine those that are being archived.
|
ArchivedPVsNotInListAction |
Given a list of PVs, determine those that are being archived but are not in the incoming list.
|
ArchiveEngine |
This class provides the static methods:
create channel
get pv meta data before archiving this pv
pause archiving pv
resume archiving pv
get metics of one pv
change the archival parameter of one pv
destory pv
|
ArchivePVAction |
BPL for archiving a PV.
|
ArchivePVState |
State for the archive PV workflow
|
ArchivePVState.ArchivePVStateMachine |
|
ArchiverConfigException |
Use this to throw configuration related exceptions.
|
ArchiverValuesHandler |
|
ArchiverValuesHandler.ArchiverValuesType |
|
ArchivesHandler |
SAX2 for handling archiver.archives.
|
ArchiveWriter |
Interface for writing samples to an archive
|
ArchiveWriterFactory |
|
ArchPaths |
This is a replacement for NIO Paths that caters to our syntax rules.
|
ArchServletContextListener |
This is a ServletContextListener expected to be registered in web.xml that serves as the source of dependency injection.
|
AreWeArchivingPV |
Send a true/false if we are archiving the given PV or not.
|
ArrayListCollectorEventStream |
An event stream that wraps an ArrayList event stream; use this if the data in your consolidated results do not fit a clean binning pattern and you need to return results that span multiple years.
|
ArrayListEventStream |
Implements an event stream on top of an arraylist
|
Average |
Running (exponential) average
|
BasicContext |
All the main units of work in the appliance that deal with plugins pass in a context that can be used to hold state that pertains to the unit of work.
|
BasicDispatcher |
Glue code that is in all the BPL servlets.
|
BlackholeStoragePlugin |
A storage plugin that deletes all data that goes into it.
|
BPLAction |
A very simple struts like action for business processes.
|
BPLServlet |
The main business logic servlet for the engine.
|
BPLServlet |
The main business logic servlet for ETL.
|
BPLServlet |
The main business logic servlet for mgmt.
|
BPLServlet |
The main business logic servlet for retrieval.
|
BulkPauseResumeUtils |
Some utility methods for bulk pause and resume...
|
ByteArray |
A version of byte[] that is used to provide some optimization for data retrieval and the like.
|
ByteBufSampleValue |
A sample value that encapsulates a byte buffer.
|
CallableEventStream |
Encapsulates an event stream into a callable.
|
CapacityPlanningBPL |
Primary capacity planning logic for the default capacity planning as outlined in the doc.
|
CapacityPlanningData |
Data from various appliances that is used for capacity planning.
|
CapacityPlanningData.CPStaticData |
|
CAPlotBinning |
Approx implementation of ChannelArchiver plotbinning for Michael Davidsaver
From the doc
If there is no sample for the time span of a bin, the bin remains empty.
If there is one sample, it is placed in the bin.
If there are two samples, they are placed in the bin
If there are more than two samples, the first and last one are placed in the bin.
|
ChangeArchivalParamsAction |
|
ChangeArchivalParamsAction |
Change the archival parameters for a PV.
|
ChangeInYearsException |
External integrations may not have the same contract as PB the plugin re year partitions.
|
ChangePVName |
Change the name of the PV in the PB file.
|
ChangeTypeForPV |
|
ChannelArchiverDataServerInfo |
POJO that contains Channel Archiver Data Server information.
|
ChannelArchiverDataServerPVInfo |
As part of archiver.names, the ChannelArchiver XMLRPC server also returns the first and last timestamp.
|
ChannelArchiverListView |
Get a list of all Channel Archivers that we know about.
|
ChannelArchiverReadOnlyPlugin |
A storage plugin that can front a Channel Archiver Data Server.
|
CleanUpAnyImmortalChannels |
This is a reasonably dangerous call.
|
CompareEventLine |
This is a special kind of comparison function meant for a combo binary/linear search function.
|
CompareEventLine.NextStep |
|
ComparePBEvent |
A comparator for PB events that is used in searching.
|
CompareWithChannelArchiver |
Compares a specified period with data obtained from the channel archiver
|
ConfigException |
|
ConfigPersistence |
Interface for persisting configuration
These are the pieces of configuration - all of these are key/value; keys are strings, values are typically JSON strings or plain strings.
|
ConfigService |
Interface for appliance configuration.
|
ConfigService.STARTUP_SEQUENCE |
|
ConfigService.WAR_FILE |
|
ConfigServiceForTests |
|
ConnectedPVCountForAppliance |
Return connected/disconnected/paused PV counts as a JSON object.
|
ConsolidatePBFilesForOnePV |
consolidate PB files for one pv before one storage
|
ConsolidatePBFilesForOnePV |
|
ContextErrorHandler |
Handler for JCA Context errors and messages; places them in log.
|
ControllingPV |
PV's that can control the archiving of other PV's will need to implement this interface.
|
ConversionException |
|
ConversionFunction |
A conversion function takes in a EventStream and gives you another EventStream that is based on this EventStream.
|
ConvertPVNameToKey |
Most labs use a standard character (typically the ":" or the "-" character) in their naming conventions to separate out the components of a name.
|
Count |
Counts the number of items in an interval.
|
CountEventsInPBFile |
Utility for counting the number of events in a PV file.
|
CreationTimeReportForAppliance |
Creation time and paused status of all PVs in this appliance
|
CSVEvent |
|
CSVEventStream |
An event stream backed by a CSV file.
|
CurrentlyDisconnectedPVs |
|
CurrentlyDisconnectedPVsAction |
|
CurrentThreadExecutorService |
An ExecutorService that runs everything on the current thread.
|
CurrentThreadWorkerEventStream |
Expands the results from a Reader using the current thread.
|
DataRetrieval |
Similar to the reader interface, this is the main retrieval interface.
|
DataRetrievalServlet |
Main servlet for retrieval of data.
|
DataSourceforPV |
Represents a data source for data for a PV
|
DataSourceResolution |
|
DBR_Helper |
Helper for dealing with DBR..
|
DBR2PBTypeMapping |
Maps ArchDBRTypes to PB classes.
|
DBRTimeEvent |
A catch all interface that contains the attributes in a EPICS DBR_TIME_XXX from db_access.h.
|
DeadBand |
The intent is to mimic ADEL; this is principally targeted at decimation
Like ADEL, it applies only to scalar numbers.
|
DefaultConfigService |
This is the default config service for the archiver appliance.
|
DefaultRawPostProcessor |
This is the "default" post processor that does nothing to the underlying event stream.
|
DeletePV |
|
DeletePV |
consolidate PB files for one pv before one storage
|
DeletePV |
|
DeltaArchiveChannel |
An ArchiveChannel that stores each incoming value that differs from the
previous sample by some 'delta'.
|
DroppedEventsBufferOverflowReport |
|
DroppedEventsBufferOverflowReport |
A report based on the number of events dropped based on buffer overflows.
|
DroppedEventsTimestampReport |
|
DroppedEventsTimestampReport |
A report based on the number of events dropped based on incorrect timestamps from the IOC.
|
DroppedEventsTypeChangeReport |
|
DroppedEventsTypeChangeReport |
A report based on the number of events dropped based on changes in PV type.
|
EmptyEventIterator |
An empty event interator.
|
EmptyEventStream |
Instead of returning null, in some cases, it may be more convenient to return a EventStream with no events
|
Enablement |
Describes how a channel acts on a group.
|
EngineChannelStatus |
POJO for engine status for a PV
|
EngineConfigParser |
Ability to import a ChannelArchiver engine config file.
|
EngineContext |
the context for the Archiver Engine
|
EngineMetrics |
POJO with some basic metrics.
|
EPICS_V3_PV |
EPICS ChannelAccess implementation of the PV interface.
|
EPICS_V3_PV.MonitorMask |
Sourced from org/csstudio/platform/libs/epics/EpicsPlugin.java
|
EPICS_V4_PV |
|
EPICS2PBTypeMapping |
Separate out the JCA/EPICS v4 => PB mapping into a separate class so that clients (read ArchiveViewer) do not have to include the entire JCA/EPICS v4 jars.
|
EPICSEvent |
|
EPICSEvent.FieldValue |
|
EPICSEvent.FieldValue.Builder |
|
EPICSEvent.FieldValueOrBuilder |
|
EPICSEvent.PayloadInfo |
|
EPICSEvent.PayloadInfo.Builder |
|
EPICSEvent.PayloadInfoOrBuilder |
|
EPICSEvent.PayloadType |
|
EPICSEvent.ScalarByte |
|
EPICSEvent.ScalarByte.Builder |
|
EPICSEvent.ScalarByteOrBuilder |
|
EPICSEvent.ScalarDouble |
|
EPICSEvent.ScalarDouble.Builder |
|
EPICSEvent.ScalarDoubleOrBuilder |
|
EPICSEvent.ScalarEnum |
|
EPICSEvent.ScalarEnum.Builder |
|
EPICSEvent.ScalarEnumOrBuilder |
|
EPICSEvent.ScalarFloat |
|
EPICSEvent.ScalarFloat.Builder |
|
EPICSEvent.ScalarFloatOrBuilder |
|
EPICSEvent.ScalarInt |
|
EPICSEvent.ScalarInt.Builder |
|
EPICSEvent.ScalarIntOrBuilder |
|
EPICSEvent.ScalarShort |
|
EPICSEvent.ScalarShort.Builder |
|
EPICSEvent.ScalarShortOrBuilder |
|
EPICSEvent.ScalarString |
|
EPICSEvent.ScalarString.Builder |
|
EPICSEvent.ScalarStringOrBuilder |
|
EPICSEvent.V4GenericBytes |
|
EPICSEvent.V4GenericBytes.Builder |
|
EPICSEvent.V4GenericBytesOrBuilder |
|
EPICSEvent.VectorChar |
|
EPICSEvent.VectorChar.Builder |
|
EPICSEvent.VectorCharOrBuilder |
|
EPICSEvent.VectorDouble |
|
EPICSEvent.VectorDouble.Builder |
|
EPICSEvent.VectorDoubleOrBuilder |
|
EPICSEvent.VectorEnum |
|
EPICSEvent.VectorEnum.Builder |
|
EPICSEvent.VectorEnumOrBuilder |
|
EPICSEvent.VectorFloat |
|
EPICSEvent.VectorFloat.Builder |
|
EPICSEvent.VectorFloatOrBuilder |
|
EPICSEvent.VectorInt |
|
EPICSEvent.VectorInt.Builder |
|
EPICSEvent.VectorIntOrBuilder |
|
EPICSEvent.VectorShort |
|
EPICSEvent.VectorShort.Builder |
|
EPICSEvent.VectorShortOrBuilder |
|
EPICSEvent.VectorString |
|
EPICSEvent.VectorString.Builder |
|
EPICSEvent.VectorStringOrBuilder |
|
ErrorBars |
Similar to the mean operator; in additon, the stdz is passed in as an extra column
|
ETLBulkStream |
Event streams can optionally implement bulk transfer friendly methods.
|
ETLContext |
A class to hold state for one run of ETL.
|
ETLDest |
An ETL dest is data source that can act as a sink for ETL.
|
ETLExecutor |
Run ETLs for one PV; mostly for unit tests..
|
ETLInfo |
A POJO that encapsulates all the information needed about a stream from an ETL source
|
ETLJob |
We schedule a ETLPVLookupItems with the appropriate thread using an ETLJob
|
ETLMetricsForLifetime |
ETL metrics for the appliance as a whole for one lifetime
|
ETLPVLookupItems |
A POJO for PV name, ETLSource, and ETLDest items,
which can be used as elements in a list (e.g.,
implementations of the ETLPVLookup interface,
such as PBThreeTierETLPVLookup).
|
ETLSource |
An ETL source is data source that can act as a source for ETL.
|
ETLStreamCreator |
We can potentially get a large number of ETLInfo objects when performing ETL for the first time.
|
Event |
An event represents an archiver sample.
|
EventConsumer |
|
EventRateReport |
Report for PVs by event rate.
|
EventRateReport |
Event rate report.
|
EventStream |
An event stream is a sequence of events in temporal order.
|
EventStreamConsumer |
|
EventStreamDesc |
An event stream should also support this additional information about the stream.
|
ExceptionCommunicator |
Comminucate exceptions as part of the mime response.
|
ExecutePolicy |
Given the information computed by the engine about the PV, compute the archiving policy using policies.py
Information to the policies.py is passed in as a dictionary with these keys
dbrtype -- The ArchDBRType of the PV
eventRate -- The sampled event rate in events per second.
eventCount -- The total number of events.
storageRate -- The sampled storage in bytes per seconds.
aliasName -- The value of the .NAME field for aliases
policyName -- If the user has overridden the policy when requesting archiving, this is the name of the policy
All the extra fields are use the fieldName as the key (for example, ADEL comes in as .ADEL).
|
ExportConfig |
Export the archiving configuration (PVTypeInfo's) as a JSON file.
|
ExportConfigForThisInstance |
Export the archiving configuration (PVTypeInfo's) for this instance as a JSON file.
|
ExportCSV |
This is the reverse of ImportCSV.
|
ExtraFieldsPostProcessor |
A post processor that looks for fields
|
FieldValues |
EPICS PVs have additional fields like HIHI, LOLO etc that occasionally change.
|
FileBackedPBEventStream |
An EventStream that is backed by a single PB file.
|
FileBackedPBEventStreamIterator |
|
FileBackedPBEventStreamPositionBasedIterator |
An iterator for a FileBackedPBEventStream.
|
FileBackedPBEventStreamTimeBasedIterator |
An iterator for a FileBackedPBEventStream.
|
FileEventStreamSearch |
This is a variant of binary search that searches for an event in a event stream file.
|
FileStreamCreator |
A stream creator that is backed by a single file.
|
FillNoFillSupport |
Add ability for PostProcessors to support optional behavior where we fill empty bins with values from the previous bins.
|
FillsCollectorEventStream |
This is similar to the summary stats collector except we keep aspects of the original event stream like dbr_type and so on.
|
FilterArchivedPVs |
Given a list of PV's in the POST, filter these to those that are being archived in this cluster.
|
FirstFill |
Similar to the firstSample operator with the exception that we alter the timestamp to the middle of the bin and copy over the previous bin's value if a bin does not have any samples.
|
FirstSamplePP |
This takes "interval" argument and returns only the first sample in that interval...
|
Fliers |
This is a copy of ignore fliers with the comparision sign reversed.
|
FlxXMLResponse |
Test response of action script+XML with large data sets
For now this is only for one PV.
|
GenericMultiApplianceReport |
Generic reporting class to call all the appliances with a particular URL and then return the results.
|
GenericPVMetricsReport<T extends Number> |
We collect many metrics during archiving in the PVMetrics objects.
|
GetAllAliasesAction |
|
GetAllExpandedPVNames |
|
GetAllPVs |
|
GetApplianceInfo |
|
GetApplianceProps |
Get various appliance properties as name/value constructs mostly for the UI.
|
GetAppliancesInCluster |
|
GetClientConfiguration |
Get a client configuration JSON file given the file name.
|
GetDataAtTime |
|
GetDataAtTimeEngine |
PV for getting the data for multiple PV's from the engine's buffers at a particular time.
|
GetEngineDataAction |
PV for getting the data for a PV from the engine's buffers
|
GetLastKnownEventTimeStamp |
|
GetLatestMetaDataAction |
Get the latest metadata from the various sources within the engine..
|
GetMatchingPVs |
Get matching PV's for this appliance.
|
GetMatchingPVsForAppliance |
|
GetPausedPVsForThisAppliance |
Get a list of PVs for this appliance that are paused as a JSON array
|
GetPolicyList |
|
GetPolicyText |
Returns the text of the policies for this installation as a text file...
|
GetPVMetaData |
Gets information about the PV from PVTypeInfo, the engine and other places
Gets information about the PV from PVTypeInfo, the engine and other places
pv - The name of the pv.
|
GetPVsForThisAppliance |
Get a list of PVs for this appliance as a JSON array
|
GetPVStatusAction |
Get the status of a PV.
|
GetPVTypeInfo |
Gets the type info for a PV as a JSON object
|
GetPVTypeInfoKeys |
|
GetStoresForPV |
Gets the names of the data stores for this PV.
|
GetUrlContent |
Small utility for getting the contents of an URL as various things
|
GetVersion |
Get the version from the version.txt file.
|
GetVersions |
|
HashMapEvent |
We get a HashMap of NVPairs from the Channel Archiver - this class exposes these as an archiver Event
We typically get secs=1250696265, value=70.9337, sevr=0, nano=267115322, stat=0
|
IgnoreFliers |
Ignores data that is more than the specified amount of std deviation from the mean.
|
ImportChannelArchiverConfigAction |
Use this to import a Channel Archiver configuration file using HTTP POST.
|
ImportConfig |
Import configuration from an exported file
Send the exported file as the body of the POST.
|
ImportConfigForAppliance |
Import configuration from an exported file for this appliance...
|
ImportCSV |
Simple import of a CSV file into storage plugin.
|
ImportDataFromPlugin |
Import data using another plugin given the plugin definition URL for a PV and store in the specified store.
|
InfoHandler |
SAX2 for handling archiver.info
|
InMemoryPersistence |
Dummy in memory persistence layer for unit tests
|
InputStreamBackedEventStream |
An EventStream that is backed by an arbitrary input stream.
|
InputStreamBackedEventStreamIterator |
The iterator for the InputStreamBackedEventStream
|
InstanceReport |
|
InstanceReportDetails |
|
InstanceReportDetails |
|
InstanceReportDetails |
|
InstanceReportDetails |
|
JCA2ArchDBRType |
|
JCACommandThread |
JCA command pump, added for two reasons:
JCA callbacks can't directly send JCA commands without danger of a
deadlock, at least not with JNI and the "DirectRequestDispatcher".
|
JCAConfigGen |
Read the system environment and generate a JCA config stream
As of today, this seems to be a more visible way to configure JCA for this project than hidden files or other schemes
We'll see how this stands the test of time.
|
JCAEventDispatcherBasedOnPVName |
Attempt to distribute the load of serializing the event across multiple threads
All events that have a Channel as the source are sent to a thread based on the hash of the pv name.
|
JDBM2Persistence |
Uses JDBM2 as a persistence layer; probably not for production installations as JDBM2 does not support concurrent access and so on.
|
Jitter |
Implements SummaryStatistics.getStandardDeviation()/SummaryStatistics.getMean()
|
JNITargetArch |
|
JPlotResponse |
|
JSONDecoder<T> |
Generate something that marshalls JSON into a POJO using bean introspection.
|
JSONEncoder<T> |
Generate something that converts a POJO into JSON using bean introspection.
|
JSONResponse |
|
Kurtosis |
Implements the kurtosis over a bin.
|
LastFill |
Similar to the firstFill operator with the exception that we use the last sample in the bin.
|
LastKnownTimeStampReport |
Get the last known timestamp for all PV's.
|
LastSample |
Similar to the firstSample operator with the exception that we use the last sample in the bin.\
|
LinearInterpolation |
Implements the arithmetic mean across an interval
|
LineByteStream |
This class wraps a RandomAccessFile and returns byte arrays separated by lines.
|
LineByteStreamCreator |
When using a MultiFileEventStream on a HOUR granularity, we could potentially run into "too many open files" issues.
|
LineEscaper |
Simple class to escape/unescape newlines in binary data.
|
LineTooLongException |
An exception thrown by the LineByteStream when we encounter lines that are too long.
|
ListAllChannels |
Lists all the channels that are currently active
|
LoessInterpolation |
Implements the arithmetic mean across an interval
|
LogLevel |
|
LostConnectionsReport |
|
LostConnectionsReport |
|
MatlabResponse |
Generate a ".mat" matlab file
The response contains two objects, a header and a data object.
|
Max |
Implements the max item in an interval
|
Mean |
Implements the arithmetic mean across an interval
|
Median |
Implements the median over a bin.
|
MergeDedupEventStream |
EventStream that is constructed with two source EventStream's ( for the same PV ) and then return's a merged-deduped stream of Events.
|
MergeDedupStoragePlugin |
The MergeDedupStoragePlugin is primarily meant for achieving a small amount of failover in the archiving of a PV.
|
MergeDedupWithCallablesEventStream |
This is almost idential to the MergeDedupEventStream; expect it takes as its first argument a list of EventStream callables
which it then merges with the second EventStream
|
MergeInDataFromExternalStore |
|
MetaCompletedListener |
Callback once we determine various attributes of the PV.
|
MetaGet |
this class is used to create channel for pv and compute the meta info for one pv.
|
MetaGetsAction |
Details for the PV's that are currently in METAINFO_REQUESTED requested state in the archive workflow.
|
MetaGetsForThisApplianceAction |
Reports for PVs that never connected.
|
MetaInfo |
this class is used for getting the meta data
|
MgmtPostStartup |
Make sure all the other web apps have started and if so, send them their post startup messages...
|
MgmtRuntimeState |
Runtime state for the mgmt app.
|
MgmtUIFilter |
Make sure that the webapp has completely started up before we allow any UI actions..
|
MimeResponse |
A set of events for classes that convert event streams to mime specific responses.
|
MimeTypeConstants |
Constants for mime types
|
Min |
Implements the min item in an interval
|
MismatchedDBRTypeException |
Thrown when we have a mismatch in what config tells us and what a stream tells us.
|
ModifyMetaFieldsAction |
|
ModifyStoreURLForPV |
Modifies the specified store for this PV using the new definition.
|
MonitoredArchiveChannel |
An ArchiveChannel that stores each incoming value.
|
MultiFilePBEventStream |
An eventstream that spans multiple PB files.
|
MultiFilePBEventStreamIterator |
The iterator for MultiFilePBEventStream's
All we do is go thru the streams in sequence and then return the events one after the other.
|
MySQLPersistence |
Persistence layer ontop of MySQL TEXT(blobs) on InnoDB
Bear in mind, an untuned mysql server does poorly in terms of performance.
|
NamedFlagsGet |
|
NamedFlagsSet |
|
NamesHandler |
SAX2 for handling archiver.names
|
NamesHandler.ChannelDescription |
|
NCount |
NCount is a post processor which returns number of samples in
a selected time span.
|
NeverConnectedPVsAction |
Report for PVs never connected.
|
NeverConnectedPVsForThisAppliance |
|
NoDataException |
Thrown when a reader has no data for a particular time frame and particular PV.
|
NonMgmtPostStartup |
This pings the mgmt web app to let it know that we have started up.
|
NormalizationFactor |
|
Nth |
Nth is a post processor which returns every n-th value.
|
NTUtil |
A helper class to easily extract value from nt structures
|
Optimized |
Optimized expects one parameter at initialization, which is the number of requested points.
|
OptimizedWithLastSample |
OptimizedWithLastSample expects one parameter at initialization, which is the number of requested points.
|
OutOfSpaceHandling |
How should ETL deal with running out of space in the dest?
Should we delete the source streams? This would mean that we would lose data.
|
PartionedTime |
All the PB classes also implement this version of timeinfo.
|
PartitionGranularity |
A small enum for defining the granularity of the partition.
|
PauseArchivingPV |
|
PauseArchivingPV |
Remove the ETL jobs for this PV.
|
PauseArchivingPV |
|
PausedPVsReport |
Generate a report of PVs that are currently paused.
|
PausePVsOnShutdown |
Pause all PVs; this does not update PVTypeinfo.
|
PB2JSON |
|
PBFileInfo |
Gets some information about PB files.
|
PBOverHTTPStoragePlugin |
A read-only storage plugin that gets data using the PB/http protocol from a server.
|
PBParseException |
We convert PB exceptions into a runtime exception to minimize the number of IOExceptions in the method declarations.
|
PBRAWResponse |
Mimeresponse for PB over HTTP.
|
PBScalarByte |
A DBRTimeEvent for a scalar byte.
|
PBScalarDouble |
* A DBRTimeEvent for a scalar double.
|
PBScalarEnum |
A DBRTimeEvent for a scalar enum.
|
PBScalarFloat |
A DBRTimeEvent for a scalar float.
|
PBScalarInt |
A DBRTimeEvent for a scalar int.
|
PBScalarShort |
A DBRTimeEvent for a scalar short.
|
PBScalarString |
A DBRTimeEvent for a scalar string.
|
PBThreeTierETLPVLookup |
Holds runtime state for ETL.
|
PBTypeSystem |
TypeSystem for SLAC PB types.
|
PBV4GenericBytes |
A DBRTimeEvent that wraps a V4 struct.
|
PBVectorByte |
A DBRTimeEvent for a vector byte.
|
PBVectorDouble |
A DBRTimeEvent for a vector double.
|
PBVectorEnum |
A DBRTimeEvent for a vector enum.
|
PBVectorFloat |
A DBRTimeEvent for a vector float.
|
PBVectorInt |
A DBRTimeEvent for a vector int.
|
PBVectorShort |
A DBRTimeEvent for a vector short.
|
PBVectorString |
A DBRTimeEvent for a vector string.
|
PeriodFormat |
Parser for scan or update periods
|
PingServlet |
Implements a ping for the archive viewer.
|
PlainPBPathNameUtility |
A utility class with a bunch of methods that operate on the path names used by the PlainPB storage plugin.
|
PlainPBStoragePlugin |
The plain PB storage plugin stores data in a chunk per PV per partition in sequential form.
|
PlainPBStoragePlugin.CompressionMode |
Support for ZIP_PER_PV is still experimental.
|
POJOEvent |
A simple POJO that implements the event interface.
|
PolicyConfig |
A PolicyConfig object is typically the right hand side of a policy.
|
PolicyConfig.SamplingMethod |
|
PoorMansProfiler |
Small easy to use profiler.
|
PopulationVariance |
Implements the SummaryStatistics.getPopulationVariance
|
PostProcessor |
The interface for retrieval post processors.
|
PostProcessors |
Factory class for post processors.
|
PostProcessorWithConsolidatedEventStream |
Some post processors implement a consolidated event stream.
|
PrintExtraFields |
|
PrintFirstAndLastTimes |
Print the timestamp of the first and last sample in a PB files/PB files in a directory
|
PrintPBResponse |
|
PrintTimes |
|
ProcessMetrics |
Maintains a days worth of a limited number of predefined process metrics.
|
ProcessMetricsChartData |
|
ProcessMetricsReport |
Combine the process metrics from the various wars and send as json.
|
ProcessMgmtScriptables |
Called as part of the javadoc task;
This loads the javadoc generated file docs/api/mgmt_scriptables.txt and uses it to generate the docs/api/mgmt_scriptables.html document.
|
ProxyUtils |
Small utility class to proxy mgmt BPL to appliance other than this appliance.
|
PubSubEvent |
Generic POJO for pubsub events within this cluster..
|
PutClientConfiguration |
Puts a client configuration JSON file given the file name.
|
PutPVTypeInfo |
Updates the type info for a PV.
|
PV |
A control system PV.
|
PvaAction |
|
PvaArchivePVAction |
Add one or more pvs to the archiver.
|
PvaDataRetrievalService |
|
PvaDataRetrievalServlet |
|
PvaGetAllPVs |
Get all the PVs in the cluster.
|
PvaGetApplianceInfo |
Based on GetApplianceInfo
|
PvaGetArchivedPVs |
Given a list of PVs, determine those that are being archived.
|
PvaGetPVData |
|
PvaGetPVStatus |
Get the status of a PV.
|
PvaMergeDedupConsumer |
Implementation of the Merge/Dedup algorithm for combining EventStreams into one EventStream.
|
PvaMgmtService |
|
PvaMimeResponse |
|
PvaServlet |
|
PVConfig |
Represents the configuration for a single PV in the engine config file.
|
PVContext |
Handle PV context, pool PVs by name.
|
PVContext.MonitorMask |
|
PVDetails |
Details of a PV
|
PVDetails |
Gets the ETL details of a PV.
|
PVDetails |
Detailed statistics for a PV.
|
PVFactory |
|
PVListener |
A listener for PV updates.
|
PVMetrics |
PVMetrics includes the dynamic information of the pv
|
PVNames |
Utility class for dealing with various aspects of EPICS PV names
|
PVNames.EPICSVersion |
|
PVNameToKeyMapping |
Interface for converting a PV name to something that forms the prefix of a chunk's key.
|
PVsByStorageConsumed |
|
PVsByStorageConsumed |
|
PVsMatchingParameter |
Small utility class for listing PVs that match a parameter
|
PVStatusAction |
BPL for getting the status of a PV.
|
PVTypeInfo |
Somewhat static information about a PV like it's type info, graphic limits, event rates etc.
|
PVTypeInfoEvent |
Called when add/remove/update's are made on PVTypeInfo's
|
PVTypeInfoEvent.ChangeType |
|
QWResponse |
|
RawDataRetrievalAsEventStream |
Client side class for retrieving data from the appliance archiver using the PB over HTTP protocol.
|
ReadAsDBRType |
Small utilty to read a .pb file as the specfied DBR type.
|
Reader |
The main data retrieval interface; this is used to get an EventStream for events for one PV between a start and an end time.
|
RecentlyAddedPVs |
Generate a report of PVs that were recently added into the system.
|
RecentlyAddedPVsforThisInstance |
Generate a report of PVs recently added to this instance....
|
RecentlyChangedPVs |
Generate a report of PVs that were recently changed.
|
RecentlyChangedPVsforThisInstance |
|
RedisPersistence |
Uses redis as a persistence layer.
|
RefCountedChannel |
A Channel with thread-safe reference count.
|
RefreshPVDataFromChannelArchivers |
Call the config service to refresh the PV data from ChannelArchivers.
|
RemotableEventStreamDesc |
Information about the whole stream that is often used in generating headers etc...
|
RemotableOverRaw |
This is applicable to EventStreams.
|
RemoveAliasAction |
|
RemoveExternalArchiverServer |
Remove the entry for a external Archiver Data Server from the config database
Note that the entire cluster may need to be restarted for this change to take effect.
|
RenamePVAction |
|
ResetFailoverCaches |
|
ResetFailoverCachesForThisAppliance |
Each retrieval component in a cluster caches the PV's from remote failover appliances.
|
ReshardPV |
Reshards the PV to another appliance.
|
RestartArchiveWorkflowThreadForAppliance |
Restart the archive PV workflow for this thread.
|
ResumeArchivingPV |
|
ResumeArchivingPV |
|
RetrievalEventProcessor |
The DataRetrieval interface is a streaming interface with out-of-band events on the stream being passed as events on this interface.
|
RetrievalResult |
Result of a retrieval.
|
RetrievalServlet |
This is currently the code that remotes an event stream, for example from the engine etc.
|
RetrievalState |
|
RMS |
Implements the RMS across an interval
|
SampleBuffer |
Buffer for the samples of one channel.
|
SampleMode |
Archive engine sample mode description
|
SampleRetrievalState |
|
SampleValue |
Get the value of this event.
|
SamplingInfo |
Some additional info pertaining to the process of archiving.
|
ScalarStringSampleValue |
An implementation of SampleValue for scalar strings.
|
ScalarValue<T extends Number> |
An implementation of SampleValue for scalar numbers.
|
ScannedArchiveChannel |
An ArchiveChannel that stores value in a periodic scan.
|
SearchForPVsRegex |
|
SeekandPrintTimes |
Seek to a position in the file and then print some info about each event.
|
SilentPVReport |
|
SilentPVReport |
|
SimulationEvent |
An event typically used in the unit tests.
|
SimulationEventStream |
An EventStream that backed by a generator.
|
SimulationEventStreamIterator |
Iterator for the SimulationEventStream
|
SimulationValueGenerator |
Simple interface for a class that can be used to generate event streams based on some function.
|
SineGenerator |
Generates a sine wave with a default period of one hour and a specifiable offset.
|
SinglePVCSVResponse |
Implementation of a CSV response for a single PV
Currently, we are restricting the CSV response to only one PV.
|
Skewness |
Implements the skewness over a bin.
|
SkipAliasCheckAction |
|
SlicePBFile |
Make a copy of the specified PB file only including the samples between the specified timestamps.
|
SlowChangingPVsWithDroppedEvents |
|
SlowChangingPVsWithDroppedEvents |
A report that looks at the potentially slow changing PV's that have dropped events.
|
StandardDeviation |
Implements the RMS across an interval
|
StaticContentServlet |
Serves static content in the web app...
|
Statistics |
Statistics is a post processor which provides a set of statistical numbers for a specific bin.
|
StatusSeverityCounts |
Walks a directory and looks in the PB files and determines the most common status and severity codes....
|
StorageDetailsForAppliance |
|
StorageMetrics |
Interface providing details for the storage metrics pages...
|
StorageMetricsContext |
Performance optimization for storage metrics methods.
|
StorageMetricsForAppliance |
|
StoragePlugin |
The main interface for a storage plugin; this is an object that implements the reader and the writer interfaces.
|
StoragePluginURLParser |
Parses a URL representation of a storage plugin.
|
StorageRateReport |
Report for PV by storage rate
|
StorageRateReport |
A report on PVs based on their storage rates.
|
StorageReport |
|
StorageReportDetails |
|
StorageWithLifetime |
|
StorageWithLifetime.StorageConsumedByPV |
|
StreamPBIntoOutput |
Utility class with method to push an EventStream into an OutputStream
|
SummaryStatsCollector |
The SummaryStatsPostProcessor uses instances of this interface to compute statistical summaries
|
SummaryStatsCollectorAdditionalColumns |
The SummaryStatsPostProcessor uses instances of this interface to serve additional columns.
|
SummaryStatsCollectorEventStream |
An event stream over a list of SummaryStatsCollectors; typically used by post processors that return consolidated results.
|
SummaryStatsPostProcessor |
Abstract class for various operators that operate on a SummaryStatistics
Child classes implement the getIdentity and the getStats method.
|
SummaryStatsVectorCollector |
SummaryStatsCombinedCollector is a collector, which provides a set of numbers
(statistical results) rather than just a single value.
|
SVGResponse |
|
SyncStaticContentHeadersFooters |
Small utility to sync the headers and footers from index.html to the other html files.
|
SyncStaticContentHeadersFooters.TextChunk |
|
TextResponse |
A human readable text response; mostly to be used for debugging etc.
|
Throttle |
Throttle that only permits a certain number of events.
|
ThrottledLogger |
Logger that only allows a certain message rate.
|
ThruNumberAndStringConversion |
Generic class for some standard type conversions.
|
TimeSpan |
Simple time span class with start and end times.
|
TimeSpanDependentProcessing |
Post processors can optionally implement this interface if the implement timespan specific functionality
|
TimeSpanDependentProcessor |
A TimeSpan + PostProcessor used for time dependent sparsification.
|
TimeSpanLimitEventStream |
An EventStream that wraps another event stream but limits the data to samples greater than or equal to a specified start time and less than or equal to a specified end time.
|
TimeSpanReport |
Archiving time span.
|
TimeUtils |
There are various versions of timestamps in the archiver appliance.
|
TwoWeekRaw |
Returns raw data for the previous two weeks and uses FirstSamplePP for the rest.
|
TypeSystem |
Interface for translating from JCA to Event (actually DBRTimeEvents).
|
UnarchivedPVsAction |
Given a list of PVs, determine those that are not being archived/have pending requests.
|
UnitOfRetrieval |
|
UploadChannelArchiverConfigAction |
Use this to upload a Channel Archiver configuration file.
|
URIUtils |
Some utilities for parsing URI's
|
UserSpecifiedSamplingParams |
Various options that the user can specify for archiving a PV.
|
ValidateAndFixPBFile |
Validate every line in a PB file by unmarshalling it and accessing the timestamp.
|
ValidatePBFile |
Various validations for a PB file.
|
ValueUtil |
|
Variance |
Implements the SummaryStatistics.getVariance
|
VectorStringSampleValue |
An implementation of SampleValue for vector strings.
|
VectorValue<T extends Number> |
An implementation of SampleValue for vector numbers.
|
WaveformPVsAction |
List of all the waveforms being archived.
|
WaveformPVsAction |
All the waveforms that are currently being archived.
|
WebappReady |
The other web apps tell the mgmt webapp when they have started using this call.
|
WrappedSeekableByteChannel |
Compressed files typically do not let us seek arbitrarily within the stream.
|
WriteChannel |
Interface for writing samples to a channel in the archive
|
Writer |
The main data consumption interface, this represents objects which take an event stream and write it to a (potentially permanent) store.
|
WriterRunnable |
WriterRunnable is scheduled by the executor in the engine context every writing period.
|
XMLRPCClient |
A class that handles the XML-RPC portion of an existing channel archiver instance.
|
XMLRPCStaxProcessor |
Our layer on top of STAX; similar to DefaultHandler with the exception of the boolean to indicate pause/resume processing.
|
YearListener |
Callback once year changes
|
YearSecondTimestamp |
This is a version of a timestamp that breaks down time into a short year, a signed int secondsintoyear and a signed int nanos
This is the format that is used internally in the protocol buffers storage plugin.
|