model

package

v0.0.0-...-292f928 Latest Latest Go to latest Published: Feb 23, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/eviltomorrow/robber-repository

Documentation ¶

Index ¶

Constants
Variables
func QuoteWithDeleteManyByCodesAndDate(exec mysql.Exec, model string, codes []string, date string, ...) (int64, error)
func QuoteWithInsertMany(exec mysql.Exec, model string, data []*Quote, timeout time.Duration) (int64, error)
func StockWithInsertMany(exec mysql.Exec, stocks []*Stock, timeout time.Duration) (int64, error)
func StockWithInsertOrUpdateMany(exec mysql.Exec, stocks []*Stock, timeout time.Duration) (int64, error)
func StockWithSelectMany(exec mysql.Exec, codes []string, timeout time.Duration) (map[string]*Stock, error)
func StockWithUpdateOne(exec mysql.Exec, code string, stock *Stock, timeout time.Duration) (int64, error)
func TaskWithInsertOne(exec mysql.Exec, task *Task, timeout time.Duration) (int64, error)
func TaskWithUpdateOne(exec mysql.Exec, date string, task *Task, timeout time.Duration) (int64, error)
type Quote
- func (q *Quote) String() string
type Stock
- func StockWithSelectRange(exec mysql.Exec, offset, limit int64, timeout time.Duration) ([]*Stock, error)
- func (s *Stock) String() string
type Task
- func TaskWithSelectOne(exec mysql.Exec, date string, timeout time.Duration) (*Task, error)
- func (t *Task) String() string

Constants ¶

View Source

const (
	Day  = "day"
	Week = "week"
)

View Source

const (
	FieldQuoteID              = "id"
	FieldQuoteCode            = "code"
	FieldQuoteOpen            = "open"
	FieldQuoteClose           = "close"
	FieldQuoteHigh            = "high"
	FieldQuoteLow             = "low"
	FieldQuoteYesterdayClosed = "yesterday_closed"
	FieldQuoteVolume          = "volume"
	FieldQuoteAccount         = "account"
	FieldQuoteDate            = "date"
	FieldQuoteNumOfYear       = "num_of_year"
	FieldQuoteXd              = "xd"
	FieldQuoteCreateTimestamp = "create_timestamp"
	FieldQuoteModifyTimestamp = "modify_timestamp"
)

View Source

const (
	FieldStockCode            = "code"
	FieldStockName            = "name"
	FieldStockSuspend         = "suspend"
	FieldStockCreateTimestamp = "create_timestamp"
	FieldStockModifyTimestamp = "modify_timestamp"
)

View Source

const (
	FieldTaskDate            = "date"
	FieldTaskCompleted       = "completed"
	FieldTaskMetadataCount   = "metadata_count"
	FieldTaskStockCount      = "stock_count"
	FieldTaskDayCount        = "day_count"
	FieldTaskWeekCount       = "week_count"
	FieldTaskCallBackURL     = "callback_url"
	FieldTaskCreateTimestamp = "create_timestamp"
	FieldTaskModifyTimestamp = "modify_timestamp"
)

Variables ¶

View Source

var TaskFields = []string{
	FieldTaskDate,
	FieldTaskCompleted,
	FieldTaskMetadataCount,
	FieldTaskStockCount,
	FieldTaskDayCount,
	FieldTaskWeekCount,
	FieldTaskCallBackURL,
	FieldTaskCreateTimestamp,
	FieldTaskModifyTimestamp,
}

Functions ¶

func QuoteWithDeleteManyByCodesAndDate ¶

func QuoteWithDeleteManyByCodesAndDate(exec mysql.Exec, model string, codes []string, date string, timeout time.Duration) (int64, error)

func QuoteWithInsertMany ¶

func QuoteWithInsertMany(exec mysql.Exec, model string, data []*Quote, timeout time.Duration) (int64, error)

func StockWithInsertMany ¶

func StockWithInsertMany(exec mysql.Exec, stocks []*Stock, timeout time.Duration) (int64, error)

func StockWithInsertOrUpdateMany ¶

func StockWithInsertOrUpdateMany(exec mysql.Exec, stocks []*Stock, timeout time.Duration) (int64, error)

func StockWithSelectMany ¶

func StockWithSelectMany(exec mysql.Exec, codes []string, timeout time.Duration) (map[string]*Stock, error)

func StockWithUpdateOne ¶

func StockWithUpdateOne(exec mysql.Exec, code string, stock *Stock, timeout time.Duration) (int64, error)

func TaskWithInsertOne ¶

func TaskWithInsertOne(exec mysql.Exec, task *Task, timeout time.Duration) (int64, error)

func TaskWithUpdateOne ¶

func TaskWithUpdateOne(exec mysql.Exec, date string, task *Task, timeout time.Duration) (int64, error)

Types ¶

type Quote ¶

type Quote struct {
	Id              int64        `json:"id"`
	Code            string       `json:"code"`
	Open            float64      `json:"open"`
	Close           float64      `json:"close"`
	High            float64      `json:"high"`
	Low             float64      `json:"low"`
	YesterdayClosed float64      `json:"yesterday_closed"`
	Volume          uint64       `json:"volume"`
	Account         float64      `json:"account"`
	Date            time.Time    `json:"date"`
	NumOfYear       int          `json:"num_of_year"`
	Xd              float64      `json:"xd"`
	CreateTimestamp time.Time    `json:"create_timestamp"`
	ModifyTimestamp sql.NullTime `json:"modify_timestamp"`
}

func QuoteWithSelectBetweenByCodeAndDate ¶

func QuoteWithSelectBetweenByCodeAndDate(exec mysql.Exec, model string, code string, begin, end string, timeout time.Duration) ([]*Quote, error)

func QuoteWithSelectManyLatest ¶

func QuoteWithSelectManyLatest(exec mysql.Exec, model string, code string, date string, limit int64, timeout time.Duration) ([]*Quote, error)

func QuoteWithSelectOneByCodeAndDate ¶

func QuoteWithSelectOneByCodeAndDate(exec mysql.Exec, model string, code string, date string, timeout time.Duration) (*Quote, error)

func QuoteWithSelectRangeByDate ¶

func QuoteWithSelectRangeByDate(exec mysql.Exec, model string, date string, offset, limit int64, timeout time.Duration) ([]*Quote, error)

func (*Quote) String ¶

func (q *Quote) String() string

type Stock ¶

type Stock struct {
	Code            string       `json:"code"`
	Name            string       `json:"name"`
	Suspend         string       `json:"suspend"`
	CreateTimestamp time.Time    `json:"create_timestamp"`
	ModifyTimestamp sql.NullTime `json:"modify_timestamp"`
}

Stock

func StockWithSelectRange ¶

func StockWithSelectRange(exec mysql.Exec, offset, limit int64, timeout time.Duration) ([]*Stock, error)

func (*Stock) String ¶

func (s *Stock) String() string

type Task ¶

type Task struct {
	Date            string       `json:"date"`
	Completed       int8         `json:"completed"`
	MetadataCount   int64        `json:"metadata_count"`
	StockCount      int64        `json:"stock_count"`
	DayCount        int64        `json:"day_count"`
	WeekCount       int64        `json:"week_count"`
	CallbackURL     string       `json:"callback_url"`
	CreateTimestamp time.Time    `json:"create_timestamp"`
	ModifyTimestamp sql.NullTime `json:"modify_timestamp"`
}

Task

func TaskWithSelectOne ¶

func TaskWithSelectOne(exec mysql.Exec, date string, timeout time.Duration) (*Task, error)

func (*Task) String ¶

func (t *Task) String() string

Source Files ¶

View all Source files

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