stores

Documentation

Index

• 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 Ledis
  • 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
• 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 Store
  • func Parse(arg string) (Store, error)

Types

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 Ledis

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

Ledis define ledis store

func NewLedis

func NewLedis(root string) *Ledis

NewLedis create new ledis store

func (Ledis) Close

func (s Ledis) Close() error

Close close ledis store

func (Ledis) Exists

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

Exists check quote exists

func (Ledis) Load

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

Load load exchange daily quote

func (Ledis) Save

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

Save save exchange daily quote

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 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