writer

Documentation

Index

• type BarWriter
• type BarWriterImpl
  • func (b BarWriterImpl) Write(symbol string, bars []api.Bar) error
• type MarketStoreWriter
• type MarketStoreWriterImpl
  • func (m *MarketStoreWriterImpl) Write(csm io.ColumnSeriesMap) error
• type MarketTimeChecker
• type NoopMarketTimeChecker
  • func (nc *NoopMarketTimeChecker) IsOpen(t time.Time) bool
• type SnapshotWriter
• type SnapshotWriterImpl
  • func NewSnapshotWriterImpl(w MarketStoreWriter, tf string, tz *time.Location, tc MarketTimeChecker) *SnapshotWriterImpl
  • func (q SnapshotWriterImpl) Write(snapshots map[string]*api.Snapshot) error

Types

type BarWriter

type BarWriter interface {
	Write(symbol string, bars []api.Bar) error
}

BarWriter is an interface to write chart data to the marketstore.

type BarWriterImpl

type BarWriterImpl struct {
	MarketStoreWriter MarketStoreWriter
	Timeframe         string
	// BarWriterImpl writes data with the timezone
	Timezone *time.Location
}

BarWriterImpl is an implementation of the BarWriter interface.

func (BarWriterImpl) Write

func (b BarWriterImpl) Write(symbol string, bars []api.Bar) error

Write converts the Response of the GetMultiBars API to a ColumnSeriesMap and write it to the local marketstore server.

type MarketStoreWriter

type MarketStoreWriter interface {
	Write(csm io.ColumnSeriesMap) error
}

MarketStoreWriter is an interface to write data to marketstore. this interface is necessary for writing unit tests of Alpaca Broker API Feeder without actually saving data to the marketstore.

type MarketStoreWriterImpl

type MarketStoreWriterImpl struct{}

MarketStoreWriterImpl writes the column series map data to the local marketstore data.

func (*MarketStoreWriterImpl) Write

func (m *MarketStoreWriterImpl) Write(csm io.ColumnSeriesMap) error

type MarketTimeChecker

type MarketTimeChecker interface {
	IsOpen(t time.Time) bool
}

type NoopMarketTimeChecker

type NoopMarketTimeChecker struct{}

NoopMarketTimeChecker checks nothing and always returns IsOpen=true.

func (*NoopMarketTimeChecker) IsOpen

func (nc *NoopMarketTimeChecker) IsOpen(t time.Time) bool

type SnapshotWriter

type SnapshotWriter interface {
	Write(snapshots map[string]*api.Snapshot) error
}

SnapshotWriter is an interface to write the realtime stock data to the marketstore.

type SnapshotWriterImpl

type SnapshotWriterImpl struct {
	MarketStoreWriter MarketStoreWriter
	Timeframe         string
	// SnapshotWriterImpl writes data with the timezone
	Timezone    *time.Location
	TimeChecker MarketTimeChecker
}

SnapshotWriterImpl is an implementation of the SnapshotWriter interface.

func NewSnapshotWriterImpl

func NewSnapshotWriterImpl(w MarketStoreWriter, tf string, tz *time.Location, tc MarketTimeChecker,
) *SnapshotWriterImpl

func (SnapshotWriterImpl) Write

func (q SnapshotWriterImpl) Write(snapshots map[string]*api.Snapshot) error

Write converts the map(key:symbol, value:snapshot) to a ColumnSeriesMap and write it to the local marketstore server.