dbstore

Documentation

Index

• type DBStore
  • func LoadDB(cfg *viper.Viper) (db *DBStore, err error)
  • func NewDBStore(dbType, dbURI string) (dr *DBStore, err error)
  • func (dr *DBStore) Close() (err error)
  • func (dr *DBStore) GetKlineTables() (tbls []TableInfo, err error)
  • func (dr *DBStore) GetKlineTbl(exchange, symbol, binSize string) *KlineTbl
  • func (dr *DBStore) GetTableSession(tbl string, data TimeData) (sess *xorm.Session)
  • func (dr *DBStore) GetTables() (tbls []string, err error)
  • func (dr *DBStore) NewKlineTbl(exchange, symbol, binSize string) *KlineTbl
  • func (dr *DBStore) SetDebug(bDebug bool)
  • func (d *DBStore) SetUseCache(useCache bool)
  • func (d *DBStore) WriteKlines(exchange, symbol, binSize string, datas []interface{}) (err error)
• type DataCreator
• type KlineTbl
  • func NewKlineTbl(db *DBStore, exchange, symbol, binSize string) (t *KlineTbl)
  • func (tbl *KlineTbl) GetSlice(data interface{}) (rets []interface{})
  • func (tbl *KlineTbl) Init(bus *Bus) (err error)
  • func (tbl *KlineTbl) SetLoadDataMode(bLoad bool)
  • func (tbl *KlineTbl) Sing() TimeData
  • func (tbl *KlineTbl) Slice() interface{}
• type TableInfo
• type TimeData
• type TimeTbl
  • func NewTimeTbl(db *DBStore, creator DataCreator, exchange, symbol, binSize, extName string) (t *TimeTbl)
  • func (t *TimeTbl) AddOrUpdateData(data interface{}) (err error)
  • func (t *TimeTbl) CacheData(start, end time.Time, bSize string) (err error)
  • func (tbl *TimeTbl) Count() (n int64, err error)
  • func (t *TimeTbl) DataChan(start, end time.Time, bSize string) (klines chan []interface{}, err error)
  • func (t *TimeTbl) DataRecent(recent int32, bSize string) (klines []interface{}, err error)
  • func (t *TimeTbl) Exists(data interface{}) (bRet bool, err error)
  • func (t *TimeTbl) GetDatas(since, end time.Time, limit int) (datas []interface{}, err error)
  • func (tbl *TimeTbl) GetNewest() (t time.Time)
  • func (tbl *TimeTbl) GetOldest() (t time.Time)
  • func (t *TimeTbl) GetSymbol() string
  • func (t *TimeTbl) GetTable() string
  • func (tbl *TimeTbl) IsEmpty() (isEmpty bool)
  • func (t *TimeTbl) SetCloseCh(closeCh chan bool)
  • func (t *TimeTbl) SetLoadOnce(loadOnce int)
  • func (t *TimeTbl) UpdateData(data interface{}) (err error)
  • func (t *TimeTbl) WriteData(data interface{}) (err error)
  • func (t *TimeTbl) WriteDatas(datas []interface{}) (err error)
• type TradeTbl
  • func NewTradeTbl(db *DBStore, id int64) (t *TradeTbl)

Types

type DBStore

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

func LoadDB

func LoadDB(cfg *viper.Viper) (db *DBStore, err error)

Load init db from config file

func NewDBStore

func NewDBStore(dbType, dbURI string) (dr *DBStore, err error)

NewDBStore support sqlite,mysql,pg

func (*DBStore) Close

func (dr *DBStore) Close() (err error)

Close close db

func (*DBStore) GetKlineTables

func (dr *DBStore) GetKlineTables() (tbls []TableInfo, err error)

func (*DBStore) GetKlineTbl

func (dr *DBStore) GetKlineTbl(exchange, symbol, binSize string) *KlineTbl

GetKlineTbl get kline table

func (*DBStore) GetTableSession

func (dr *DBStore) GetTableSession(tbl string, data TimeData) (sess *xorm.Session)

GetTableSession get table,if not exsit, create the table

func (*DBStore) GetTables

func (dr *DBStore) GetTables() (tbls []string, err error)

func (*DBStore) NewKlineTbl

func (dr *DBStore) NewKlineTbl(exchange, symbol, binSize string) *KlineTbl

func (*DBStore) SetDebug

func (dr *DBStore) SetDebug(bDebug bool)

SetDebug set debug mode

func (*DBStore) SetUseCache

func (d *DBStore) SetUseCache(useCache bool)

func (*DBStore) WriteKlines

func (d *DBStore) WriteKlines(exchange, symbol, binSize string, datas []interface{}) (err error)

WriteKlines write klines

type DataCreator

type DataCreator interface {
	Sing() TimeData
	Slice() interface{}
	GetSlice(interface{}) []interface{}
}

type KlineTbl

type KlineTbl struct {
	BaseProcesser
	TimeTbl
	// contains filtered or unexported fields
}

KlineTbl kline data table

func NewKlineTbl

func NewKlineTbl(db *DBStore, exchange, symbol, binSize string) (t *KlineTbl)

func (*KlineTbl) GetSlice

func (tbl *KlineTbl) GetSlice(data interface{}) (rets []interface{})

func (*KlineTbl) Init

func (tbl *KlineTbl) Init(bus *Bus) (err error)

func (*KlineTbl) SetLoadDataMode

func (tbl *KlineTbl) SetLoadDataMode(bLoad bool)

func (*KlineTbl) Sing

func (tbl *KlineTbl) Sing() TimeData

func (*KlineTbl) Slice

func (tbl *KlineTbl) Slice() interface{}

type TableInfo

type TableInfo struct {
	Exchange string
	Symbol   string
	BinSize  string
}

type TimeData

type TimeData interface {
	GetStart() int64
	Time() time.Time
	GetTable() string
	SetTable(string)
}

TimeData data with time info

type TimeTbl

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

TimeTbl tbl with time info

func NewTimeTbl

func NewTimeTbl(db *DBStore, creator DataCreator, exchange, symbol, binSize, extName string) (t *TimeTbl)

NewTimeTbl create new time table

func (*TimeTbl) AddOrUpdateData

func (t *TimeTbl) AddOrUpdateData(data interface{}) (err error)

func (*TimeTbl) CacheData

func (t *TimeTbl) CacheData(start, end time.Time, bSize string) (err error)

CacheData load datas and store to cache

func (*TimeTbl) Count

func (tbl *TimeTbl) Count() (n int64, err error)

func (*TimeTbl) DataChan

func (t *TimeTbl) DataChan(start, end time.Time, bSize string) (klines chan []interface{}, err error)

func (*TimeTbl) DataRecent

func (t *TimeTbl) DataRecent(recent int32, bSize string) (klines []interface{}, err error)

func (*TimeTbl) Exists

func (t *TimeTbl) Exists(data interface{}) (bRet bool, err error)

Exists check if data's time exists

func (*TimeTbl) GetDatas

func (t *TimeTbl) GetDatas(since, end time.Time, limit int) (datas []interface{}, err error)

func (*TimeTbl) GetNewest

func (tbl *TimeTbl) GetNewest() (t time.Time)

func (*TimeTbl) GetOldest

func (tbl *TimeTbl) GetOldest() (t time.Time)

func (*TimeTbl) GetSymbol

func (t *TimeTbl) GetSymbol() string

func (*TimeTbl) GetTable

func (t *TimeTbl) GetTable() string

func (*TimeTbl) IsEmpty

func (tbl *TimeTbl) IsEmpty() (isEmpty bool)

func (*TimeTbl) SetCloseCh

func (t *TimeTbl) SetCloseCh(closeCh chan bool)

func (*TimeTbl) SetLoadOnce

func (t *TimeTbl) SetLoadOnce(loadOnce int)

func (*TimeTbl) UpdateData

func (t *TimeTbl) UpdateData(data interface{}) (err error)

UpdateData update datas

func (*TimeTbl) WriteData

func (t *TimeTbl) WriteData(data interface{}) (err error)

WriteData write data

func (*TimeTbl) WriteDatas

func (t *TimeTbl) WriteDatas(datas []interface{}) (err error)

WriteDatas write datas

type TradeTbl

type TradeTbl struct {
}

func NewTradeTbl

func NewTradeTbl(db *DBStore, id int64) (t *TradeTbl)