sync

Documentation

Index

• Constants
• type ProfileRunInfo
• type ProfileWork
  • func (o *ProfileWork) GetDao() (dao qdao.D, err error)
• type Syncer
  • func (o *Syncer) DoProfile(work *ProfileWork) (data []interface{}, err error)
  • func (o *Syncer) DoProfileRecover(work *ProfileWork)
  • func (o *Syncer) DoProfileWithRecord(work *ProfileWork) (ferr error)
  • func (o *Syncer) GetMetaToken(profilename string) string
  • func (o *Syncer) GetProfile(name string) map[string]interface{}
  • func (o *Syncer) GetProfileRunInfo(profilename string) *ProfileRunInfo
  • func (o *Syncer) HandleCmd(cmd *global.Cmd) (*global.Cmd, bool, error)
  • func (o *Syncer) Lua_handler(phrase string, work *ProfileWork) (interface{}, error)
  • func (o Syncer) Lua_request(work *ProfileWork, fields []string, requestargs map[string]interface{}) (ret []interface{}, err error)
  • func (o *Syncer) Netease_khistory(phrase string, work *ProfileWork) (interface{}, error)
  • func (o Syncer) Netease_request(work *ProfileWork, fields []string, requestargs map[string]interface{}) (data []interface{}, ids []interface{}, err error)
  • func (o *Syncer) Netease_snapshot(phrase string, work *ProfileWork) (err error)
  • func (o *Syncer) PersistAndCache(work *ProfileWork, data []interface{}) (rdata []interface{}, ids []interface{}, err error)
  • func (o *Syncer) Run(name string)
  • func (o Syncer) ShenJian_request(work *ProfileWork, fields []string, requestargs map[string]interface{}) (data []interface{}, ids []interface{}, err error)
  • func (o *Syncer) ShenJian_snapshot(phrase string, work *ProfileWork) (err error)
  • func (o *Syncer) ShowAPI_khistory(phrase string, work *ProfileWork) (err error)
  • func (o *Syncer) ShowAPI_request(work *ProfileWork, requestargs map[string]interface{}) (interface{}, error)
  • func (o *Syncer) ShowAPI_snapshot(phrase string, work *ProfileWork) (err error)
  • func (o *Syncer) Terminate() error
  • func (o *Syncer) TuShare_khistory(phrase string, work *ProfileWork) (interface{}, error)
  • func (o Syncer) TuShare_request(work *ProfileWork, fields []string, requestargs map[string]interface{}) (ret []interface{}, err error)
  • func (o *Syncer) TuShare_stock_group(phrase string, work *ProfileWork) (interface{}, error)
  • func (o *Syncer) TuShare_trade_calendar(phrase string, work *ProfileWork) (interface{}, error)
• type SyncerMapperFunc

Constants

const SHOWAPI_FETCH_META_TOKEN = "meta."

Types

type ProfileRunInfo

type ProfileRunInfo struct {
	RunCount     int
	LastRunTime  int64
	LastEndTime  int64
	LastRunError error
}

type ProfileWork

type ProfileWork struct {
	Id          interface{}
	Dao         qdao.D
	ProfileName string
	Profile     map[string]interface{}
	StartTime   int64
	EndTime     int64
	Force       bool
	Factor      float64
	Context     *Syncer
	GCmd        *global.Cmd
	Args        map[string]interface{}
	Mapper      SyncerMapperFunc
}

func (*ProfileWork) GetDao

func (o *ProfileWork) GetDao() (dao qdao.D, err error)

type Syncer

type Syncer struct {
	Name string
	// contains filtered or unexported fields
}

func (*Syncer) DoProfile

func (o *Syncer) DoProfile(work *ProfileWork) (data []interface{}, err error)

func (*Syncer) DoProfileRecover

func (o *Syncer) DoProfileRecover(work *ProfileWork)

func (*Syncer) DoProfileWithRecord

func (o *Syncer) DoProfileWithRecord(work *ProfileWork) (ferr error)

func (*Syncer) GetMetaToken

func (o *Syncer) GetMetaToken(profilename string) string

func (*Syncer) GetProfile

func (o *Syncer) GetProfile(name string) map[string]interface{}

func (*Syncer) GetProfileRunInfo

func (o *Syncer) GetProfileRunInfo(profilename string) *ProfileRunInfo

func (*Syncer) HandleCmd

func (o *Syncer) HandleCmd(cmd *global.Cmd) (*global.Cmd, bool, error)

func (*Syncer) Lua_handler

func (o *Syncer) Lua_handler(phrase string, work *ProfileWork) (interface{}, error)

func (Syncer) Lua_request

func (o Syncer) Lua_request(
	work *ProfileWork,
	fields []string,
	requestargs map[string]interface{}) (ret []interface{}, err error)

func (*Syncer) Netease_khistory

func (o *Syncer) Netease_khistory(phrase string, work *ProfileWork) (interface{}, error)

func (Syncer) Netease_request

func (o Syncer) Netease_request(
	work *ProfileWork,
	fields []string,
	requestargs map[string]interface{}) (data []interface{}, ids []interface{}, err error)

func (*Syncer) Netease_snapshot

func (o *Syncer) Netease_snapshot(
	phrase string, work *ProfileWork) (err error)

func (*Syncer) PersistAndCache

func (o *Syncer) PersistAndCache(
	work *ProfileWork,
	data []interface{}) (rdata []interface{}, ids []interface{}, err error)

func (*Syncer) Run

func (o *Syncer) Run(name string)

func (Syncer) ShenJian_request

func (o Syncer) ShenJian_request(
	work *ProfileWork,
	fields []string,
	requestargs map[string]interface{}) (data []interface{}, ids []interface{}, err error)

func (*Syncer) ShenJian_snapshot

func (o *Syncer) ShenJian_snapshot(
	phrase string, work *ProfileWork) (err error)

func (*Syncer) ShowAPI_khistory

func (o *Syncer) ShowAPI_khistory(phrase string, work *ProfileWork) (err error)

func (*Syncer) ShowAPI_request

func (o *Syncer) ShowAPI_request(
	work *ProfileWork,
	requestargs map[string]interface{}) (interface{}, error)

func (*Syncer) ShowAPI_snapshot

func (o *Syncer) ShowAPI_snapshot(
	phrase string, work *ProfileWork) (err error)

func (*Syncer) Terminate

func (o *Syncer) Terminate() error

func (*Syncer) TuShare_khistory

func (o *Syncer) TuShare_khistory(phrase string, work *ProfileWork) (interface{}, error)

func (Syncer) TuShare_request

func (o Syncer) TuShare_request(
	work *ProfileWork,
	fields []string,
	requestargs map[string]interface{}) (ret []interface{}, err error)

func (*Syncer) TuShare_stock_group

func (o *Syncer) TuShare_stock_group(phrase string, work *ProfileWork) (interface{}, error)

func (*Syncer) TuShare_trade_calendar

func (o *Syncer) TuShare_trade_calendar(phrase string, work *ProfileWork) (interface{}, error)

type SyncerMapperFunc

type SyncerMapperFunc func(data interface{}) interface{}