Package | Description |
---|---|
com.devexperts.qd |
This package contains basic interfaces and other API elements of QD system
which shall be sufficient for the client application programmer.
|
com.devexperts.qd.kit |
This package contains default implementations of various QD components which
do not constitute any separate module or subsystem and which can be easily replaced.
|
com.devexperts.qd.ng |
This package contains next-generation interfaces for data and subscription exchange based on
RecordCursor class. |
com.devexperts.qd.qtp |
This package contains interfaces with default implementations required
to create and operate a connection using QTP.
|
com.devexperts.qd.qtp.fieldreplacer |
Modifier and Type | Method and Description |
---|---|
boolean |
QDFilter.accept(RecordCursor cur) |
String |
DataField.getString(RecordCursor cursor) |
void |
DataField.read(com.devexperts.io.BufferedInput in,
RecordCursor cursor) |
void |
DataRecord.readFields(com.devexperts.io.BufferedInput in,
RecordCursor cursor)
Deprecated.
Use
BinaryQTPParser class |
void |
DataField.setString(RecordCursor cursor,
String value) |
boolean |
DataRecord.update(RecordCursor from,
RecordCursor to)
Updates this record's field values in
to cursor by values from cursor. |
T |
QDAgent.AttachmentStrategy.updateAttachment(T oldAttachment,
RecordCursor cursor,
boolean remove) |
void |
DataField.write(com.devexperts.io.BufferedOutput out,
RecordCursor cursor) |
void |
DataRecord.writeFields(com.devexperts.io.BufferedOutput out,
RecordCursor cursor)
Deprecated.
Use
BinaryQTPComposer class |
Modifier and Type | Method and Description |
---|---|
String |
WideDecimalField.getString(RecordCursor cursor) |
String |
VoidIntField.getString(RecordCursor cursor) |
String |
TimeMillisField.getString(RecordCursor cursor) |
String |
LongField.getString(RecordCursor cursor) |
String |
AbstractDataObjField.getString(RecordCursor cursor) |
String |
AbstractDataIntField.getString(RecordCursor cursor) |
protected abstract void |
ArrayListAttachmentStrategy.process(RecordCursor cursor,
T attachment,
C ctx) |
void |
ArrayListAttachmentStrategy.processEach(RecordCursor cursor,
C ctx) |
void |
WideDecimalField.read(com.devexperts.io.BufferedInput in,
RecordCursor cursor) |
void |
VoidIntField.read(com.devexperts.io.BufferedInput in,
RecordCursor cursor) |
void |
TimeMillisField.read(com.devexperts.io.BufferedInput in,
RecordCursor cursor) |
void |
LongField.read(com.devexperts.io.BufferedInput in,
RecordCursor cursor) |
void |
AbstractDataObjField.read(com.devexperts.io.BufferedInput in,
RecordCursor cursor) |
void |
AbstractDataIntField.read(com.devexperts.io.BufferedInput in,
RecordCursor cursor) |
void |
DefaultRecord.readFields(com.devexperts.io.BufferedInput in,
RecordCursor cursor) |
void |
WideDecimalField.setString(RecordCursor cursor,
String value) |
void |
VoidIntField.setString(RecordCursor cursor,
String value) |
void |
TimeMillisField.setString(RecordCursor cursor,
String value) |
void |
LongField.setString(RecordCursor cursor,
String value) |
void |
AbstractDataObjField.setString(RecordCursor cursor,
String value) |
void |
AbstractDataIntField.setString(RecordCursor cursor,
String value) |
boolean |
DefaultRecord.update(RecordCursor from,
RecordCursor to) |
Object |
ArrayListAttachmentStrategy.updateAttachment(Object oldAttachment,
RecordCursor cursor,
boolean remove) |
void |
WideDecimalField.write(com.devexperts.io.BufferedOutput out,
RecordCursor cursor) |
void |
VoidIntField.write(com.devexperts.io.BufferedOutput out,
RecordCursor cursor) |
void |
TimeMillisField.write(com.devexperts.io.BufferedOutput out,
RecordCursor cursor) |
void |
LongField.write(com.devexperts.io.BufferedOutput out,
RecordCursor cursor) |
void |
AbstractDataObjField.write(com.devexperts.io.BufferedOutput out,
RecordCursor cursor) |
void |
AbstractDataIntField.write(com.devexperts.io.BufferedOutput out,
RecordCursor cursor) |
void |
DefaultRecord.writeFields(com.devexperts.io.BufferedOutput out,
RecordCursor cursor) |
Modifier and Type | Method and Description |
---|---|
RecordCursor |
RecordBuffer.add(DataRecord record,
int cipher,
String symbol)
Returns write cursor at the current limit and advances limit.
|
RecordCursor |
RecordBuffer.add(RecordCursor from)
Adds a record to this buffer from the specified
RecordCursor
and returns write cursor to the recently added record. |
RecordCursor |
RecordBuffer.addDataAndCompactIfNeeded(RecordCursor from)
Adds record with data from the specified
RecordCursor . |
static RecordCursor |
RecordCursor.allocate(DataRecord record,
int cipher,
String symbol)
Allocates writable
RecordCursor that points to a freshly allocated storage for a given record's
integer and object field values and also sets symbol. |
static RecordCursor |
RecordCursor.allocate(DataRecord record,
int cipher,
String symbol,
RecordMode mode)
Allocates writable
RecordCursor that points to a freshly allocated storage for a given record's
integer and object field values using a specified mode and also sets symbol. |
static RecordCursor |
RecordCursor.allocate(DataRecord record,
String symbol)
Allocates writable
RecordCursor that points to a freshly allocated storage for a given record's
integer and object field values and also sets symbol. |
static RecordCursor |
RecordCursor.allocate(DataRecord record,
String symbol,
RecordMode mode)
Allocates writable
RecordCursor that points to a freshly allocated storage for a given record's
integer and object field values using a specified mode and also sets symbol. |
static RecordCursor |
RecordCursor.allocate(RecordCursor source)
Allocates
RecordCursor that points to a freshly allocated storage with a copy of
data from a given source. |
abstract RecordCursor |
RecordSource.current()
Returns read cursor at the current position.
|
RecordCursor |
RecordBuffer.current()
Returns read cursor at the current position.
|
RecordCursor |
RecordCursor.Owner.cursor()
Returns owned
RecordCursor . |
abstract RecordCursor |
RecordSource.cursorAt(long position)
Returns read cursor at a specified position.
|
RecordCursor |
RecordBuffer.cursorAt(long position)
Returns read cursor at a specified position.
|
abstract RecordCursor |
RecordSource.next()
Returns read cursor at the current position and advances position to next record.
|
RecordCursor |
RecordBuffer.next()
Returns read cursor at the current position and advances position to next record.
|
RecordCursor |
RecordBuffer.writeCurrent()
Returns write cursor at the current position.
|
RecordCursor |
RecordBuffer.writeCursorAt(long position)
Returns write cursor at a specified position.
|
RecordCursor |
RecordBuffer.writeNext()
Returns write cursor at the current position and advances position to next record.
|
Modifier and Type | Method and Description |
---|---|
boolean |
RecordFilter.accept(RecordCursor cur)
Returns true if record pointed to by this cursor is accepted.
|
RecordCursor |
RecordBuffer.add(RecordCursor from)
Adds a record to this buffer from the specified
RecordCursor
and returns write cursor to the recently added record. |
RecordCursor |
RecordBuffer.addDataAndCompactIfNeeded(RecordCursor from)
Adds record with data from the specified
RecordCursor . |
static RecordCursor |
RecordCursor.allocate(RecordCursor source)
Allocates
RecordCursor that points to a freshly allocated storage with a copy of
data from a given source. |
static RecordCursor.Owner |
RecordCursor.allocateOwner(RecordCursor source)
Allocates
RecordCursor.Owner that points to a freshly allocated storage with a copy of
data from a given source. |
void |
RecordSink.append(RecordCursor cursor)
Adds a record to this sink from the specified
RecordCursor . |
void |
RecordBuffer.append(RecordCursor from)
Adds a record to this buffer from the specified
RecordCursor . |
abstract void |
AbstractRecordSink.append(RecordCursor cursor)
Adds a record to this sink from the specified
RecordCursor . |
void |
RecordBuffer.cleanup(RecordCursor cursor)
Cleanups the data at the corresponding cursor and reduces
RecordBuffer.size() by one. |
void |
RecordCursor.copyDataFrom(RecordCursor from)
Copies data from the specified
RecordCursor . |
void |
RecordCursor.copyFrom(RecordCursor from)
Copies data and extra values from the specified cursor into this cursor overwriting everything unconditionally.
|
protected double |
RecordMapping.getAsDouble(RecordCursor cursor,
int fieldId) |
protected int |
RecordMapping.getAsInt(RecordCursor cursor,
int fieldId) |
protected long |
RecordMapping.getAsLong(RecordCursor cursor,
int fieldId) |
protected long |
RecordMapping.getAsTimeMillis(RecordCursor cursor,
int fieldId) |
protected int |
RecordMapping.getAsTimeSeconds(RecordCursor cursor,
int fieldId) |
protected int |
RecordMapping.getAsTinyDecimal(RecordCursor cursor,
int fieldId) |
protected long |
RecordMapping.getAsWideDecimal(RecordCursor cursor,
int fieldId) |
protected int |
RecordMapping.getInt(RecordCursor cursor,
int intFieldIndex) |
protected long |
RecordMapping.getLong(RecordCursor cursor,
int intFieldIndex) |
protected Object |
RecordMapping.getObj(RecordCursor cursor,
int objFieldIndex) |
boolean |
RecordCursor.isDataIdenticalTo(RecordCursor other)
Returns
true when data contents of this cursor are equal (identity-wise) to the contents
of the other cursor. |
void |
RecordCursor.Owner.setAs(RecordCursor other)
Configures the
cursor to be exactly as the other cursor. |
protected void |
RecordMapping.setAsDouble(RecordCursor cursor,
int fieldId,
double value) |
protected void |
RecordMapping.setAsInt(RecordCursor cursor,
int fieldId,
int value) |
protected void |
RecordMapping.setAsLong(RecordCursor cursor,
int fieldId,
long value) |
protected void |
RecordMapping.setAsTimeMillis(RecordCursor cursor,
int fieldId,
long value) |
protected void |
RecordMapping.setAsTimeSeconds(RecordCursor cursor,
int fieldId,
int value) |
protected void |
RecordMapping.setAsTinyDecimal(RecordCursor cursor,
int fieldId,
int value) |
protected void |
RecordMapping.setAsWideDecimal(RecordCursor cursor,
int fieldId,
long value) |
protected void |
RecordMapping.setInt(RecordCursor cursor,
int intFieldIndex,
int value) |
protected void |
RecordMapping.setLong(RecordCursor cursor,
int intFieldIndex,
long value) |
protected void |
RecordMapping.setObj(RecordCursor cursor,
int objFieldIndex,
Object value) |
boolean |
RecordCursor.updateDataFrom(RecordCursor from)
Updates data from the specified cursor into this cursor, checking each field with
DataIntField.equals(int,int) or DataObjField.equals(Object,Object) respectively. |
boolean |
RecordCursor.updateFrom(RecordCursor from)
Deprecated.
Renamed to
updateDataFrom(RecordCursor) |
Modifier and Type | Method and Description |
---|---|
RecordCursor |
BinaryRecordDesc.readRecord(com.devexperts.io.BufferedInput msg,
RecordBuffer buffer,
int cipher,
String symbol,
int eventFlags)
Reads record from the specified input and adds it to the specified cursor.
|
Modifier and Type | Method and Description |
---|---|
Consumer<RecordCursor> |
FieldReplacer.createFieldReplacer(DataRecord dataRecord)
Creates consumer to be used to update fields in
RecordCursor
with specified data record . |
Modifier and Type | Method and Description |
---|---|
void |
OutputStreamComposer.append(RecordCursor cursor) |
void |
AbstractQTPComposer.append(RecordCursor cursor) |
protected long |
AbstractQTPComposer.getEventTimeSequence(RecordCursor cursor) |
protected void |
BinaryRecordDesc.readFields(com.devexperts.io.BufferedInput msg,
RecordCursor cur,
int nDesc) |
protected void |
AbstractQTPParser.replaceFieldIfNeeded(RecordCursor cursor) |
protected void |
AbstractQTPParser.setEventTimeSequenceIfNeeded(RecordCursor cur) |
protected void |
BinaryRecordDesc.setIntValue(RecordCursor cur,
int index,
int value,
com.devexperts.io.BufferedInput msg) |
protected void |
BinaryRecordDesc.setLongValue(RecordCursor cur,
int index,
long value,
com.devexperts.io.BufferedInput msg) |
protected void |
BinaryRecordDesc.setObjValue(RecordCursor cur,
int index,
Object value,
com.devexperts.io.BufferedInput msg) |
protected void |
BinaryQTPComposer.writeField(DataField field,
RecordCursor cursor) |
protected abstract void |
AbstractQTPComposer.writeField(DataField field,
RecordCursor cursor) |
void |
BinaryRecordDesc.writeRecord(com.devexperts.io.BufferedOutput msg,
RecordCursor cur,
int eventFlags,
long eventTimeSequence)
Writers record to the specified output from the specified cursor.
|
protected void |
BinaryQTPComposer.writeRecordPayload(RecordCursor cursor,
int eventFlags) |
protected void |
AbstractQTPComposer.writeRecordPayload(RecordCursor cursor,
int eventFlags) |
Modifier and Type | Method and Description |
---|---|
static Consumer<RecordCursor> |
FieldReplacersCache.createComposite(List<Consumer<RecordCursor>> consumers) |
Consumer<RecordCursor> |
DefaultFieldReplacer.createFieldReplacer(DataRecord record) |
Modifier and Type | Method and Description |
---|---|
void |
FieldReplacersCache.accept(RecordCursor cursor) |
Modifier and Type | Method and Description |
---|---|
static Consumer<RecordCursor> |
FieldReplacersCache.createComposite(List<Consumer<RecordCursor>> consumers) |
Copyright © 2002–2025 Devexperts LLC. All rights reserved.