feeds

Documentation

Index

• type CSVDOHLCVRecordParser
  • func (csvFPSP *CSVDOHLCVRecordParser) ParseRecord(csvRecord []string, dateColumnIndex int, openPriceColumnIndex int, ...) (dholcv gotrade.DOHLCV, err error)
• type CSVFileFeed
  • func NewCSVFileFeed(fileName string, dateColumnIndex int, openPriceColumnIndex int, ...) *CSVFileFeed
  • func NewCSVFileFeedWithDOHLCVFormat(fileName string, dateParser TextDateParser) *CSVFileFeed
  • func (csvFPSF *CSVFileFeed) FillDOHLCVStream(priceStream gotrade.DOHLCVStreamTickReceiver) (err error)
• type TextDateParser
  • func DashedYearDayMonthDateParser() TextDateParser
  • func DashedYearDayMonthDateParserForLocation(location *time.Location) TextDateParser

Types

type CSVDOHLCVRecordParser

type CSVDOHLCVRecordParser struct {
}

func (*CSVDOHLCVRecordParser) ParseRecord

func (csvFPSP *CSVDOHLCVRecordParser) ParseRecord(csvRecord []string,
	dateColumnIndex int,
	openPriceColumnIndex int,
	highPriceColumnIndex int,
	lowPriceColumnIndex int,
	closePriceColumnIndex int,
	volumeColumnIndex int,
	dateParser TextDateParser) (dholcv gotrade.DOHLCV, err error)

type CSVFileFeed

type CSVFileFeed struct {
	*CSVDOHLCVRecordParser
	// contains filtered or unexported fields
}

func NewCSVFileFeed

func NewCSVFileFeed(fileName string,
	dateColumnIndex int,
	openPriceColumnIndex int,
	highPriceColumnIndex int,
	lowPriceColumnIndex int,
	closePriceColumnIndex int,
	volumeColumnIndex int,
	dateParser TextDateParser) *CSVFileFeed

func NewCSVFileFeedWithDOHLCVFormat

func NewCSVFileFeedWithDOHLCVFormat(fileName string,
	dateParser TextDateParser) *CSVFileFeed

func (*CSVFileFeed) FillDOHLCVStream

func (csvFPSF *CSVFileFeed) FillDOHLCVStream(priceStream gotrade.DOHLCVStreamTickReceiver) (err error)

type TextDateParser

type TextDateParser func(textDate string) (date time.Time, err error)

func DashedYearDayMonthDateParser

func DashedYearDayMonthDateParser() TextDateParser

func DashedYearDayMonthDateParserForLocation

func DashedYearDayMonthDateParserForLocation(location *time.Location) TextDateParser