Package deltix.qsrv.hf.tickdb.pub

Interface TickCursor

All Superinterfaces:

deltix.util.concurrent.AbstractCursor, java.lang.AutoCloseable, java.io.Closeable, deltix.util.lang.Disposable, EntityAndTypeSubscriptionController, EntitySubscriptionController, InstrumentMessageSource, deltix.util.concurrent.IntermittentlyAvailableResource, MessageInfo, deltix.data.stream.MessageSource<deltix.qsrv.hf.pub.InstrumentMessage>, RealTimeMessageSource<deltix.qsrv.hf.pub.InstrumentMessage>, StreamSubscriptionController, SubscriptionController, SymbolAndTypeSubscriptionController, SymbolSubscriptionController, TimeController, TypedMessageSource, TypeSubscriptionController

All Known Implementing Classes:

TickCursorAdapter, TickCursorClientAeron

public interface TickCursor
extends InstrumentMessageSource

A cursor (also known as iterator, or result set) for reading data from a stream. This class provides implements SubscriptionController for dynamically reconfiguring the feed, as well as method TimeController.reset(long) for essentially re-opening the cursor on a completely different timestamp. This class extends [sequential] FilteredMessageSource with random access to underlying source using TimeController.reset(long) method.

Method Summary

Methods inherited from interface deltix.util.concurrent.AbstractCursor

isAtEnd, next

Methods inherited from interface deltix.util.lang.Disposable

close

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.EntityAndTypeSubscriptionController

add, remove

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.EntitySubscriptionController

addEntities, addEntities, addEntity, clearAllEntities, removeEntities, removeEntities, removeEntity, subscribeToAllEntities

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.InstrumentMessageSource

getMessage, isClosed

Methods inherited from interface deltix.util.concurrent.IntermittentlyAvailableResource

setAvailabilityListener

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.MessageInfo

getCurrentEntityIndex, getCurrentStream, getCurrentStreamIndex, getCurrentStreamKey

Methods inherited from interface deltix.data.stream.RealTimeMessageSource

isRealTime, realTimeAvailable

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.StreamSubscriptionController

addStream, removeAllStreams, removeStream

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.SymbolAndTypeSubscriptionController

add, remove

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.SymbolSubscriptionController

addSymbol, addSymbols, addSymbols, clearAllSymbols, removeSymbol, removeSymbols, removeSymbols, subscribeToAllSymbols

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.TimeController

reset, setTimeForNewSubscriptions

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.TypedMessageSource

getCurrentType, getCurrentTypeIndex

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.TypeSubscriptionController

addTypes, removeTypes, setTypes, subscribeToAllTypes