Package | Description |
---|---|
com.aquenos.cassandra.pvarchiver.controlsystem |
Provides the link between the archive server and the control-system specific
support modules.
|
Modifier and Type | Method and Description |
---|---|
ListenableFuture<? extends ControlSystemChannel> |
ControlSystemSupport.createChannel(String channelName,
Map<String,String> options,
SampleBucketId currentBucketId,
SampleListener<SampleType> sampleListener)
Creates the control-system-specific support for an archived channel.
|
ListenableFuture<Void> |
ControlSystemSupport.deleteSamples(SampleBucketId bucketId)
Deletes all samples associated with the specified sample bucket.
|
ListenableFuture<SampleWithSizeEstimate<SampleType>> |
ControlSystemSupport.generateChannelDisabledSample(String channelName,
Map<String,String> options,
SampleBucketId currentBucketId)
Generates a sample that indicates that the specified channel is disabled.
|
ListenableFuture<SampleBucketState> |
ControlSystemSupport.getSampleBucketState(SampleBucketId bucketId)
Returns the state of the specified sample bucket.
|
ListenableFuture<ObjectResultSet<SampleType>> |
ControlSystemSupport.getSamples(SampleBucketId bucketId,
long timeStampGreaterThanOrEqualTo,
long timeStampLessThanOrEqualTo,
int limit)
Retrieves samples from the specified sample bucket.
|
ListenableFuture<ObjectResultSet<SampleType>> |
ControlSystemSupport.getSamplesInReverseOrder(SampleBucketId bucketId,
long timeStampGreaterThanOrEqualTo,
long timeStampLessThanOrEqualTo,
int limit)
Retrieves samples from the specified sample bucket in reverse order
(newer samples first).
|
ListenableFuture<Void> |
ControlSystemSupport.writeSample(SampleType sample,
SampleBucketId bucketId,
int newBucketSize)
Writes a sample to the database.
|
Copyright © 2011–2017 aquenos GmbH. All rights reserved.