Package ch.psi.wica.infrastructure.stream

Class WicaStreamDataBuffer<T extends WicaChannelData>

java.lang.Object

ch.psi.wica.infrastructure.stream.WicaStreamDataBuffer<T>

Direct Known Subclasses:

WicaStreamMetadataDataBuffer, WicaStreamMonitoredValueDataBuffer, WicaStreamPolledValueDataBuffer

@ThreadSafe
abstract class WicaStreamDataBuffer<T extends WicaChannelData>
extends Object

Constructor Summary

Constructors

Constructor	Description
WicaStreamDataBuffer(int bufferSize)	Constructs a new instance which is capable of holding a queue of received data points up to the configured buffer size.

Method Summary

Modifier and Type	Method	Description
Map<WicaChannel,List<T>>	getLaterThan(Set<WicaChannel> wicaChannels, LocalDateTime since)
T	getLatest(WicaDataBufferStorageKey key)
protected abstract WicaDataBufferStorageKey	getStorageKey(WicaChannel wicaChannel)
void	saveDataPoint(WicaDataBufferStorageKey key, T t)

Methods inherited from class java.lang.Object

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

Constructor Details

WicaStreamDataBuffer

WicaStreamDataBuffer(int bufferSize)

Constructs a new instance which is capable of holding a queue of received data points up to the configured buffer size.

Parameters:

bufferSize - the buffer size.

Method Details

getLaterThan

public Map<WicaChannel,List<T>> getLaterThan(Set<WicaChannel> wicaChannels,
 LocalDateTime since)

saveDataPoint

public void saveDataPoint(WicaDataBufferStorageKey key,
 T t)

getLatest

public T getLatest(WicaDataBufferStorageKey key)

getStorageKey

protected abstract WicaDataBufferStorageKey getStorageKey(WicaChannel wicaChannel)