stores

package

Go to main page

Versions in this module

v0

v0.7.3

Mar 9, 2023

v0.7.2

Nov 23, 2021

v0.7.1

Nov 23, 2021

v0.7.0

Jan 24, 2021

Changes in this version

+ type TDEngine struct

+ func NewTDEngine(address string) (*TDEngine, error)

+ func (s TDEngine) Close() error

+ func (s TDEngine) Delete(exchange exchanges.Exchange, date time.Time) error

+ func (s TDEngine) Exists(exchange exchanges.Exchange, date time.Time) (bool, error)

+ func (s TDEngine) Load(exchange exchanges.Exchange, date time.Time) (*quotes.ExchangeDailyQuote, error)

+ func (s TDEngine) Save(exchange exchanges.Exchange, date time.Time, edq *quotes.ExchangeDailyQuote) error

v0.6.5

Aug 2, 2020

Changes in this version

+ type S3 struct

+ func NewS3(config *S3Config) *S3

+ func (s S3) Close() error

+ func (s S3) Delete(exchange exchanges.Exchange, date time.Time) error

+ func (s S3) Exists(exchange exchanges.Exchange, date time.Time) (bool, error)

+ func (s S3) Load(exchange exchanges.Exchange, date time.Time) (*quotes.ExchangeDailyQuote, error)

+ func (s S3) Save(exchange exchanges.Exchange, date time.Time, edq *quotes.ExchangeDailyQuote) error

+ type S3Config struct

+ AccessKeyID string

+ Bucket string

+ Region string

+ SecretAccessKey string

v0.6.4

Feb 17, 2020

Changes in this version

type Cos

+ func (s Cos) Delete(exchange exchanges.Exchange, date time.Time) error

type FileSystem

+ func (s FileSystem) Delete(exchange exchanges.Exchange, date time.Time) error

type InfluxDB

+ func (s InfluxDB) Delete(exchange exchanges.Exchange, date time.Time) error

type LevelDB

+ func (s LevelDB) Delete(exchange exchanges.Exchange, date time.Time) error

type Redis

+ func (s Redis) Delete(exchange exchanges.Exchange, date time.Time) error

type Store

+ Delete func(exchanges.Exchange, time.Time) error

v0.6.3

Feb 9, 2020

Changes in this version

+ type InfluxDB struct

+ func NewInfluxDB(address, db string) *InfluxDB

+ func (s InfluxDB) Close() error

+ func (s InfluxDB) Exists(exchange exchanges.Exchange, date time.Time) (bool, error)

+ func (s InfluxDB) Load(exchange exchanges.Exchange, date time.Time) (*quotes.ExchangeDailyQuote, error)

+ func (s InfluxDB) Save(exchange exchanges.Exchange, date time.Time, edq *quotes.ExchangeDailyQuote) error

v0.6.2

Jul 13, 2019

v0.6.1

Jun 29, 2019

v0.6.0

Feb 16, 2019

v0.5.5

Feb 11, 2019

v0.5.4

Feb 11, 2019

v0.5.3

Nov 3, 2018

v0.5.2

Oct 28, 2018

v0.5.1

Oct 28, 2018

Changes in this version

+ type Cos struct

+ func NewCos(client *cos.Client) *Cos

+ func (s Cos) Close() error

+ func (s Cos) Exists(exchange exchanges.Exchange, date time.Time) (bool, error)

+ func (s Cos) Load(exchange exchanges.Exchange, date time.Time) (*quotes.ExchangeDailyQuote, error)

+ func (s Cos) Save(exchange exchanges.Exchange, date time.Time, edq *quotes.ExchangeDailyQuote) error

v0.5.0

Oct 28, 2018

v0.4.7

Oct 28, 2018

v0.4.6

Oct 7, 2018

v0.4.5

Sep 25, 2018

v0.4.4

Sep 25, 2018

v0.4.3

Sep 20, 2018

Changes in this version

+ type KV struct

+ Key string

+ Value string

v0.4.2

Sep 15, 2018

Changes in this version

+ type Redis struct

+ func NewRedis(address, password string) *Redis

+ func (s Redis) Close() error

+ func (s Redis) Exists(exchange exchanges.Exchange, date time.Time) (bool, error)

+ func (s Redis) Load(exchange exchanges.Exchange, date time.Time) (*quotes.ExchangeDailyQuote, error)

+ func (s Redis) Save(exchange exchanges.Exchange, date time.Time, edq *quotes.ExchangeDailyQuote) error

v0.4.1

Sep 14, 2018

v0.4.0

Sep 13, 2018

v0.3.6

Sep 13, 2018

v0.3.5

Sep 10, 2018

v0.3.4

Sep 10, 2018

v0.3.3

Sep 8, 2018

v0.3.2

Sep 7, 2018

Changes in this version

+ type Ledis struct

+ func NewLedis(root string) *Ledis

+ func (s Ledis) Close() error

+ func (s Ledis) Exists(exchange exchanges.Exchange, date time.Time) (bool, error)

+ func (s Ledis) Load(exchange exchanges.Exchange, date time.Time) (*quotes.ExchangeDailyQuote, error)

+ func (s Ledis) Save(exchange exchanges.Exchange, date time.Time, edq *quotes.ExchangeDailyQuote) error

v0.3.1

Sep 3, 2018

Changes in this version

type FileSystem

+ func (s FileSystem) Close() error

+ type LevelDB struct

+ func NewLevelDB(root string) *LevelDB

+ func (s LevelDB) Close() error

+ func (s LevelDB) Exists(exchange exchanges.Exchange, date time.Time) (bool, error)

+ func (s LevelDB) Load(exchange exchanges.Exchange, date time.Time) (*quotes.ExchangeDailyQuote, error)

+ func (s LevelDB) Save(exchange exchanges.Exchange, date time.Time, edq *quotes.ExchangeDailyQuote) error

type Store

+ Close func() error

v0.3.0

Sep 2, 2018

v0.2.0

Aug 31, 2018

Changes in this version

type FileSystem

+ func (s FileSystem) Remove(exchange exchanges.Exchange, date time.Time) error

type Store

+ Remove func(exchanges.Exchange, time.Time) error

v0.1.2

Aug 30, 2018

v0.1.1

Aug 30, 2018

v0.1.0

Aug 29, 2018

Changes in this version

+ type FileSystem struct

+ func NewFileSystem(root string) *FileSystem

+ func (s FileSystem) Exists(exchange exchanges.Exchange, date time.Time) (bool, error)

+ func (s FileSystem) Load(exchange exchanges.Exchange, date time.Time, decoder quotes.Decoder) error

+ func (s FileSystem) Save(exchange exchanges.Exchange, date time.Time, encoder quotes.Encoder) error

+ type Store interface

+ Exists func(exchanges.Exchange, time.Time) (bool, error)

+ Load func(exchanges.Exchange, time.Time, quotes.Decoder) error

+ Save func(exchanges.Exchange, time.Time, quotes.Encoder) error

+ func Parse(arg string) (Store, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL