collectors

Documentation

Index

• Variables
• func GetCsv(file string) (*csv.Reader, error)
• func GetPreviousIntervalDates(date time.Time, intervalDuration int) (time.Time, time.Time)
• type FileTickerCollector
  • func NewFileTickerCollector(options domain.CollectorOptions, indicators *[]domain.Indicator) *FileTickerCollector
  • func (ftc *FileTickerCollector) GetTicker(tickerSymbol string) (float32, error)
  • func (ftc *FileTickerCollector) Regist(observable domain.OnNewAssetPrice)
  • func (ftc *FileTickerCollector) SetIndicators(indicators *[]domain.Indicator)
  • func (ftc *FileTickerCollector) Start()
  • func (ftc *FileTickerCollector) Stop()
• type KrakenCollector
  • func NewKrakenCollector(asset string, options domain.CollectorOptions, krakenAPI *krakenapi.KrakenAPI, ...) *KrakenCollector
  • func (kc *KrakenCollector) GetTicker(tickerSymbol string) (float32, error)
  • func (kc *KrakenCollector) PublishAssetPrice(ohlc *domain.OHLC) error
  • func (kc *KrakenCollector) Regist(observable domain.OnNewAssetPrice)
  • func (kc *KrakenCollector) SetIndicators(indicators *[]domain.Indicator)
  • func (kc *KrakenCollector) Start()
  • func (kc *KrakenCollector) Stop()
• type SocketEvent
• type TickerMessage

Variables

var Pairs = map[string]string{
	"BTC":  "XBT/EUR",
	"ETH":  "ETH/EUR",
	"ADA":  "ADA/EUR",
	"ATOM": "ATOM/EUR",
	"DOT":  "DOT/EUR",
}

Functions

func GetCsv

func GetCsv(file string) (*csv.Reader, error)

GetCsv returns the pointer for a csv file from the filepath

func GetPreviousIntervalDates

func GetPreviousIntervalDates(date time.Time, intervalDuration int) (time.Time, time.Time)

Types

type FileTickerCollector

type FileTickerCollector struct {
	// contains filtered or unexported fields
}

FileTickerCollector collects data from a csv file

func NewFileTickerCollector

func NewFileTickerCollector(options domain.CollectorOptions, indicators *[]domain.Indicator) *FileTickerCollector

NewFileTickerCollector returns an instance of FileTickerCollector

func (*FileTickerCollector) GetTicker

func (ftc *FileTickerCollector) GetTicker(tickerSymbol string) (float32, error)

GetTicker is a stub

func (*FileTickerCollector) Regist

func (ftc *FileTickerCollector) Regist(observable domain.OnNewAssetPrice)

Regist add function to be executed when a new price is received

func (*FileTickerCollector) SetIndicators

func (ftc *FileTickerCollector) SetIndicators(indicators *[]domain.Indicator)

func (*FileTickerCollector) Start

func (ftc *FileTickerCollector) Start()

Start starts collecting data from data source

func (*FileTickerCollector) Stop

func (ftc *FileTickerCollector) Stop()

Stop is a stub

type KrakenCollector

type KrakenCollector struct {
	// contains filtered or unexported fields
}

KrakenCollector collects data from kraken exchange

func NewKrakenCollector

func NewKrakenCollector(asset string, options domain.CollectorOptions, krakenAPI *krakenapi.KrakenAPI, indicators *[]domain.Indicator) *KrakenCollector

NewKrakenCollector returns an instance of KrakenCollector

func (*KrakenCollector) GetTicker

func (kc *KrakenCollector) GetTicker(tickerSymbol string) (float32, error)

GetTicker calls kraken API to get ticker pair price

func (*KrakenCollector) PublishAssetPrice

func (kc *KrakenCollector) PublishAssetPrice(ohlc *domain.OHLC) error

func (*KrakenCollector) Regist

func (kc *KrakenCollector) Regist(observable domain.OnNewAssetPrice)

Regist add function to be executed when ticker price changes

func (*KrakenCollector) SetIndicators

func (kc *KrakenCollector) SetIndicators(indicators *[]domain.Indicator)

SetIndicators set indicators that listen for price changes

func (*KrakenCollector) Start

func (kc *KrakenCollector) Start()

Start connects to a kraken websocket that send prices variations

func (*KrakenCollector) Stop

func (kc *KrakenCollector) Stop()

Stop closes connection with kraken websocket

type SocketEvent

type SocketEvent struct {
	Event string
}

SocketEvent is a type used to decode kraken websocket messages

type TickerMessage

type TickerMessage struct {
	A []interface{}
	B []interface{}
	V []interface{}
}

TickerMessage is a type used to decode messages of ticker price change events