Class InstrumentGroupRTIndicator

java.lang.Object

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

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

All Implemented Interfaces:

ClockAware, Resettable, RTIndicator

public class InstrumentGroupRTIndicator
extends AbstractRTIndicator
implements ClockAware

Groups an instrument indicator map and extra indicators as a whole with a builder interface

Field Summary

Fields

Modifier and Type	Field	Description
static final String	PREFIX_ADD
static final String	PREFIX_BOLLINGER
static final String	PREFIX_CCI
static final String	PREFIX_CLAMP
static final String	PREFIX_DIFF
static final String	PREFIX_DIST
static final String	PREFIX_EMA
static final String	PREFIX_GAIN
static final String	PREFIX_HIDDEN
static final String	PREFIX_LOSS
static final String	PREFIX_MACD
static final String	PREFIX_MAX
static final String	PREFIX_MIN
static final String	PREFIX_MUL
static final String	PREFIX_RATE_CHANGE
static final String	PREFIX_ROUND
static final String	PREFIX_RSI
static final String	PREFIX_SMA
static final String	PREFIX_STOCH_RSI
static final String	PREFIX_SUM
static final String	PREFIX_WINDOW
static final String	RTINDICATOR_PRICE
static final String	SUBFIX_BANDWIDTH	Bandwidth name suffix — a structural disambiguator (the band's own name), not a display hint.
static final String	SUBFIX_BOLLINGER_LOWER
static final String	SUBFIX_BOLLINGER_UPPER

Constructor Summary

Constructors

Constructor	Description
InstrumentGroupRTIndicator(Instrument instrument)
InstrumentGroupRTIndicator(@NonNull InstrumentMapRTIndicator indicators)

Method Summary

Modifier and Type	Method	Description
InstrumentGroupRTIndicator	add(@NonNull String name, @NonNull MarketSnapshotValueSource valueSource)
InstrumentGroupRTIndicator	add(@NonNull String name, @NonNull MarketSnapshotValueSource valueSource, RTIndicator indicator)
InstrumentGroupRTIndicator	add(@NonNull String name, @NonNull RTIndicator indicator)
InstrumentGroupRTIndicator	add(@NonNull String name, @NonNull RTIndicator indicator, @NonNull DisplayHint displayHint)	Registers an indicator under a clean name, carrying its DisplayHint as descriptor metadata instead of smuggling it into the name.
InstrumentGroupRTIndicator	add(String indicatorA, String indicatorB)
InstrumentGroupRTIndicator	add(String name, String indicatorA, String indicatorB)
InstrumentGroupRTIndicator	addPrice()
void	addWindow(WindowTimeRTIndicator window)
InstrumentGroupRTIndicator	backtestEnabled(boolean backtestEnabled)	Enables or disables backtest mode for this group and its underlying indicator map.
InstrumentGroupRTIndicator	bollinger()
InstrumentGroupRTIndicator	bollinger(int periods)
InstrumentGroupRTIndicator	bollinger(int periods, Number k)
InstrumentGroupRTIndicator	bollinger(String name, int periods, Number k)	Adds a Bollinger Bands indicator with its upper and lower bands as separate named entries.
InstrumentGroupRTIndicator	bollingerBandwidth(String bollingerIndicatorName)	Adds a Bollinger BandWidth indicator derived from an existing Bollinger indicator.
InstrumentGroupRTIndicator	cci(int periods)	CCI over periods, registered as "cci" + periods.
InstrumentGroupRTIndicator	cci(String name, int periods)
InstrumentGroupRTIndicator	clamp(String indicator, Number minRange, Number maxRange)
InstrumentGroupRTIndicator	clamp(String name, String indicator, Number minRange, Number maxRange)
InstrumentGroupRTIndicator	clamp(String name, String indicator, Predicate<Double> clampPredicate, Number clampValue)
InstrumentGroupRTIndicator	clamp(String indicator, Predicate<Double> clampPredicate, Number clampValue)
void	clear()
InstrumentGroupRTIndicator	conditional(String name, String indicator, @NonNull Predicate<RTIndicator> predicate, @NonNull RTIndicator thenIndicator)
InstrumentGroupRTIndicator	conditional(String name, String indicator, @NonNull Predicate<RTIndicator> predicate, @NonNull RTIndicator thenIndicator, RTIndicator elseIndicator)
InstrumentGroupRTIndicator	decorate(String name, String indicator, @NonNull UnaryOperator<RTIndicator> op)	Wraps an existing indicator with a unary operator transformation and registers the result.
InstrumentGroupRTIndicator	diff(String indicatorA, String indicatorB)
InstrumentGroupRTIndicator	diff(String name, String indicatorA, String indicatorB)
InstrumentGroupRTIndicator	distance(String indicator, String indicatorBase)
InstrumentGroupRTIndicator	distance(String name, String indicator, String indicatorBase)
InstrumentGroupRTIndicator	distanceMa(String indicator)
InstrumentGroupRTIndicator	distanceMa(String name, String indicator)
InstrumentGroupRTIndicator	ema(int periods)
InstrumentGroupRTIndicator	ema(String name, int periods)
InstrumentGroupRTIndicator	ema(String name, String indicator, int periods)
InstrumentGroupRTIndicator	equal(String name, String indicator, @NonNull Number coefficient)
InstrumentGroupRTIndicator	equal(String name, String indicator, @NonNull Number coefficient, String thenIndicator)
InstrumentGroupRTIndicator	equal(String name, String indicator, @NonNull Number coefficient, String thenIndicator, String elseIndicator)
InstrumentGroupRTIndicator	fun(String name, String indicatorA, String indicatorB, BiFunction<Double,Double,Double> bifunction)
InstrumentGroupRTIndicator	gain(String indicator)
InstrumentGroupRTIndicator	gain(String name, String indicator)
InstrumentGroupRTIndicator	gain(String name, String indicator, boolean resetPeriodsOnSustain)
Optional<RTIndicator>	get(String name)
RTIndicator	getExisting(String name)
InstrumentMapRTIndicator	getIndicators()
Instrument	getInstrument()
List<IndicatorNotice>	getNotices()	Wiring diagnostics raised about this group's indicators — e.g. one that needs per-bar OHLCV bound to a ticker stream.
Optional<RTIndicator>	getReadOnly(String name)
RTIndicator	getReadOnlyExisting(String name)
StateStore	getStateStore()	Returns this group's state store — the single store every window listener of this instrument shares — either the injected one or an in-memory store created on first access.
double	getValue(String name)
InstrumentGroupRTIndicator	greatOrEqual(String name, String indicator, @NonNull Number coefficient)
InstrumentGroupRTIndicator	greatOrEqual(String name, String indicator, @NonNull Number coefficient, String thenIndicator)
InstrumentGroupRTIndicator	greatOrEqual(String name, String indicator, @NonNull Number coefficient, String thenIndicator, String elseIndicator)
InstrumentGroupRTIndicator	greatThan(String name, String indicator, @NonNull Number coefficient)
InstrumentGroupRTIndicator	greatThan(String name, String indicator, @NonNull Number coefficient, String thenIndicator)
InstrumentGroupRTIndicator	greatThan(String name, String indicator, @NonNull Number coefficient, String thenIndicator, String elseIndicator)
InstrumentGroupRTIndicator	indicatorBank(com.wualabs.qtsurfer.engine.indicators.cache.IndicatorBank.Session indicatorBankSession)	Routes every indicator registered from here on through a memoization bank, so a batch of runs over one dataset computes each distinct indicator once.
boolean	isBacktestEnabled()
InstrumentGroupRTIndicator	lessOrEqual(String name, String indicator, @NonNull Number coefficient)
InstrumentGroupRTIndicator	lessOrEqual(String name, String indicator, @NonNull Number coefficient, String thenIndicator)
InstrumentGroupRTIndicator	lessOrEqual(String name, String indicator, @NonNull Number coefficient, String thenIndicator, String elseIndicator)
InstrumentGroupRTIndicator	lessThan(String name, String indicator, @NonNull Number coefficient)
InstrumentGroupRTIndicator	lessThan(String name, String indicator, @NonNull Number coefficient, String thenIndicator)
InstrumentGroupRTIndicator	lessThan(String name, String indicator, @NonNull Number coefficient, String thenIndicator, String elseIndicator)
InstrumentGroupRTIndicator	loss(String indicator)
InstrumentGroupRTIndicator	loss(String name, String indicator)
InstrumentGroupRTIndicator	loss(String name, String indicator, boolean resetPeriodsOnSustain)
InstrumentGroupRTIndicator	macd()	MACD (12/26) of this group's default source, registered as "macd".
InstrumentGroupRTIndicator	macd(String name)	MACD (12/26) of this group's default source.
InstrumentGroupRTIndicator	macd(String name, int shortEmaPeriods, int longEmaPeriods)
InstrumentGroupRTIndicator	macd(String name, String indicator, int shortEmaPeriods, int longEmaPeriods)	MACD of another registered indicator.
InstrumentGroupRTIndicator	max(String indicator)
InstrumentGroupRTIndicator	max(String name, String indicator)
InstrumentGroupRTIndicator	min(String indicator)
InstrumentGroupRTIndicator	min(String name, String indicator)
InstrumentGroupRTIndicator	mul(String indicator, Number coefficient)
InstrumentGroupRTIndicator	mul(String indicatorA, String indicatorB)
InstrumentGroupRTIndicator	mul(String name, String indicator, Number coefficient)
InstrumentGroupRTIndicator	mul(String name, String indicatorA, String indicatorB)
InstrumentGroupRTIndicator	notEqual(String name, String indicator, @NonNull Number coefficient)
InstrumentGroupRTIndicator	notEqual(String name, String indicator, @NonNull Number coefficient, String thenIndicator)
InstrumentGroupRTIndicator	notEqual(String name, String indicator, @NonNull Number coefficient, String thenIndicator, String elseIndicator)
InstrumentGroupRTIndicator	percentChange(String indicator)
InstrumentGroupRTIndicator	percentChange(String name, String indicator)
InstrumentGroupRTIndicator	periodCount(String name, String indicator, @NonNull Predicate<Double> predicate)
InstrumentGroupRTIndicator	predicate(String name, String indicator, @NonNull Predicate<Double> predicate)
InstrumentGroupRTIndicator	rateChange(String indicator)
InstrumentGroupRTIndicator	rateChange(String name, String indicator, boolean percent)
RTIndicator	remove(String name)	Unregisters an indicator and hands back the instance that was doing the work.
void	reset()	Resets every indicator in this group in place, mirroring setClockSupplier(Supplier).
void	reset(@NonNull String... indicators)
InstrumentGroupRTIndicator	round(String indicator, int decimals)
InstrumentGroupRTIndicator	round(String name, String indicator, int decimals)
InstrumentGroupRTIndicator	rsi(int periods)
InstrumentGroupRTIndicator	rsi(int periods, boolean sma)
InstrumentGroupRTIndicator	rsi(String name, int periods, boolean sma)
void	setClockSupplier(Supplier<Clock> clockSupplier)
InstrumentGroupRTIndicator	sma(int periods)
InstrumentGroupRTIndicator	sma(String name, int periods)
InstrumentGroupRTIndicator	sma(String name, int periods, boolean discreteMode)
InstrumentGroupRTIndicator	sma(String name, String indicator, int periods)
InstrumentGroupRTIndicator	stateStoreSupplier(@NonNull Supplier<StateStore> stateStoreSupplier)	Replaces the store this group hands to its windows.
InstrumentGroupRTIndicator	stochRsi(int periods)	Stochastic RSI over periods, registered as "stochRsi" + periods.
InstrumentGroupRTIndicator	stochRsi(String name, int periods)	Stochastic RSI — output is [0, 100], hence DisplayHint.PERCENT.
InstrumentGroupRTIndicator	sum(String indicator)
InstrumentGroupRTIndicator	sum(String name, String indicator)
InstrumentGroupRTIndicator	useTickerValue(@NonNull String indicatorName, @NonNull MarketSnapshotValueSource valueSource)	Wraps an existing indicator with a TickerRTIndicator so it receives values from a specific snapshot value source instead of raw numeric updates.
WindowTimeRTIndicatorBuilder	window()	Creates a new WindowTimeRTIndicatorBuilder wired to this group's indicator map.
WindowTimeRTIndicatorBuilder	window(WindowTimeRTIndicator.WindowTime windowTime)
InstrumentGroupRTIndicator	window(@NonNull String indicatorName, int windowTimeSeconds, @NonNull OnChangeRTIndicator.OnChangeListener onChangeListener)
InstrumentGroupRTIndicator	window(@NonNull String indicatorName, @NonNull WindowTimeRTIndicator.WindowTime windowTime, @NonNull OnChangeRTIndicator.OnChangeListener onChangeListener)
InstrumentGroupRTIndicator	window(@NonNull String indicatorName, @NonNull Duration windowTime, @NonNull OnChangeRTIndicator.OnChangeListener onChangeListener)
WindowTimeRTIndicatorBuilder	window(Duration windowTime)

Methods inherited from class AbstractRTIndicator

equals, getDisplayHint, getMeta, getValue, hashCode, hide, isPoison, setValue, toString, 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

Field Details

PREFIX_HIDDEN

public static final String PREFIX_HIDDEN

See Also:

• Constant Field Values

RTINDICATOR_PRICE

public static final String RTINDICATOR_PRICE

See Also:

• Constant Field Values

PREFIX_SMA

public static final String PREFIX_SMA

See Also:

• Constant Field Values

PREFIX_EMA

public static final String PREFIX_EMA

See Also:

• Constant Field Values

PREFIX_RSI

public static final String PREFIX_RSI

See Also:

• Constant Field Values

PREFIX_MACD

public static final String PREFIX_MACD

See Also:

• Constant Field Values

PREFIX_CCI

public static final String PREFIX_CCI

See Also:

• Constant Field Values

PREFIX_STOCH_RSI

public static final String PREFIX_STOCH_RSI

See Also:

• Constant Field Values

PREFIX_BOLLINGER

public static final String PREFIX_BOLLINGER

See Also:

• Constant Field Values

PREFIX_GAIN

public static final String PREFIX_GAIN

See Also:

• Constant Field Values

PREFIX_LOSS

public static final String PREFIX_LOSS

See Also:

• Constant Field Values

PREFIX_WINDOW

public static final String PREFIX_WINDOW

See Also:

• Constant Field Values

PREFIX_DIST

public static final String PREFIX_DIST

See Also:

• Constant Field Values

PREFIX_SUM

public static final String PREFIX_SUM

See Also:

• Constant Field Values

PREFIX_MAX

public static final String PREFIX_MAX

See Also:

• Constant Field Values

PREFIX_MIN

public static final String PREFIX_MIN

See Also:

• Constant Field Values

PREFIX_ADD

public static final String PREFIX_ADD

See Also:

• Constant Field Values

PREFIX_DIFF

public static final String PREFIX_DIFF

See Also:

• Constant Field Values

PREFIX_MUL

public static final String PREFIX_MUL

See Also:

• Constant Field Values

PREFIX_RATE_CHANGE

public static final String PREFIX_RATE_CHANGE

See Also:

• Constant Field Values

PREFIX_CLAMP

public static final String PREFIX_CLAMP

See Also:

• Constant Field Values

PREFIX_ROUND

public static final String PREFIX_ROUND

See Also:

• Constant Field Values

SUBFIX_BOLLINGER_UPPER

public static final String SUBFIX_BOLLINGER_UPPER

See Also:

• Constant Field Values

SUBFIX_BOLLINGER_LOWER

public static final String SUBFIX_BOLLINGER_LOWER

See Also:

• Constant Field Values

SUBFIX_BANDWIDTH

public static final String SUBFIX_BANDWIDTH

Bandwidth name suffix — a structural disambiguator (the band's own name), not a display hint.

See Also:

• Constant Field Values

Constructor Details

InstrumentGroupRTIndicator

public InstrumentGroupRTIndicator(Instrument instrument)

InstrumentGroupRTIndicator

public InstrumentGroupRTIndicator(@NonNull
 @NonNull InstrumentMapRTIndicator indicators)

Method Details

getNotices

public List<IndicatorNotice> getNotices()

Wiring diagnostics raised about this group's indicators — e.g. one that needs per-bar OHLCV bound to a ticker stream. Delegates to the underlying map, which is where the dispatch that detects them happens; exposed here because this is the object a strategy already holds.

Returns:

the notices in the order they were first raised, empty for a correctly wired group

addPrice

public InstrumentGroupRTIndicator addPrice()

sma

public InstrumentGroupRTIndicator sma(int periods)

sma

public InstrumentGroupRTIndicator sma(String name,
 int periods)

sma

public InstrumentGroupRTIndicator sma(String name,
 int periods,
 boolean discreteMode)

ema

public InstrumentGroupRTIndicator ema(int periods)

ema

public InstrumentGroupRTIndicator ema(String name,
 int periods)

rsi

public InstrumentGroupRTIndicator rsi(int periods)

rsi

public InstrumentGroupRTIndicator rsi(int periods,
 boolean sma)

rsi

public InstrumentGroupRTIndicator rsi(String name,
 int periods,
 boolean sma)

macd

public InstrumentGroupRTIndicator macd()

MACD (12/26) of this group's default source, registered as "macd".

macd

public InstrumentGroupRTIndicator macd(String name)

MACD (12/26) of this group's default source.

macd

public InstrumentGroupRTIndicator macd(String name,
 int shortEmaPeriods,
 int longEmaPeriods)

macd

public InstrumentGroupRTIndicator macd(String name,
 String indicator,
 int shortEmaPeriods,
 int longEmaPeriods)

MACD of another registered indicator.

cci

public InstrumentGroupRTIndicator cci(int periods)

CCI over periods, registered as "cci" + periods.

cci

public InstrumentGroupRTIndicator cci(String name,
 int periods)

stochRsi

public InstrumentGroupRTIndicator stochRsi(int periods)

Stochastic RSI over periods, registered as "stochRsi" + periods.

stochRsi

public InstrumentGroupRTIndicator stochRsi(String name,
 int periods)

Stochastic RSI — output is [0, 100], hence DisplayHint.PERCENT.

bollinger

public InstrumentGroupRTIndicator bollinger()

bollinger

public InstrumentGroupRTIndicator bollinger(int periods)

bollinger

public InstrumentGroupRTIndicator bollinger(int periods,
 Number k)

bollinger

public InstrumentGroupRTIndicator bollinger(String name,
 int periods,
 Number k)

Adds a Bollinger Bands indicator with its upper and lower bands as separate named entries. The middle band is registered under name, upper under name + "Upper", and lower under name + "Lower".

Parameters:

name - base name for the Bollinger indicator entries

periods - number of periods for the SMA/standard deviation calculation

k - multiplier for the standard deviation bands

Returns:

this builder for chaining

bollingerBandwidth

public InstrumentGroupRTIndicator bollingerBandwidth(String bollingerIndicatorName)

Adds a Bollinger BandWidth indicator derived from an existing Bollinger indicator. If the named indicator is not found or is not a BollingerBandsRTIndicator, a new default Bollinger indicator is auto-created as a hidden (prefixed with "_") entry. The bandwidth indicator is registered as bollingerIndicatorName + "BW" and carries a DisplayHint.PERCENT hint.

Parameters:

bollingerIndicatorName - name of the existing Bollinger indicator to derive from

Returns:

this builder for chaining

gain

public InstrumentGroupRTIndicator gain(String indicator)

gain

public InstrumentGroupRTIndicator gain(String name,
 String indicator)

gain

public InstrumentGroupRTIndicator gain(String name,
 String indicator,
 boolean resetPeriodsOnSustain)

loss

public InstrumentGroupRTIndicator loss(String indicator)

loss

public InstrumentGroupRTIndicator loss(String name,
 String indicator)

loss

public InstrumentGroupRTIndicator loss(String name,
 String indicator,
 boolean resetPeriodsOnSustain)

max

public InstrumentGroupRTIndicator max(String indicator)

max

public InstrumentGroupRTIndicator max(String name,
 String indicator)

min

public InstrumentGroupRTIndicator min(String indicator)

min

public InstrumentGroupRTIndicator min(String name,
 String indicator)

sum

public InstrumentGroupRTIndicator sum(String indicator)

sum

public InstrumentGroupRTIndicator sum(String name,
 String indicator)

distanceMa

public InstrumentGroupRTIndicator distanceMa(String indicator)

distanceMa

public InstrumentGroupRTIndicator distanceMa(String name,
 String indicator)

distance

public InstrumentGroupRTIndicator distance(String indicator,
 String indicatorBase)

distance

public InstrumentGroupRTIndicator distance(String name,
 String indicator,
 String indicatorBase)

percentChange

public InstrumentGroupRTIndicator percentChange(String indicator)

percentChange

public InstrumentGroupRTIndicator percentChange(String name,
 String indicator)

rateChange

public InstrumentGroupRTIndicator rateChange(String indicator)

rateChange

public InstrumentGroupRTIndicator rateChange(String name,
 String indicator,
 boolean percent)

window

public InstrumentGroupRTIndicator window(@NonNull
 @NonNull String indicatorName,
 int windowTimeSeconds,
 @NonNull
 @NonNull OnChangeRTIndicator.OnChangeListener onChangeListener)

window

public InstrumentGroupRTIndicator window(@NonNull
 @NonNull String indicatorName,
 @NonNull
 @NonNull WindowTimeRTIndicator.WindowTime windowTime,
 @NonNull
 @NonNull OnChangeRTIndicator.OnChangeListener onChangeListener)

window

public InstrumentGroupRTIndicator window(@NonNull
 @NonNull String indicatorName,
 @NonNull
 @NonNull Duration windowTime,
 @NonNull
 @NonNull OnChangeRTIndicator.OnChangeListener onChangeListener)

sma

public InstrumentGroupRTIndicator sma(String name,
 String indicator,
 int periods)

ema

public InstrumentGroupRTIndicator ema(String name,
 String indicator,
 int periods)

decorate

public InstrumentGroupRTIndicator decorate(String name,
 String indicator,
 @NonNull
 @NonNull UnaryOperator<RTIndicator> op)

Wraps an existing indicator with a unary operator transformation and registers the result. The source indicator is accessed as read-only, so the original is not mutated by updates.

Parameters:

name - name for the new decorated indicator

indicator - name of the existing indicator to wrap

op - operator that receives the read-only indicator and returns a new one

Returns:

this builder for chaining

equal

public InstrumentGroupRTIndicator equal(String name,
 String indicator,
 @NonNull
 @NonNull Number coefficient)

notEqual

public InstrumentGroupRTIndicator notEqual(String name,
 String indicator,
 @NonNull
 @NonNull Number coefficient)

greatOrEqual

public InstrumentGroupRTIndicator greatOrEqual(String name,
 String indicator,
 @NonNull
 @NonNull Number coefficient)

greatThan

public InstrumentGroupRTIndicator greatThan(String name,
 String indicator,
 @NonNull
 @NonNull Number coefficient)

lessOrEqual

public InstrumentGroupRTIndicator lessOrEqual(String name,
 String indicator,
 @NonNull
 @NonNull Number coefficient)

lessThan

public InstrumentGroupRTIndicator lessThan(String name,
 String indicator,
 @NonNull
 @NonNull Number coefficient)

predicate

public InstrumentGroupRTIndicator predicate(String name,
 String indicator,
 @NonNull
 @NonNull Predicate<Double> predicate)

periodCount

public InstrumentGroupRTIndicator periodCount(String name,
 String indicator,
 @NonNull
 @NonNull Predicate<Double> predicate)

equal

public InstrumentGroupRTIndicator equal(String name,
 String indicator,
 @NonNull
 @NonNull Number coefficient,
 String thenIndicator)

equal

public InstrumentGroupRTIndicator equal(String name,
 String indicator,
 @NonNull
 @NonNull Number coefficient,
 String thenIndicator,
 String elseIndicator)

notEqual

public InstrumentGroupRTIndicator notEqual(String name,
 String indicator,
 @NonNull
 @NonNull Number coefficient,
 String thenIndicator)

notEqual

public InstrumentGroupRTIndicator notEqual(String name,
 String indicator,
 @NonNull
 @NonNull Number coefficient,
 String thenIndicator,
 String elseIndicator)

greatOrEqual

public InstrumentGroupRTIndicator greatOrEqual(String name,
 String indicator,
 @NonNull
 @NonNull Number coefficient,
 String thenIndicator)

greatOrEqual

public InstrumentGroupRTIndicator greatOrEqual(String name,
 String indicator,
 @NonNull
 @NonNull Number coefficient,
 String thenIndicator,
 String elseIndicator)

greatThan

public InstrumentGroupRTIndicator greatThan(String name,
 String indicator,
 @NonNull
 @NonNull Number coefficient,
 String thenIndicator)

greatThan

public InstrumentGroupRTIndicator greatThan(String name,
 String indicator,
 @NonNull
 @NonNull Number coefficient,
 String thenIndicator,
 String elseIndicator)

lessOrEqual

public InstrumentGroupRTIndicator lessOrEqual(String name,
 String indicator,
 @NonNull
 @NonNull Number coefficient,
 String thenIndicator)

lessOrEqual

public InstrumentGroupRTIndicator lessOrEqual(String name,
 String indicator,
 @NonNull
 @NonNull Number coefficient,
 String thenIndicator,
 String elseIndicator)

lessThan

public InstrumentGroupRTIndicator lessThan(String name,
 String indicator,
 @NonNull
 @NonNull Number coefficient,
 String thenIndicator)

lessThan

public InstrumentGroupRTIndicator lessThan(String name,
 String indicator,
 @NonNull
 @NonNull Number coefficient,
 String thenIndicator,
 String elseIndicator)

conditional

public InstrumentGroupRTIndicator conditional(String name,
 String indicator,
 @NonNull
 @NonNull Predicate<RTIndicator> predicate,
 @NonNull
 @NonNull RTIndicator thenIndicator)

conditional

public InstrumentGroupRTIndicator conditional(String name,
 String indicator,
 @NonNull
 @NonNull Predicate<RTIndicator> predicate,
 @NonNull
 @NonNull RTIndicator thenIndicator,
 RTIndicator elseIndicator)

clamp

public InstrumentGroupRTIndicator clamp(String indicator,
 Predicate<Double> clampPredicate,
 Number clampValue)

clamp

public InstrumentGroupRTIndicator clamp(String name,
 String indicator,
 Predicate<Double> clampPredicate,
 Number clampValue)

clamp

public InstrumentGroupRTIndicator clamp(String indicator,
 Number minRange,
 Number maxRange)

clamp

public InstrumentGroupRTIndicator clamp(String name,
 String indicator,
 Number minRange,
 Number maxRange)

round

public InstrumentGroupRTIndicator round(String indicator,
 int decimals)

round

public InstrumentGroupRTIndicator round(String name,
 String indicator,
 int decimals)

add

public InstrumentGroupRTIndicator add(String indicatorA,
 String indicatorB)

add

public InstrumentGroupRTIndicator add(String name,
 String indicatorA,
 String indicatorB)

diff

public InstrumentGroupRTIndicator diff(String indicatorA,
 String indicatorB)

diff

public InstrumentGroupRTIndicator diff(String name,
 String indicatorA,
 String indicatorB)

mul

public InstrumentGroupRTIndicator mul(String indicatorA,
 String indicatorB)

mul

public InstrumentGroupRTIndicator mul(String name,
 String indicatorA,
 String indicatorB)

fun

public InstrumentGroupRTIndicator fun(String name,
 String indicatorA,
 String indicatorB,
 BiFunction<Double,Double,Double> bifunction)

mul

public InstrumentGroupRTIndicator mul(String indicator,
 Number coefficient)

mul

public InstrumentGroupRTIndicator mul(String name,
 String indicator,
 Number coefficient)

getStateStore

public StateStore getStateStore()

Returns this group's state store — the single store every window listener of this instrument shares — either the injected one or an in-memory store created on first access. A strategy overrides the whole topology by injecting its own supplier via stateStoreSupplier(Supplier), which is how state reaches a persistent backend .

Because the store is shared, keys are a per-instrument namespace: two windows that use the same key see each other's value. Name keys accordingly.

Calling this materializes the store. Windows call it only when they have something to write , so a group nobody listens to never creates one.

Returns:

the state store for this instrument (never null)

stateStoreSupplier

public InstrumentGroupRTIndicator stateStoreSupplier(@NonNull
 @NonNull Supplier<StateStore> stateStoreSupplier)

Replaces the store this group hands to its windows. Windows resolve through the group at event time rather than capturing a store when they are built, so this may be set before or after setupIndicators — what matters is that it lands before the first window boundary writes.

Parameters:

stateStoreSupplier - supplies the store for this instrument

Returns:

this builder for chaining

indicatorBank

public InstrumentGroupRTIndicator indicatorBank(com.wualabs.qtsurfer.engine.indicators.cache.IndicatorBank.Session indicatorBankSession)

Routes every indicator registered from here on through a memoization bank, so a batch of runs over one dataset computes each distinct indicator once.

Must be set before the indicators are built. Interception happens as each one is registered, which is the only moment a replacement can still be picked up by the derived indicators that reference it — swapping afterwards would leave them reading an instance nothing updates any more.

Parameters:

indicatorBankSession - this run's view of the bank, or null to compute everything live (the default, and what every non-sweep caller gets)

Returns:

this builder for chaining

add

public InstrumentGroupRTIndicator add(@NonNull
 @NonNull String name,
 @NonNull
 @NonNull RTIndicator indicator)

add

public InstrumentGroupRTIndicator add(@NonNull
 @NonNull String name,
 @NonNull
 @NonNull RTIndicator indicator,
 @NonNull
 @NonNull DisplayHint displayHint)

Registers an indicator under a clean name, carrying its DisplayHint as descriptor metadata instead of smuggling it into the name. Replaces the old add(name + "%", indicator) convention: the registered name is now exactly name, so getExisting(name) finds it, and the charting layer reads the hint from the indicator.

Parameters:

name - the clean registration name (also the lookup name)

indicator - the indicator to register

displayHint - how its value should be presented

Returns:

this builder for chaining

add

public InstrumentGroupRTIndicator add(@NonNull
 @NonNull String name,
 @NonNull
 @NonNull MarketSnapshotValueSource valueSource)

add

public InstrumentGroupRTIndicator add(@NonNull
 @NonNull String name,
 @NonNull
 @NonNull MarketSnapshotValueSource valueSource,
 RTIndicator indicator)

useTickerValue

public InstrumentGroupRTIndicator useTickerValue(@NonNull
 @NonNull String indicatorName,
 @NonNull
 @NonNull MarketSnapshotValueSource valueSource)

Wraps an existing indicator with a TickerRTIndicator so it receives values from a specific snapshot value source instead of raw numeric updates. If the indicator already consumes a snapshot directly (implements RichRTIndicator), the operation is skipped with a warning. The existing indicator is removed and re-added wrapped with the new value source.

Parameters:

indicatorName - name of the existing indicator to wrap

valueSource - the snapshot field to use as the value source

Returns:

this builder for chaining

addWindow

public void addWindow(WindowTimeRTIndicator window)

getValue

public double getValue(String name)

getReadOnlyExisting

public RTIndicator getReadOnlyExisting(String name)

getReadOnly

public Optional<RTIndicator> getReadOnly(String name)

getExisting

public RTIndicator getExisting(String name)

get

public Optional<RTIndicator> get(String name)

remove

public RTIndicator remove(String name)

Unregisters an indicator and hands back the instance that was doing the work.

When memoization is active the registered object is a wrapper, and what comes back here is the indicator inside it, with any recording it had started dropped: a series that stops where the indicator left the group describes nothing a later run will replay.

Parameters:

name - the registered name

Returns:

the indicator, or null if nothing was registered under that name

reset

public void reset(@NonNull
 @NonNull String... indicators)

clear

public void clear()

window

public WindowTimeRTIndicatorBuilder window(WindowTimeRTIndicator.WindowTime windowTime)

window

public WindowTimeRTIndicatorBuilder window(Duration windowTime)

window

public WindowTimeRTIndicatorBuilder window()

Creates a new WindowTimeRTIndicatorBuilder wired to this group's indicator map. Built windows are auto-registered: unnamed windows get an auto-generated hidden name via addWindow(WindowTimeRTIndicator), named windows are added under their own name. Every window inherits this group's state store, so listeners of one instrument share one state namespace.

Returns:

a new builder for configuring and building a WindowTimeRTIndicator

setClockSupplier

public void setClockSupplier(Supplier<Clock> clockSupplier)

Specified by:

setClockSupplier in interface ClockAware

reset

public void reset()

Resets every indicator in this group in place, mirroring setClockSupplier(Supplier). Distinct from the selective reset(String...) overload: this no-arg override honors the base Resettable.reset() contract for the whole group. Instruments are kept (see clear()); only rolling state is zeroed.

Specified by:

reset in interface Resettable

Overrides:

reset in class AbstractRTIndicator

backtestEnabled

public InstrumentGroupRTIndicator backtestEnabled(boolean backtestEnabled)

Enables or disables backtest mode for this group and its underlying indicator map. When enabled, ticker timestamps are used to set a fixed clock for time-aware indicators.

Parameters:

backtestEnabled - true to enable backtest mode

Returns:

this builder for chaining

getInstrument

public Instrument getInstrument()

getIndicators

public InstrumentMapRTIndicator getIndicators()

isBacktestEnabled

public boolean isBacktestEnabled()