service

Documentation

Index

• Variables
• func BuildRangeCode() chan string
• func DeleteMetadataByDate(db *mongo.Client, code, date string, timeout time.Duration) (int64, error)
• func FetchMetadataFromLog(path string) (chan *model.Metadata, error)
• func FetchMetadataFromSina(codes []string) ([]*model.Metadata, error)
• func InsertMetadataMany(db *mongo.Client, metadata []*model.Metadata, timeout time.Duration) (int64, error)
• func SelectMetadataRange(db *mongo.Client, offset, limit int64, date string, lastID string, ...) ([]*model.Metadata, error)

Variables

var (
	ErrNoStockCode = fmt.Errorf("no exist stock code in Sina API")
	ErrNoStockData = fmt.Errorf("no stock data")
)

var CodeList = []string{
	"sh688***",
	"sh605***",
	"sh603***",
	"sh601***",
	"sh600***",
	"sz300***",
	"sz0030**",
	"sz002***",
	"sz000***",
}

Functions

func BuildRangeCode

func BuildRangeCode() chan string

func DeleteMetadataByDate

func DeleteMetadataByDate(db *mongo.Client, code, date string, timeout time.Duration) (int64, error)

func FetchMetadataFromLog

func FetchMetadataFromLog(path string) (chan *model.Metadata, error)

FetchMetadataFromSina fetch data from sina

func FetchMetadataFromSina

func FetchMetadataFromSina(codes []string) ([]*model.Metadata, error)

FetchMetadataFromSina fetch data from sina

func InsertMetadataMany

func InsertMetadataMany(db *mongo.Client, metadata []*model.Metadata, timeout time.Duration) (int64, error)

func SelectMetadataRange

func SelectMetadataRange(db *mongo.Client, offset, limit int64, date string, lastID string, timeout time.Duration) ([]*model.Metadata, error)