indicator

Jul 24, 2023

Changes in this version

+ func Min(x, y int) int

Jun 30, 2023

Changes in this version

type KLineStream

+ func (s *KLineStream) BackFill(kLines []types.KLine)

type PriceStream

+ func Volumes(source KLineSubscription) *PriceStream

+ func (s *PriceStream) AddSubscriber(f func(v float64))

Jun 15, 2023

Changes in this version

+ const MaxNumOfKLines

+ type ATRPStream struct

+ func ATRP2(source KLineSubscription, window int) *ATRPStream

+ type ATRStream struct

+ func ATR2(source KLineSubscription, window int) *ATRStream

+ type BOLLStream struct

+ DownBand *Float64Series

+ SMA *SMAStream

+ StdDev *StdDevStream

+ UpBand *Float64Series

+ func BOLL2(source Float64Source, window int, k float64) *BOLLStream

+ func (s *BOLLStream) Calculate(v float64) float64

+ type CMAStream struct

+ func CMA2(source Float64Source) *CMAStream

+ func (s *CMAStream) Calculate(x float64) float64

+ func (s *CMAStream) Truncate()

+ type CrossStream struct

+ func Cross(a, b Float64Source) *CrossStream

+ type CrossType float64

+ const CrossOver

+ const CrossUnder

+ type EWMAStream struct

+ func EWMA2(source Float64Source, window int) *EWMAStream

+ func (s *EWMAStream) Calculate(v float64) float64

+ type Float64Calculator interface

+ Calculate func(x float64) float64

+ PushAndEmit func(x float64)

+ type Float64Series struct

+ func NewFloat64Series(v ...float64) *Float64Series

+ func (f *Float64Series) Bind(source Float64Source, target Float64Calculator)

+ func (f *Float64Series) Index(i int) float64

+ func (f *Float64Series) Last(i int) float64

+ func (f *Float64Series) Length() int

+ func (f *Float64Series) PushAndEmit(x float64)

+ func (f *Float64Series) Slice() floats.Slice

+ func (f *Float64Series) Subscribe(source Float64Source, c func(x float64))

+ type Float64Source interface

+ OnUpdate func(f func(v float64))

+ type Float64Subscription interface

+ AddSubscriber func(f func(v float64))

+ type Float64Truncator interface

+ Truncate func()

+ type Float64Updater struct

+ func (f *Float64Updater) EmitUpdate(v float64)

+ func (f *Float64Updater) OnUpdate(cb func(v float64))

+ type KLineStream struct

+ func KLines(source types.Stream, symbol string, interval types.Interval) *KLineStream

+ func (s *KLineStream) AddSubscriber(f func(k types.KLine))

+ func (s *KLineStream) EmitUpdate(k types.KLine)

+ func (s *KLineStream) Last(i int) *types.KLine

+ func (s *KLineStream) Length() int

+ func (s *KLineStream) OnUpdate(cb func(k types.KLine))

+ type KLineSubscription interface

+ AddSubscriber func(f func(k types.KLine))

+ Last func(i int) *types.KLine

+ Length func() int

+ type MACDLegacy struct

+ EndTime time.Time

+ Histogram floats.Slice

+ Values floats.Slice

+ func (inc *MACDLegacy) EmitUpdate(macd float64, signal float64, histogram float64)

+ func (inc *MACDLegacy) Last(i int) float64

+ func (inc *MACDLegacy) Length() int

+ func (inc *MACDLegacy) MACD() types.SeriesExtend

+ func (inc *MACDLegacy) OnUpdate(cb func(macd float64, signal float64, histogram float64))

+ func (inc *MACDLegacy) PushK(k types.KLine)

+ func (inc *MACDLegacy) Singals() types.SeriesExtend

+ func (inc *MACDLegacy) Update(x float64)

+ type MACDStream struct

+ FastEWMA *EWMAStream

+ Histogram *SubtractStream

+ Signal *EWMAStream

+ SlowEWMA *EWMAStream

+ func MACD2(source Float64Source, shortWindow, longWindow, signalWindow int) *MACDStream

+ type MultiplyStream struct

+ func Multiply(a, b Float64Source) *MultiplyStream

+ type PivotHighStream struct

+ func PivotHigh2(source Float64Source, window, rightWindow int) *PivotHighStream

+ type PivotLowStream struct

+ func PivotLow2(source Float64Source, window, rightWindow int) *PivotLowStream

+ type PriceStream struct

+ func ClosePrices(source KLineSubscription) *PriceStream

+ func HighPrices(source KLineSubscription) *PriceStream

+ func LowPrices(source KLineSubscription) *PriceStream

+ func OpenPrices(source KLineSubscription) *PriceStream

+ func Price(source KLineSubscription, mapper KLineValueMapper) *PriceStream

+ func (s *PriceStream) PushAndEmit(v float64)

+ type RMAStream struct

+ Adjust bool

+ func RMA2(source Float64Source, window int, adjust bool) *RMAStream

+ func (s *RMAStream) Calculate(x float64) float64

+ func (s *RMAStream) Truncate()

+ type RSIStream struct

+ func RSI2(source Float64Source, window int) *RSIStream

+ func (s *RSIStream) Calculate(_ float64) float64

+ type SMAStream struct

+ func SMA2(source Float64Source, window int) *SMAStream

+ func (s *SMAStream) Calculate(v float64) float64

+ func (s *SMAStream) Truncate()

+ type StdDevStream struct

+ func StdDev2(source Float64Source, window int) *StdDevStream

+ func (s *StdDevStream) Calculate(x float64) float64

+ type StochStream struct

+ D floats.Slice

+ K floats.Slice

+ func Stoch2(source KLineSubscription, window, dPeriod int) *StochStream

+ func (S *StochStream) EmitUpdate(k float64, d float64)

+ func (S *StochStream) OnUpdate(cb func(k float64, d float64))

+ type SubtractStream struct

+ func Subtract(a, b Float64Source) *SubtractStream

+ type TRStream struct

+ func TR2(source KLineSubscription) *TRStream

Mar 13, 2023

Changes in this version

+ type KlingerOscillator struct

+ Fast types.UpdatableSeries

+ Slow types.UpdatableSeries

+ VF VolumeForce

+ func (inc *KlingerOscillator) BindK(target KLineClosedEmitter, symbol string, interval types.Interval)

+ func (inc *KlingerOscillator) EmitUpdate(value float64)

+ func (inc *KlingerOscillator) Index(i int) float64

+ func (inc *KlingerOscillator) Last() float64

+ func (inc *KlingerOscillator) Length() int

+ func (inc *KlingerOscillator) OnUpdate(cb func(value float64))

+ func (inc *KlingerOscillator) PushK(k types.KLine)

+ func (inc *KlingerOscillator) Update(high, low, cloze, volume float64)

+ type PSAR struct

+ AF float64

+ EP float64

+ EndTime time.Time

+ Falling bool

+ High *types.Queue

+ Low *types.Queue

+ UpdateCallbacks []func(value float64)

+ Values floats.Slice

+ func (inc *PSAR) BindK(target KLineClosedEmitter, symbol string, interval types.Interval)

+ func (inc *PSAR) EmitUpdate(value float64)

+ func (inc *PSAR) Last() float64

+ func (inc *PSAR) Length() int

+ func (inc *PSAR) OnUpdate(cb func(value float64))

+ func (inc *PSAR) PushK(k types.KLine)

+ func (inc *PSAR) Update(high, low float64)

+ type PivotSupertrend struct

+ ATRMultiplier float64

+ AverageTrueRange *ATR

+ EndTime time.Time

+ PivotHigh *PivotHigh

+ PivotLow *PivotLow

+ PivotWindow int

+ UpdateCallbacks []func(value float64)

+ func (inc *PivotSupertrend) BindK(target KLineClosedEmitter, symbol string, interval types.Interval)

+ func (inc *PivotSupertrend) Direction() types.Direction

+ func (inc *PivotSupertrend) EmitUpdate(value float64)

+ func (inc *PivotSupertrend) GetSignal() types.Direction

+ func (inc *PivotSupertrend) Index(i int) float64

+ func (inc *PivotSupertrend) Last() float64

+ func (inc *PivotSupertrend) LastSupertrendResistance() float64

+ func (inc *PivotSupertrend) LastSupertrendSupport() float64

+ func (inc *PivotSupertrend) Length() int

+ func (inc *PivotSupertrend) LoadK(allKLines []types.KLine)

+ func (inc *PivotSupertrend) OnUpdate(cb func(value float64))

+ func (inc *PivotSupertrend) PushK(k types.KLine)

+ func (inc *PivotSupertrend) Update(highPrice, lowPrice, closePrice float64)

type Supertrend

+ func (inc *Supertrend) Direction() types.Direction

+ func (inc *Supertrend) LastSupertrendResistance() float64

+ func (inc *Supertrend) LastSupertrendSupport() float64

+ type TSI struct

+ Apcds *EWMA

+ Apcs *EWMA

+ FastWindow int

+ Pcds *EWMA

+ Pcs *EWMA

+ PrevValue float64

+ SlowWindow int

+ Values floats.Slice

+ func (inc *TSI) BindK(target KLineClosedEmitter, symbol string, interval types.Interval)

+ func (inc *TSI) EmitUpdate(value float64)

+ func (inc *TSI) Index(i int) float64

+ func (inc *TSI) Last() float64

+ func (inc *TSI) Length() int

+ func (inc *TSI) OnUpdate(cb func(value float64))

+ func (inc *TSI) PushK(k types.KLine)

+ func (inc *TSI) Update(value float64)

+ type UtBotAlert struct

+ AverageTrueRange *ATR

+ EndTime time.Time

+ KeyValue float64

+ UpdateCallbacks []func(value types.Direction)

+ Values []types.Direction

+ func NewUtBotAlert(iw types.IntervalWindow, keyValue float64) *UtBotAlert

+ func (inc *UtBotAlert) BindK(target KLineClosedEmitter, symbol string, interval types.Interval)

+ func (inc *UtBotAlert) EmitUpdate(value types.Direction)

+ func (inc *UtBotAlert) GetSignal() types.Direction

+ func (inc *UtBotAlert) Index(i int) types.Direction

+ func (inc *UtBotAlert) Last() types.Direction

+ func (inc *UtBotAlert) Length() int

+ func (inc *UtBotAlert) LoadK(allKLines []types.KLine)

+ func (inc *UtBotAlert) OnUpdate(cb func(value types.Direction))

+ func (inc *UtBotAlert) PushK(k types.KLine)

+ func (inc *UtBotAlert) Update(highPrice, lowPrice, closePrice float64)

+ type VolumeForce struct

+ Value float64

+ func (inc *VolumeForce) Update(high, low, cloze, volume float64)

+ type VolumeProfile struct

+ Delta float64

+ func (inc *VolumeProfile) PointOfControlAboveEqual(price float64, limit ...float64) (resultPrice float64, vol float64)

+ func (inc *VolumeProfile) PointOfControlBelowEqual(price float64, limit ...float64) (resultPrice float64, vol float64)

+ func (inc *VolumeProfile) Update(price, volume float64, timestamp types.Time)

Dec 23, 2022

Changes in this version

+ const MaxNumOfATR

+ const MaxNumOfATRTruncateSize

+ const MaxNumOfRMA

+ const MaxNumOfRMATruncateSize

+ const MaxNumOfStdev

+ const MaxNumOfStdevTruncateSize

+ type LinReg struct

+ EndTime time.Time

+ UpdateCallbacks []func(value float64)

+ ValueRatios floats.Slice

+ Values floats.Slice

+ func (lr *LinReg) BindK(target KLineClosedEmitter, symbol string, interval types.Interval)

+ func (lr *LinReg) EmitUpdate(value float64)

+ func (lr *LinReg) Index(i int) float64

+ func (lr *LinReg) IndexRatio(i int) float64

+ func (lr *LinReg) Last() float64

+ func (lr *LinReg) LastRatio() float64

+ func (lr *LinReg) Length() int

+ func (lr *LinReg) LengthRatio() int

+ func (lr *LinReg) LoadK(allKLines []types.KLine)

+ func (lr *LinReg) OnUpdate(cb func(value float64))

+ func (lr *LinReg) PushK(k types.KLine)

+ func (lr *LinReg) Update(kline types.KLine)

Sep 20, 2022

Changes in this version

+ type MACDConfig struct

+ LongPeriod int

+ ShortPeriod int

Sep 6, 2022

Changes in this version

+ type GHFilter struct

+ UpdateCallbacks []func(value float64)

+ Values floats.Slice

+ func (inc *GHFilter) EmitUpdate(value float64)

+ func (inc *GHFilter) Index(i int) float64

+ func (inc *GHFilter) Last() float64

+ func (inc *GHFilter) Length() int

+ func (inc *GHFilter) OnUpdate(cb func(value float64))

+ func (inc *GHFilter) PushK(k types.KLine)

+ func (inc *GHFilter) Update(value float64)

+ type KalmanFilter struct

+ AdditionalSmoothWindow uint

+ UpdateCallbacks []func(value float64)

+ Values floats.Slice

+ func (inc *KalmanFilter) EmitUpdate(value float64)

+ func (inc *KalmanFilter) Index(i int) float64

+ func (inc *KalmanFilter) Last() float64

+ func (inc *KalmanFilter) Length() int

+ func (inc *KalmanFilter) OnUpdate(cb func(value float64))

+ func (inc *KalmanFilter) PushK(k types.KLine)

+ func (inc *KalmanFilter) Update(value float64)

Sep 4, 2022

Changes in this version

+ type GMA struct

+ SMA *SMA

+ UpdateCallbacks []func(value float64)

+ func (inc *GMA) BindK(target KLineClosedEmitter, symbol string, interval types.Interval)

+ func (inc *GMA) Clone() (out *GMA)

+ func (inc *GMA) EmitUpdate(value float64)

+ func (inc *GMA) Index(i int) float64

+ func (inc *GMA) Last() float64

+ func (inc *GMA) Length() int

+ func (inc *GMA) LoadK(allKLines []types.KLine)

+ func (inc *GMA) OnUpdate(cb func(value float64))

+ func (inc *GMA) PushK(k types.KLine)

+ func (inc *GMA) TestUpdate(value float64) *GMA

+ func (inc *GMA) Update(value float64)

+ type PivotHigh struct

+ EndTime time.Time

+ Highs floats.Slice

+ Values floats.Slice

+ func (inc *PivotHigh) EmitUpdate(value float64)

+ func (inc *PivotHigh) Last() float64

+ func (inc *PivotHigh) Length() int

+ func (inc *PivotHigh) OnUpdate(cb func(value float64))

+ func (inc *PivotHigh) PushK(k types.KLine)

+ func (inc *PivotHigh) Update(value float64)

type VWMA

+ func (inc *VWMA) PushK(k types.KLine)

+ type WeightedDrift struct

+ LastValue float64

+ MA types.UpdatableSeriesExtend

+ UpdateCallbacks []func(value float64)

+ Values floats.Slice

+ Weight *types.Queue

+ func (inc *WeightedDrift) Bind(updater KLineWindowUpdater)

+ func (inc *WeightedDrift) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *WeightedDrift) Clone() (out *WeightedDrift)

+ func (inc *WeightedDrift) EmitUpdate(value float64)

+ func (inc *WeightedDrift) Index(i int) float64

+ func (inc *WeightedDrift) Last() float64

+ func (inc *WeightedDrift) Length() int

+ func (inc *WeightedDrift) OnUpdate(cb func(value float64))

+ func (inc *WeightedDrift) PushK(k types.KLine)

+ func (inc *WeightedDrift) TestUpdate(value float64, weight float64) *WeightedDrift

+ func (inc *WeightedDrift) Update(value float64, weight float64)

+ func (inc *WeightedDrift) ZeroPoint() float64

Aug 18, 2022

Changes in this version

type Supertrend

+ func (inc *Supertrend) BindK(target KLineClosedEmitter, symbol string, interval types.Interval)

+ func (inc *Supertrend) LoadK(allKLines []types.KLine)

Jul 29, 2022

Changes in this version

type ATR

+ func (inc *ATR) Clone() *ATR

+ func (inc *ATR) TestUpdate(high, low, cloze float64) *ATR

type BOLL

+ func (inc *BOLL) BindK(target KLineClosedEmitter, symbol string, interval types.Interval)

+ func (inc *BOLL) LoadK(allKLines []types.KLine)

type DEMA

+ func (inc *DEMA) Clone() *DEMA

+ func (inc *DEMA) TestUpdate(value float64) *DEMA

type Drift

+ MA types.UpdatableSeriesExtend

+ func (inc *Drift) Clone() (out *Drift)

+ func (inc *Drift) TestUpdate(value float64) *Drift

+ func (inc *Drift) ZeroPoint() float64

type EWMA

+ func (inc *EWMA) Clone() *EWMA

+ func (inc *EWMA) TestUpdate(value float64) *EWMA

+ type FisherTransform struct

+ UpdateCallbacks []func(value float64)

+ Values types.Float64Slice

+ func (inc *FisherTransform) Clone() types.UpdatableSeriesExtend

+ func (inc *FisherTransform) EmitUpdate(value float64)

+ func (inc *FisherTransform) Index(i int) float64

+ func (inc *FisherTransform) Last() float64

+ func (inc *FisherTransform) Length() int

+ func (inc *FisherTransform) OnUpdate(cb func(value float64))

+ func (inc *FisherTransform) Update(value float64)

type HULL

+ func (inc *HULL) PushK(k types.KLine)

+ type Low struct

+ EndTime time.Time

+ Values types.Float64Slice

+ func (inc *Low) EmitUpdate(value float64)

+ func (inc *Low) OnUpdate(cb func(value float64))

+ func (inc *Low) PushK(k types.KLine)

+ func (inc *Low) Update(value float64)

type MACD

+ func (inc *MACD) Length() int

+ type PivotLow struct

+ EndTime time.Time

+ Lows types.Float64Slice

+ Values types.Float64Slice

+ func (inc *PivotLow) EmitUpdate(value float64)

+ func (inc *PivotLow) Last() float64

+ func (inc *PivotLow) Length() int

+ func (inc *PivotLow) OnUpdate(cb func(value float64))

+ func (inc *PivotLow) PushK(k types.KLine)

+ func (inc *PivotLow) Update(value float64)

type RMA

+ func (inc *RMA) Clone() types.UpdatableSeriesExtend

type SMA

+ func (inc *SMA) Clone() types.UpdatableSeriesExtend

+ func (inc *SMA) LoadK(allKLines []types.KLine)

+ type Simple interface

+ Last func() float64

+ OnUpdate func(f func(value float64))

type TILL

+ func (inc *TILL) BindK(target KLineClosedEmitter, symbol string, interval types.Interval)

+ func (inc *TILL) LoadK(allKLines []types.KLine)

Jul 19, 2022

Changes in this version

type AD

+ func (inc *AD) CalculateAndUpdate(kLines []types.KLine)

type ALMA

+ func (inc *ALMA) CalculateAndUpdate(allKLines []types.KLine)

type ATR

+ func (inc *ATR) PushK(k types.KLine)

+ type ATRP struct

+ EndTime time.Time

+ PercentageVolatility types.Float64Slice

+ PreviousClose float64

+ RMA *RMA

+ UpdateCallbacks []func(value float64)

+ func (inc *ATRP) Bind(updater KLineWindowUpdater)

+ func (inc *ATRP) CalculateAndUpdate(kLines []types.KLine)

+ func (inc *ATRP) EmitUpdate(value float64)

+ func (inc *ATRP) Index(i int) float64

+ func (inc *ATRP) Last() float64

+ func (inc *ATRP) Length() int

+ func (inc *ATRP) OnUpdate(cb func(value float64))

+ func (inc *ATRP) PushK(k types.KLine)

+ func (inc *ATRP) Update(high, low, cloze float64)

type BOLL

+ func (inc *BOLL) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *BOLL) PushK(k types.KLine)

type CA

+ func (inc *CA) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *CA) PushK(k types.KLine)

type CCI

+ func (inc *CCI) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *CCI) PushK(k types.KLine)

type DEMA

+ func (inc *DEMA) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *DEMA) PushK(k types.KLine)

type DMI

+ func (inc *DMI) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *DMI) PushK(k types.KLine)

type Drift

+ func (inc *Drift) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *Drift) PushK(k types.KLine)

type EMV

+ func (inc *EMV) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *EMV) PushK(k types.KLine)

type EWMA

+ func (inc *EWMA) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *EWMA) PushK(k types.KLine)

type HULL

+ func (inc *HULL) CalculateAndUpdate(allKLines []types.KLine)

+ type KLineCalculateUpdater interface

+ CalculateAndUpdate func(allKLines []types.KLine)

+ type KLineClosedBinder interface

+ BindK func(target KLineClosedEmitter, symbol string, interval types.Interval)

+ type KLineClosedEmitter interface

+ OnKLineClosed func(func(k types.KLine))

+ type KLineLoader interface

+ LoadK func(allKLines []types.KLine)

+ type KLinePusher interface

+ PushK func(k types.KLine)

type MACD

+ func (inc *MACD) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *MACD) Last() float64

+ func (inc *MACD) PushK(k types.KLine)

type OBV

+ func (inc *OBV) CalculateAndUpdate(kLines []types.KLine)

+ func (inc *OBV) PushK(k types.KLine)

type Pivot

+ func (inc *Pivot) CalculateAndUpdate(klines []types.KLine)

type RMA

+ func (inc *RMA) CalculateAndUpdate(kLines []types.KLine)

+ func (inc *RMA) PushK(k types.KLine)

type RSI

+ func (inc *RSI) CalculateAndUpdate(kLines []types.KLine)

+ func (inc *RSI) PushK(k types.KLine)

type SMA

+ func (inc *SMA) BindK(target KLineClosedEmitter, symbol string, interval types.Interval)

+ func (inc *SMA) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *SMA) PushK(k types.KLine)

type SSF

+ func (inc *SSF) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *SSF) PushK(k types.KLine)

type STOCH

+ func (inc *STOCH) CalculateAndUpdate(kLines []types.KLine)

+ func (inc *STOCH) PushK(k types.KLine)

+ type StdDev struct

+ EndTime time.Time

+ Values types.Float64Slice

+ func (inc *StdDev) Bind(updater KLineWindowUpdater)

+ func (inc *StdDev) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *StdDev) EmitUpdate(value float64)

+ func (inc *StdDev) Index(i int) float64

+ func (inc *StdDev) Last() float64

+ func (inc *StdDev) Length() int

+ func (inc *StdDev) OnUpdate(cb func(value float64))

+ func (inc *StdDev) PushK(k types.KLine)

+ func (inc *StdDev) Update(value float64)

type Supertrend

+ func (inc *Supertrend) CalculateAndUpdate(kLines []types.KLine)

+ func (inc *Supertrend) PushK(k types.KLine)

type TEMA

+ func (inc *TEMA) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *TEMA) PushK(k types.KLine)

type TILL

+ func (inc *TILL) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *TILL) PushK(k types.KLine)

type TMA

+ func (inc *TMA) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *TMA) PushK(k types.KLine)

type VIDYA

+ func (inc *VIDYA) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *VIDYA) PushK(k types.KLine)

type VWAP

+ func (inc *VWAP) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *VWAP) PushK(k types.KLine)

type VWMA

+ PriceVolumeSMA *SMA

+ VolumeSMA *SMA

+ func (inc *VWMA) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *VWMA) Update(price, volume float64)

+ type Volatility struct

+ EndTime time.Time

+ UpdateCallbacks []func(value float64)

+ Values types.Float64Slice

+ func (inc *Volatility) Bind(updater KLineWindowUpdater)

+ func (inc *Volatility) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *Volatility) EmitUpdate(value float64)

+ func (inc *Volatility) Index(i int) float64

+ func (inc *Volatility) Last() float64

+ func (inc *Volatility) Length() int

+ func (inc *Volatility) OnUpdate(cb func(value float64))

type WWMA

+ func (inc *WWMA) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *WWMA) PushK(k types.KLine)

type ZLEMA

+ func (inc *ZLEMA) CalculateAndUpdate(allKLines []types.KLine)

+ func (inc *ZLEMA) PushK(k types.KLine)

Jul 10, 2022

Changes in this version

type ATR

+ func (inc *ATR) CalculateAndUpdate(kLines []types.KLine)

type OBV

+ func (inc *OBV) Index(i int) float64

type VOLATILITY

+ func (inc *VOLATILITY) Index(i int) float64

+ func (inc *VOLATILITY) Length() int

Jun 17, 2022

Changes in this version

+ type DMI struct

+ ADX types.UpdatableSeries

+ ADXSmoothing int

+ DIMinus *types.Queue

+ DIPlus *types.Queue

+ DMN types.UpdatableSeries

+ DMP types.UpdatableSeries

+ PrevHigh float64

+ PrevLow float64

+ UpdateCallbacks []func(diplus, diminus, adx float64)

+ func (inc *DMI) Bind(updater KLineWindowUpdater)

+ func (inc *DMI) EmitUpdate(diplus float64, diminus float64, adx float64)

+ func (inc *DMI) GetADX() types.Series

+ func (inc *DMI) GetDIMinus() types.Series

+ func (inc *DMI) GetDIPlus() types.Series

+ func (inc *DMI) Length() int

+ func (inc *DMI) OnUpdate(cb func(diplus float64, diminus float64, adx float64))

+ func (inc *DMI) Update(high, low, cloze float64)

type RMA

+ Adjust bool

Jun 16, 2022

Changes in this version

+ const MaxNumOfALMA

+ const MaxNumOfALMATruncateSize

+ type ALMA struct

+ Offset float64

+ Sigma int

+ Sum float64

+ UpdateCallbacks []func(value float64)

+ Values types.Float64Slice

+ Weight []float64

+ func (inc *ALMA) Bind(updater KLineWindowUpdater)

+ func (inc *ALMA) EmitUpdate(value float64)

+ func (inc *ALMA) Index(i int) float64

+ func (inc *ALMA) Last() float64

+ func (inc *ALMA) Length() int

+ func (inc *ALMA) OnUpdate(cb func(value float64))

+ func (inc *ALMA) Update(value float64)

type BOLL

+ func (inc *BOLL) Update(kLines []types.KLine)

+ type SSF struct

+ Poles int

+ UpdateCallbacks []func(value float64)

+ Values types.Float64Slice

+ func (inc *SSF) Bind(updater KLineWindowUpdater)

+ func (inc *SSF) EmitUpdate(value float64)

+ func (inc *SSF) Index(i int) float64

+ func (inc *SSF) Last() float64

+ func (inc *SSF) Length() int

+ func (inc *SSF) OnUpdate(cb func(value float64))

+ func (inc *SSF) Update(value float64)

Jun 13, 2022

Changes in this version

type Pivot

+ func (inc *Pivot) Update(klines []types.KLine)

Jun 8, 2022

Changes in this version

+ type Drift struct

+ LastValue float64

+ SMA *SMA

+ UpdateCallbacks []func(value float64)

+ Values types.Float64Slice

+ func (inc *Drift) Bind(updater KLineWindowUpdater)

+ func (inc *Drift) EmitUpdate(value float64)

+ func (inc *Drift) Index(i int) float64

+ func (inc *Drift) Last() float64

+ func (inc *Drift) Length() int

+ func (inc *Drift) OnUpdate(cb func(value float64))

+ func (inc *Drift) Update(value float64)

Jun 7, 2022

Changes in this version

+ const DefaultEMVScale

+ func KLineHighPriceMapper(k types.KLine) float64

+ func KLineLowPriceMapper(k types.KLine) float64

+ type CCI struct

+ Input types.Float64Slice

+ MA types.Float64Slice

+ TypicalPrice types.Float64Slice

+ UpdateCallbacks []func(value float64)

+ Values types.Float64Slice

+ func (inc *CCI) Bind(updater KLineWindowUpdater)

+ func (inc *CCI) EmitUpdate(value float64)

+ func (inc *CCI) Index(i int) float64

+ func (inc *CCI) Last() float64

+ func (inc *CCI) Length() int

+ func (inc *CCI) OnUpdate(cb func(value float64))

+ func (inc *CCI) Update(value float64)

+ type EMV struct

+ EMVScale float64

+ UpdateCallbacks []func(value float64)

+ Values *SMA

+ func (inc *EMV) Bind(updater KLineWindowUpdater)

+ func (inc *EMV) EmitUpdate(value float64)

+ func (inc *EMV) Index(i int) float64

+ func (inc *EMV) Last() float64

+ func (inc *EMV) Length() int

+ func (inc *EMV) OnUpdate(cb func(value float64))

+ func (inc *EMV) Update(high, low, vol float64)

+ type KLineValueMapper func(k types.KLine) float64

+ type Pivot struct

+ EndTime time.Time

+ Highs types.Float64Slice

+ Lows types.Float64Slice

+ UpdateCallbacks []func(valueLow, valueHigh float64)

+ func (inc *Pivot) Bind(updater KLineWindowUpdater)

+ func (inc *Pivot) EmitUpdate(valueLow float64, valueHigh float64)

+ func (inc *Pivot) LastHigh() float64

+ func (inc *Pivot) LastLow() float64

+ func (inc *Pivot) OnUpdate(cb func(valueLow float64, valueHigh float64))

type SMA

+ Cache types.Float64Slice

+ type Supertrend struct

+ ATRMultiplier float64

+ AverageTrueRange *ATR

+ EndTime time.Time

+ UpdateCallbacks []func(value float64)

+ func (inc *Supertrend) Bind(updater KLineWindowUpdater)

+ func (inc *Supertrend) EmitUpdate(value float64)

+ func (inc *Supertrend) GetSignal() types.Direction

+ func (inc *Supertrend) Index(i int) float64

+ func (inc *Supertrend) Last() float64

+ func (inc *Supertrend) Length() int

+ func (inc *Supertrend) OnUpdate(cb func(value float64))

+ func (inc *Supertrend) Update(highPrice, lowPrice, closePrice float64)

May 2, 2022

Changes in this version

type ATR

+ PreviousClose float64

Apr 27, 2022

Changes in this version

+ const MaxNumOfWWMA

+ const MaxNumOfWWMATruncateSize

+ type ATR struct

+ EndTime time.Time

+ PercentageVolatility types.Float64Slice

+ PriviousClose float64

+ RMA *RMA

+ UpdateCallbacks []func(value float64)

+ Values types.Float64Slice

+ func (A *ATR) EmitUpdate(value float64)

+ func (A *ATR) OnUpdate(cb func(value float64))

+ func (inc *ATR) Bind(updater KLineWindowUpdater)

+ func (inc *ATR) Index(i int) float64

+ func (inc *ATR) Last() float64

+ func (inc *ATR) Length() int

+ func (inc *ATR) Update(high, low, cloze float64)

+ type CA struct

+ Interval types.Interval

+ UpdateCallbacks []func(value float64)

+ Values types.Float64Slice

+ func (inc *CA) Bind(updater KLineWindowUpdater)

+ func (inc *CA) EmitUpdate(value float64)

+ func (inc *CA) Index(i int) float64

+ func (inc *CA) Last() float64

+ func (inc *CA) Length() int

+ func (inc *CA) OnUpdate(cb func(value float64))

+ func (inc *CA) Update(x float64)

+ type DEMA struct

+ UpdateCallbacks []func(value float64)

+ Values types.Float64Slice

+ func (inc *DEMA) Bind(updater KLineWindowUpdater)

+ func (inc *DEMA) EmitUpdate(value float64)

+ func (inc *DEMA) Index(i int) float64

+ func (inc *DEMA) Last() float64

+ func (inc *DEMA) Length() int

+ func (inc *DEMA) OnUpdate(cb func(value float64))

+ func (inc *DEMA) Update(value float64)

+ type HULL struct

+ UpdateCallbacks []func(value float64)

+ func (inc *HULL) Bind(updater KLineWindowUpdater)

+ func (inc *HULL) EmitUpdate(value float64)

+ func (inc *HULL) Index(i int) float64

+ func (inc *HULL) Last() float64

+ func (inc *HULL) Length() int

+ func (inc *HULL) OnUpdate(cb func(value float64))

+ func (inc *HULL) Update(value float64)

+ type RMA struct

+ EndTime time.Time

+ Sources types.Float64Slice

+ UpdateCallbacks []func(value float64)

+ Values types.Float64Slice

+ func (inc *RMA) Bind(updater KLineWindowUpdater)

+ func (inc *RMA) EmitUpdate(value float64)

+ func (inc *RMA) Index(i int) float64

+ func (inc *RMA) Last() float64

+ func (inc *RMA) Length() int

+ func (inc *RMA) OnUpdate(cb func(value float64))

+ func (inc *RMA) Update(x float64)

type STOCH

+ HighValues types.Float64Slice

+ LowValues types.Float64Slice

+ func (inc *STOCH) Update(high, low, cloze float64)

+ type TEMA struct

+ A1 *EWMA

+ A2 *EWMA

+ A3 *EWMA

+ UpdateCallbacks []func(value float64)

+ Values types.Float64Slice

+ func (inc *TEMA) Bind(updater KLineWindowUpdater)

+ func (inc *TEMA) EmitUpdate(value float64)

+ func (inc *TEMA) Index(i int) float64

+ func (inc *TEMA) Last() float64

+ func (inc *TEMA) Length() int

+ func (inc *TEMA) OnUpdate(cb func(value float64))

+ func (inc *TEMA) Update(value float64)

+ type TILL struct

+ UpdateCallbacks []func(value float64)

+ VolumeFactor float64

+ func (inc *TILL) Bind(updater KLineWindowUpdater)

+ func (inc *TILL) EmitUpdate(value float64)

+ func (inc *TILL) Index(i int) float64

+ func (inc *TILL) Last() float64

+ func (inc *TILL) Length() int

+ func (inc *TILL) OnUpdate(cb func(value float64))

+ func (inc *TILL) Update(value float64)

+ type TMA struct

+ UpdateCallbacks []func(value float64)

+ func (inc *TMA) Bind(updater KLineWindowUpdater)

+ func (inc *TMA) EmitUpdate(value float64)

+ func (inc *TMA) Index(i int) float64

+ func (inc *TMA) Last() float64

+ func (inc *TMA) Length() int

+ func (inc *TMA) OnUpdate(cb func(value float64))

+ func (inc *TMA) Update(value float64)

+ type VIDYA struct

+ UpdateCallbacks []func(value float64)

+ Values types.Float64Slice

+ func (inc *VIDYA) Bind(updater KLineWindowUpdater)

+ func (inc *VIDYA) EmitUpdate(value float64)

+ func (inc *VIDYA) Index(i int) float64

+ func (inc *VIDYA) Last() float64

+ func (inc *VIDYA) Length() int

+ func (inc *VIDYA) OnUpdate(cb func(value float64))

+ func (inc *VIDYA) Update(value float64)

+ type WWMA struct

+ LastOpenTime time.Time

+ UpdateCallbacks []func(value float64)

+ Values types.Float64Slice

+ func (inc *WWMA) Bind(updater KLineWindowUpdater)

+ func (inc *WWMA) EmitUpdate(value float64)

+ func (inc *WWMA) Index(i int) float64

+ func (inc *WWMA) Last() float64

+ func (inc *WWMA) Length() int

+ func (inc *WWMA) OnUpdate(cb func(value float64))

+ func (inc *WWMA) Update(value float64)

+ type ZLEMA struct

+ UpdateCallbacks []func(value float64)

+ func (inc *ZLEMA) Bind(updater KLineWindowUpdater)

+ func (inc *ZLEMA) EmitUpdate(value float64)

+ func (inc *ZLEMA) Index(i int) float64

+ func (inc *ZLEMA) Last() float64

+ func (inc *ZLEMA) Length() int

+ func (inc *ZLEMA) OnUpdate(cb func(value float64))

+ func (inc *ZLEMA) Update(value float64)

Apr 15, 2022

Changes in this version

type AD

+ func (inc *AD) Index(i int) float64

+ func (inc *AD) Length() int

type BOLL

+ func (inc *BOLL) GetDownBand() types.Series

+ func (inc *BOLL) GetSMA() types.Series

+ func (inc *BOLL) GetStdDev() types.Series

+ func (inc *BOLL) GetUpBand() types.Series

+ type BandType int

type EWMA

+ func (inc *EWMA) Index(i int) float64

+ func (inc *EWMA) Length() int

+ type Line struct

+ Interval types.Interval

+ func NewLine(startIndex int, startValue float64, endIndex int, endValue float64, ...) *Line

+ func (l *Line) Bind(updater KLineWindowUpdater)

+ func (l *Line) Index(i int) float64

+ func (l *Line) Last() float64

+ func (l *Line) Length() int

+ func (l *Line) SetXY1(index int, value float64)

+ func (l *Line) SetXY2(index int, value float64)

type MACD

+ func (inc *MACD) MACD() types.Series

+ func (inc *MACD) Singals() types.Series

+ type MACDValues struct

+ func (inc *MACDValues) Index(i int) float64

+ func (inc *MACDValues) Last() float64

+ func (inc *MACDValues) Length() int

type RSI

+ func (inc *RSI) Index(i int) float64

+ func (inc *RSI) Length() int

type SMA

+ func (inc *SMA) Index(i int) float64

+ func (inc *SMA) Length() int

+ func (inc *SMA) Update(value float64)

type STOCH

+ func (inc *STOCH) GetD() types.Series

+ func (inc *STOCH) GetK() types.Series

type VWAP

+ func (inc *VWAP) Index(i int) float64

+ func (inc *VWAP) Length() int

type VWMA

+ func (inc *VWMA) Index(i int) float64

+ func (inc *VWMA) Length() int

Apr 1, 2022

Changes in this version

+ func CalculateVWAP(klines []types.KLine, priceF KLinePriceMapper, window int) float64

type AD

+ func (inc *AD) Update(kLine types.KLine)

type MACD

+ func (inc *MACD) Update(kLine types.KLine, priceF KLinePriceMapper)

type OBV

+ func (inc *OBV) Update(kLine types.KLine, priceF KLinePriceMapper)

+ type RSI struct

+ EndTime time.Time

+ PreviousAvgGain float64

+ PreviousAvgLoss float64

+ Prices types.Float64Slice

+ UpdateCallbacks []func(value float64)

+ Values types.Float64Slice

+ func (inc *RSI) Bind(updater KLineWindowUpdater)

+ func (inc *RSI) EmitUpdate(value float64)

+ func (inc *RSI) Last() float64

+ func (inc *RSI) OnUpdate(cb func(value float64))

+ func (inc *RSI) Update(kline types.KLine, priceF KLinePriceMapper)

type VWAP

+ Prices types.Float64Slice

+ Volumes types.Float64Slice

+ func (inc *VWAP) Last() float64

+ func (inc *VWAP) Update(kLine types.KLine, priceF KLinePriceMapper)

Dec 27, 2021

Changes in this version

+ const MaxNumOfVOL

+ const MaxNumOfVOLTruncateSize

+ func KLinePriceVolumeMapper(k types.KLine) float64

+ func KLineVolumeMapper(k types.KLine) float64

+ type VOLATILITY struct

+ EndTime time.Time

+ UpdateCallbacks []func(value float64)

+ Values types.Float64Slice

+ func (inc *VOLATILITY) Bind(updater KLineWindowUpdater)

+ func (inc *VOLATILITY) EmitUpdate(value float64)

+ func (inc *VOLATILITY) Last() float64

+ func (inc *VOLATILITY) OnUpdate(cb func(value float64))

+ type VWMA struct

+ EndTime time.Time

+ UpdateCallbacks []func(value float64)

+ Values types.Float64Slice

+ func (inc *VWMA) Bind(updater KLineWindowUpdater)

+ func (inc *VWMA) EmitUpdate(value float64)

+ func (inc *VWMA) Last() float64

+ func (inc *VWMA) OnUpdate(cb func(value float64))

Aug 16, 2021

Changes in this version

+ const DPeriod

+ const MaxNumOfEWMA

+ const MaxNumOfEWMATruncateSize

+ const MaxNumOfSMA

+ const MaxNumOfSMATruncateSize

+ type STOCH struct

+ D types.Float64Slice

+ EndTime time.Time

+ K types.Float64Slice

+ KLineWindow types.KLineWindow

+ UpdateCallbacks []func(k float64, d float64)

+ func (inc *STOCH) Bind(updater KLineWindowUpdater)

+ func (inc *STOCH) EmitUpdate(k float64, d float64)

+ func (inc *STOCH) LastD() float64

+ func (inc *STOCH) LastK() float64

+ func (inc *STOCH) OnUpdate(cb func(k float64, d float64))

May 12, 2021

Changes in this version

+ func KLineTypicalPriceMapper(k types.KLine) float64

+ type AD struct

+ EndTime time.Time

+ PrePrice float64

+ UpdateCallbacks []func(value float64)

+ Values Float64Slice

+ func (inc *AD) Bind(updater KLineWindowUpdater)

+ func (inc *AD) EmitUpdate(value float64)

+ func (inc *AD) Last() float64

+ func (inc *AD) OnUpdate(cb func(value float64))

type EWMA

+ func (inc *EWMA) Update(value float64)

+ type MACD struct

+ EndTime time.Time

+ FastEWMA EWMA

+ Histogram Float64Slice

+ LongPeriod int

+ ShortPeriod int

+ SignalLine EWMA

+ SlowEWMA EWMA

+ UpdateCallbacks []func(value float64)

+ Values Float64Slice

+ func (inc *MACD) Bind(updater KLineWindowUpdater)

+ func (inc *MACD) EmitUpdate(value float64)

+ func (inc *MACD) OnUpdate(cb func(value float64))

+ type OBV struct

+ EndTime time.Time

+ PrePrice float64

+ UpdateCallbacks []func(value float64)

+ Values Float64Slice

+ func (inc *OBV) Bind(updater KLineWindowUpdater)

+ func (inc *OBV) EmitUpdate(value float64)

+ func (inc *OBV) Last() float64

+ func (inc *OBV) OnUpdate(cb func(value float64))

+ type VWAP struct

+ EndTime time.Time

+ UpdateCallbacks []func(value float64)

+ Values Float64Slice

+ VolumeSum float64

+ WeightedSum float64

+ func (V *VWAP) EmitUpdate(value float64)

+ func (V *VWAP) OnUpdate(cb func(value float64))

+ func (inc *VWAP) Bind(updater KLineWindowUpdater)

Dec 9, 2020

Changes in this version

+ func CalculateKLinesEMA(allKLines []types.KLine, priceF KLinePriceMapper, window int) float64

Dec 5, 2020

Changes in this version

+ func CalculateKLineEWMA(allKLines []types.KLine, priceF KLinePriceMapper, window int) float64

+ func KLineClosePriceMapper(k types.KLine) float64

+ func KLineOpenPriceMapper(k types.KLine) float64

+ func MapKLinePrice(kLines []types.KLine, f KLinePriceMapper) (prices []float64)

type EWMA

+ LastOpenTime time.Time

+ UpdateCallbacks []func(value float64)

+ func (inc *EWMA) EmitUpdate(value float64)

+ func (inc *EWMA) OnUpdate(cb func(value float64))

+ type KLinePriceMapper func(k types.KLine) float64

type SMA

+ UpdateCallbacks []func(value float64)

+ func (inc *SMA) EmitUpdate(value float64)

+ func (inc *SMA) OnUpdate(cb func(value float64))

Nov 11, 2020

Changes in this version

+ type BOLL struct

+ DownBand Float64Slice

+ EndTime time.Time

+ K float64

+ SMA Float64Slice

+ StdDev Float64Slice

+ UpBand Float64Slice

+ func (inc *BOLL) Bind(updater KLineWindowUpdater)

+ func (inc *BOLL) EmitUpdate(sma float64, upBand float64, downBand float64)

+ func (inc *BOLL) LastDownBand() float64

+ func (inc *BOLL) LastSMA() float64

+ func (inc *BOLL) LastStdDev() float64

+ func (inc *BOLL) LastUpBand() float64

+ func (inc *BOLL) OnUpdate(cb func(sma float64, upBand float64, downBand float64))

+ type EWMA struct

+ EndTime time.Time

+ Values Float64Slice

+ func (inc *EWMA) Bind(updater KLineWindowUpdater)

+ func (inc *EWMA) Last() float64

+ type Float64Slice []float64

+ func (s *Float64Slice) Push(v float64)

+ type KLineWindowUpdater interface

+ OnKLineWindowUpdate func(func(interval types.Interval, window types.KLineWindow))

+ type SMA struct

+ EndTime time.Time

+ Values Float64Slice

+ func (inc *SMA) Bind(updater KLineWindowUpdater)

+ func (inc *SMA) Last() float64