stores

Documentation

Index

• type Cos
  • 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
• type FileSystem
  • func NewFileSystem(root string) *FileSystem
  • func (s FileSystem) Close() error
  • func (s FileSystem) Exists(exchange exchanges.Exchange, date time.Time) (bool, error)
  • func (s FileSystem) Load(exchange exchanges.Exchange, date time.Time) (*quotes.ExchangeDailyQuote, error)
  • func (s FileSystem) Save(exchange exchanges.Exchange, date time.Time, edq *quotes.ExchangeDailyQuote) error
• type InfluxDB
  • 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
• type KV
• type LevelDB
  • 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 Redis
  • 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
• type Store
  • func Parse(arg string) (Store, error)

Types

type Cos

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

Cos define tencent cos store

func NewCos

func NewCos(client *cos.Client) *Cos

NewCos create tencent cos store

func (Cos) Close

func (s Cos) Close() error

Close close store

func (Cos) Exists

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

Exists check quote exists

func (Cos) Load

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

Load load exchange daily quote

func (Cos) Save

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

Save save exchange daily quote

type FileSystem

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

FileSystem define file system store

func NewFileSystem

func NewFileSystem(root string) *FileSystem

NewFileSystem create file system store

func (FileSystem) Close

func (s FileSystem) Close() error

Close close store

func (FileSystem) Exists

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

Exists check quote exists

func (FileSystem) Load

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

Load load exchange daily quote

func (FileSystem) Save

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

Save save exchange daily quote

type InfluxDB

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

InfluxDB influxdb store

func NewInfluxDB

func NewInfluxDB(address, db string) *InfluxDB

NewInfluxDB create new influxdb store

func (InfluxDB) Close

func (s InfluxDB) Close() error

Close close store

func (InfluxDB) Exists

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

Exists check quote exists

func (InfluxDB) Load

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

Load load exchange daily quote

func (InfluxDB) Save

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

Save save exchange daily quote

type KV

type KV struct {
	Key   string
	Value string
}

KV key value pair

type LevelDB

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

LevelDB level db store

func NewLevelDB

func NewLevelDB(root string) *LevelDB

NewLevelDB create level db store

func (LevelDB) Close

func (s LevelDB) Close() error

Close close level db store

func (LevelDB) Exists

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

Exists check quote exists

func (LevelDB) Load

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

Load load exchange daily quote

func (LevelDB) Save

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

Save save exchange daily quote

type Redis

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

Redis define redis store

func NewRedis

func NewRedis(address, password string) *Redis

NewRedis create redis store

func (Redis) Close

func (s Redis) Close() error

Close close redis store

func (Redis) Exists

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

Exists check quote exists

func (Redis) Load

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

Load load exchange daily quote

func (Redis) Save

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

Save save exchange daily quote

type Store

type Store interface {
	// Exists exchange daily quote exists
	Exists(exchanges.Exchange, time.Time) (bool, error)
	// Save save exchange daily quote
	Save(exchanges.Exchange, time.Time, *quotes.ExchangeDailyQuote) error
	// Load load exchange daily quote
	Load(exchanges.Exchange, time.Time) (*quotes.ExchangeDailyQuote, error)
	// Close close exchange daily quote store
	Close() error
}

Store define exchange daily quote store

func Parse

func Parse(arg string) (Store, error)

Parse parse command argument