Class InstrumentMapKlineSourceRTIndicator

java.lang.Object

com.wualabs.qtsurfer.engine.indicators.core.AbstractRTIndicator

com.wualabs.qtsurfer.engine.indicators.helpers.group.InstrumentMapRTIndicator

com.wualabs.qtsurfer.engine.indicators.helpers.group.InstrumentMapKlineSourceRTIndicator

All Implemented Interfaces:

Backtestable, ClockAware, Resettable, RTIndicator, RTIndicatorSource<Kline>

public class InstrumentMapKlineSourceRTIndicator
extends InstrumentMapRTIndicator
implements RTIndicatorSource<Kline>

A map of RTIndicators for an instrument fed from a kline stream — the kline-side counterpart of InstrumentMapTickerSourceRTIndicator. Builds a KlineSnapshot once per bar and dispatches it to every registered indicator.

RichRTIndicator indicators must be bound to KlineSnapshot or to the MarketSnapshot supertype — which covers every shipped indicator: the OHLCV pro indicators and the scalar wrapper (TickerRTIndicator) are all MarketSnapshot-bound. A hand-written RichRTIndicator<TickerSnapshot> would throw ClassCastException here (klines carry no order-book data), but none ship. The scalar fallback uses a KlineValueSource via KlineSnapshots; a NumberOfTrades source on a non-kline snapshot resolves to Double.NaN and is skipped.

Nested Class Summary

Nested classes/interfaces inherited from class InstrumentMapRTIndicator

InstrumentMapRTIndicator.IndicatorNotFoundException

Field Summary

Fields inherited from class InstrumentMapRTIndicator

PRIVATE_PREFIX

Constructor Summary

Constructors

Constructor	Description
InstrumentMapKlineSourceRTIndicator(@NonNull Instrument instrument, @NonNull KlineValueSource valueSource)
InstrumentMapKlineSourceRTIndicator(Instrument instrument)

Method Summary

Modifier and Type	Method	Description
InstrumentMapKlineSourceRTIndicator	backtestEnabled(boolean backtestEnabled)
protected String	cacheSelector()	Which field of the incoming data this map extracts for scalar indicators, as a stable string.
boolean	equals(Object obj)
KlineValueSource	getValueSource()
int	hashCode()
boolean	isBacktestEnabled()
void	setBacktestEnabled(boolean backtestEnabled)
void	updateFrom(Kline source)	Propagates a kline update to all registered indicators and to this map itself.

Methods inherited from class InstrumentMapRTIndicator

add, clear, forEachPublicable, get, getCacheContext, getExisting, getInstrument, getNotices, getRaw, getReadOnly, getReadOnlyExisting, getValue, indicators, namedIndicators, raiseNotice, remove, reset, setClockSupplier, size, toString

Methods inherited from class AbstractRTIndicator

getDisplayHint, getMeta, getValue, hide, isPoison, setValue, toString, update, withDisplayHint, withMeta

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface RTIndicator

getId, isHidden, isReady, ro, update, update

Constructor Details

InstrumentMapKlineSourceRTIndicator

public InstrumentMapKlineSourceRTIndicator(Instrument instrument)

InstrumentMapKlineSourceRTIndicator

public InstrumentMapKlineSourceRTIndicator(@NonNull
 @NonNull Instrument instrument,
 @NonNull
 @NonNull KlineValueSource valueSource)

Method Details

backtestEnabled

public InstrumentMapKlineSourceRTIndicator backtestEnabled(boolean backtestEnabled)

cacheSelector

protected String cacheSelector()

Description copied from class: InstrumentMapRTIndicator

Which field of the incoming data this map extracts for scalar indicators, as a stable string.

Abstract rather than defaulted on purpose: a subclass that reads a different field and forgot to say so would share memoized series between streams that never produced the same numbers, and a compile error is a far better way to find that out than a wrong leaderboard.

Specified by:

cacheSelector in class InstrumentMapRTIndicator

Returns:

the selector name, never null

updateFrom

public void updateFrom(Kline source)

Propagates a kline update to all registered indicators and to this map itself. In backtest mode, the bar close time is used to set a fixed clock on all clock-aware indicators before the update. Each child indicator is updated via RichRTIndicator.updateFrom(T) if it implements that interface, otherwise via KlineSnapshots.update(RTIndicator, MarketSnapshot, KlineValueSource) which extracts the configured value source field.

Specified by:

updateFrom in interface RTIndicatorSource<Kline>

Parameters:

source - the kline data to propagate

hashCode

public int hashCode()

Overrides:

hashCode in class InstrumentMapRTIndicator

equals

public boolean equals(Object obj)

Overrides:

equals in class InstrumentMapRTIndicator

getValueSource

public KlineValueSource getValueSource()

isBacktestEnabled

public boolean isBacktestEnabled()

Specified by:

isBacktestEnabled in interface Backtestable

setBacktestEnabled

public void setBacktestEnabled(boolean backtestEnabled)

Specified by:

setBacktestEnabled in interface Backtestable