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.qtp |
This package contains interfaces with default implementations required
to create and operate a connection using QTP.
|
com.devexperts.qd.qtp.socket |
This package contains a QTP connectors which use standard Java sockets.
|
com.devexperts.qd.stats |
Modifier and Type | Method and Description |
---|---|
static QDStats |
QDFactory.createStats(QDStats.SType type,
DataScheme scheme)
Creates default implementation of
QDStats with the specified type
and scheme. |
QDStats |
QDCollector.Builder.getStats()
Returns specified stats.
|
Modifier and Type | Method and Description |
---|---|
QDHistory |
QDFactory.createHistory(DataScheme scheme,
QDStats stats)
Deprecated.
use
QDFactory.historyBuilder() instead. |
QDHistory |
QDFactory.createHistory(DataScheme scheme,
QDStats stats,
HistorySubscriptionFilter historyFilter)
Deprecated.
use
QDFactory.historyBuilder() instead. |
QDStream |
QDFactory.createStream(DataScheme scheme,
QDStats stats)
Deprecated.
use
QDFactory.streamBuilder() instead. |
QDTicker |
QDFactory.createTicker(DataScheme scheme,
QDStats stats)
Deprecated.
use
QDFactory.tickerBuilder() instead. |
QDCollector.Builder<T> |
QDCollector.Builder.withStats(QDStats stats)
Adds stats to collector builder.
|
Modifier and Type | Field and Description |
---|---|
protected QDStats |
AbstractQTPParser.stats
Where to collect stats to.
|
protected QDStats |
AbstractQTPComposer.stats |
Modifier and Type | Field and Description |
---|---|
static com.devexperts.util.TypedKey<QDStats> |
MessageConnectors.STATS_KEY |
Modifier and Type | Method and Description |
---|---|
QDStats |
QDEndpoint.getRootStats() |
QDStats |
MessageConnector.getStats()
Returns
QDStats associated with this message connector. |
QDStats |
MessageAdapter.getStats() |
QDStats |
AbstractMessageConnector.getStats() |
Modifier and Type | Method and Description |
---|---|
boolean |
ByteArrayComposer.compose(MessageProvider provider,
QDStats stats)
Deprecated.
Composes message from the corresponding message provides and update IO bytes written in stats.
|
MessageAdapter |
MessageAdapter.Factory.createAdapter(QDStats stats)
Creates message adapter.
|
abstract MessageAdapter |
MessageAdapter.ConfigurableFactory.createAdapter(QDStats stats)
Creates message adapter.
|
MessageAdapter |
DistributorAdapter.Factory.createAdapter(QDStats stats) |
MessageAdapter |
AgentAdapter.Factory.createAdapter(QDStats stats) |
static List<MessageConnector> |
MessageConnectors.createMessageConnectors(com.devexperts.connector.proto.ApplicationConnectionFactory acFactory,
String addresses,
QDStats stats) |
static List<MessageConnector> |
MessageConnectors.createMessageConnectors(ConfigurableMessageAdapterFactory cFactory,
String addresses,
QDStats parentStats)
Creates new connectors for specified addresses using specified
configurable adapter factory.
|
void |
MessageConnector.setStats(QDStats stats)
Changes
QDStats associated with this message connector. |
void |
AbstractQTPParser.setStats(QDStats stats)
Changes stats to gather parser statistics.
|
void |
AbstractQTPComposer.setStats(QDStats stats)
Changes stats to gather composer statistics.
|
void |
AbstractMessageConnector.setStats(QDStats stats) |
Constructor and Description |
---|
AgentAdapter(DataScheme scheme,
QDStats stats)
Creates new agent adapter for specified scheme and stats.
|
AgentAdapter(QDEndpoint endpoint,
QDTicker ticker,
QDStream stream,
QDHistory history,
SubscriptionFilter filter,
QDFilter stripe,
QDStats stats)
Creates new agent adapter for specified endpoints, ticker, stream, history, filter and stats.
|
AgentAdapter(QDEndpoint endpoint,
QDTicker ticker,
QDStream stream,
QDHistory history,
SubscriptionFilter filter,
QDStats stats)
Deprecated.
|
AgentAdapter(QDTicker ticker,
QDStream stream,
QDHistory history,
SubscriptionFilter filter,
QDStats stats)
Deprecated.
|
DistributorAdapter(QDEndpoint endpoint,
QDTicker ticker,
QDStream stream,
QDHistory history,
SubscriptionFilter filter,
QDFilter stripe,
QDStats stats,
FieldReplacersCache fieldReplacer) |
DistributorAdapter(QDEndpoint endpoint,
QDTicker ticker,
QDStream stream,
QDHistory history,
SubscriptionFilter filter,
QDStats stats)
Deprecated.
|
DistributorAdapter(QDEndpoint endpoint,
QDTicker ticker,
QDStream stream,
QDHistory history,
SubscriptionFilter filter,
QDStats stats,
FieldReplacersCache fieldReplacer)
Deprecated.
|
DistributorAdapter(QDTicker ticker,
QDStream stream,
QDHistory history,
SubscriptionFilter filter,
QDStats stats)
Deprecated.
|
MessageAdapter(QDEndpoint endpoint,
QDStats stats) |
MessageAdapter(QDStats stats) |
QDEndpoint(QDEndpoint.Builder builder,
QDStats rootStats) |
QDEndpoint(String name,
DataScheme scheme,
QDStats rootStats,
List<QDCollector.Factory> collectors,
boolean withEventTimeSequence,
boolean storeEverything)
Deprecated.
Use
QDEndpoint.Builder.build() or builder constructor. |
Modifier and Type | Method and Description |
---|---|
MessageAdapter |
SocketMessageAdapterFactory.createAdapterWithSocket(Socket socket,
QDStats stats)
Runs custom authorization/authentication protocol over given
socket and
returns MessageAdapter for communication with remote host. |
void |
ServerSocketConnector.setStats(QDStats stats)
Sets stats for this connector.
|
void |
ClientSocketConnector.setStats(QDStats stats)
Sets stats for this connector.
|
Modifier and Type | Field and Description |
---|---|
protected static QDStats[] |
QDStats.EMPTY_CHILDREN |
static QDStats |
QDStats.VOID
The instance of QDStats that is always empty.
|
Modifier and Type | Method and Description |
---|---|
QDStats |
QDStats.create(QDStats.SType type)
Creates and returns new child with the corresponding type.
|
QDStats |
QDStats.create(QDStats.SType type,
String keyProperties)
Creates and returns new child with the corresponding type and key properties.
|
QDStats |
QDStats.create(QDStats.SType type,
String keyProperties,
boolean useRid)
Creates and returns new child with the corresponding type, key properties,
and an optional per-record tracking of stats.
|
protected QDStats |
QDStats.createInternal(QDStats.SType type,
String keyProperties,
boolean isSum,
int ridCount,
DataScheme scheme) |
static QDStats |
QDStats.createNamedVoid(String keyProperties)
|
QDStats |
QDStats.get(QDStats.SType type)
Returns the first found child with the specified type or
null if not found. |
QDStats |
QDStats.get(QDStats.SType type,
String keyProperties)
Returns the first found child with the corresponding type and key properties or
null if not found. |
protected QDStats[] |
QDStats.getChildren() |
QDStats |
QDStats.getOrCreate(QDStats.SType type)
Returns the first found child with the corresponding type or
creates new
one if not found. |
QDStats |
QDStats.getOrCreate(QDStats.SType type,
String keyProperties)
Returns the first found child with the corresponding type and key properties or
creates new one if not found. |
protected QDStats |
QDStats.getOrCreateSum(QDStats.SType type) |
QDStats |
QDStats.getOrVoid(QDStats.SType type)
Returns first found child with the corresponding type or
VOID if not found. |
protected QDStats |
QDStats.getParent() |
QDStats |
QDStatsContainer.getStats() |
protected QDStats |
QDStats.newInstance(QDStats.SType type,
boolean unmanaged) |
Modifier and Type | Method and Description |
---|---|
List<QDStats> |
QDStats.getAll(QDStats.SType type)
Returns all children with the corresponding type.
|
Modifier and Type | Method and Description |
---|---|
protected int |
QDStats.addChild(QDStats child) |
protected void |
QDStats.addClosedStats(QDStats child) |
protected void |
QDStats.initChild(QDStats child,
QDStats.SType type,
String keyProperties,
int ridCount,
DataScheme scheme) |
protected void |
QDStats.initStats(QDStats parent,
QDStats.StatsLock lock,
QDStats.SType type,
DataScheme scheme)
Deprecated.
|
protected boolean |
QDStats.isSumFor(QDStats child) |
protected void |
QDStats.removeChild(QDStats child,
int childIndex) |
Copyright © 2002–2025 Devexperts LLC. All rights reserved.