com.devexperts.qd.logger
Class LoggedHistory

java.lang.Object
  extended by com.devexperts.qd.logger.LoggedObject
      extended by com.devexperts.qd.logger.LoggedCollector
          extended by com.devexperts.qd.logger.LoggedHistory
All Implemented Interfaces:
QDCollector, QDHistory, QDStatsContainer, SubscriptionContainer

public class LoggedHistory
extends LoggedCollector
implements QDHistory


Field Summary
 
Fields inherited from class com.devexperts.qd.logger.LoggedObject
log, name
 
Constructor Summary
LoggedHistory(QDLog log, java.lang.String name, QDHistory delegate)
           
 
Method Summary
 boolean examineData(DataRecord record, int cipher, java.lang.String symbol, long start_time, long end_time, DataVisitor visitor)
          Examines available records for specified parameters via specified data visitor.
 boolean examineData(DataVisitor visitor)
          Examines all stored data via specified data visitor.
 int getAvailableCount(DataRecord record, int cipher, java.lang.String symbol, long start_time, long end_time)
          Returns the number of available records for specified parameters.
 long getMaxAvailableTime(DataRecord record, int cipher, java.lang.String symbol)
          Returns maximal time of available records for specified parameters.
 long getMinAvailableTime(DataRecord record, int cipher, java.lang.String symbol)
          Returns minimal time of available records for specified parameters.
 boolean isStoreEverything()
          Returns status of "store everything" mode.
 void setStoreEverything(boolean store_everything)
          Sets "store everything" mode (disabled by default).
 
Methods inherited from class com.devexperts.qd.logger.LoggedCollector
createAgent, createAgent, createDistributor, createDistributor, examineSubscription, getContract, getScheme, getStats, getSubscriptionSize, getSymbol, isSubscribed, setErrorHandler
 
Methods inherited from class com.devexperts.qd.logger.LoggedObject
child, debug, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface com.devexperts.qd.QDCollector
createAgent, createAgent, createDistributor, createDistributor, getContract, getScheme, getSymbol, setErrorHandler
 
Methods inherited from interface com.devexperts.qd.SubscriptionContainer
examineSubscription, getSubscriptionSize, isSubscribed
 
Methods inherited from interface com.devexperts.qd.stats.QDStatsContainer
getStats
 

Constructor Detail

LoggedHistory

public LoggedHistory(QDLog log,
                     java.lang.String name,
                     QDHistory delegate)
Method Detail

isStoreEverything

public boolean isStoreEverything()
Description copied from interface: QDHistory
Returns status of "store everything" mode.

Specified by:
isStoreEverything in interface QDHistory
See Also:
QDHistory.setStoreEverything(boolean)

setStoreEverything

public void setStoreEverything(boolean store_everything)
Description copied from interface: QDHistory
Sets "store everything" mode (disabled by default). In this mode processData stores everything into underlying storage regardless of subscription (by default only records that are subscribed on are being stored). When subscription is removed records are not removed from storage (by default they are). Note, that HistorySubscriptionFilter is still honored (records are stored only up to the limits established by the filter).

Specified by:
setStoreEverything in interface QDHistory

getMinAvailableTime

public long getMinAvailableTime(DataRecord record,
                                int cipher,
                                java.lang.String symbol)
Description copied from interface: QDHistory
Returns minimal time of available records for specified parameters. Returns 0 if none are available.

Specified by:
getMinAvailableTime in interface QDHistory

getMaxAvailableTime

public long getMaxAvailableTime(DataRecord record,
                                int cipher,
                                java.lang.String symbol)
Description copied from interface: QDHistory
Returns maximal time of available records for specified parameters. Returns 0 if none are available.

Specified by:
getMaxAvailableTime in interface QDHistory

getAvailableCount

public int getAvailableCount(DataRecord record,
                             int cipher,
                             java.lang.String symbol,
                             long start_time,
                             long end_time)
Description copied from interface: QDHistory
Returns the number of available records for specified parameters. The records from time interval [start_time, end_time] inclusive are counted in the specified order (from start_time to end_time). Returns 0 if none are available.

Specified by:
getAvailableCount in interface QDHistory

examineData

public boolean examineData(DataRecord record,
                           int cipher,
                           java.lang.String symbol,
                           long start_time,
                           long end_time,
                           DataVisitor visitor)
Description copied from interface: QDHistory
Examines available records for specified parameters via specified data visitor. The records from time interval [start_time, end_time] inclusive are examined in the specified order (from start_time to end_time). Returns true if not all available data from specified interval were examined or false if all available data were examined.

Specified by:
examineData in interface QDHistory

examineData

public boolean examineData(DataVisitor visitor)
Description copied from interface: QDHistory
Examines all stored data via specified data visitor. Returns true if some data was not examined or false if everything was examined.

Specified by:
examineData in interface QDHistory