services

Documentation

Index

• Constants
• Variables
• func CheckoutCanSellStockList(sellStrategyId uint64, holdings []string) []string
• func DaemonService()
• func IsTrading(status int) bool
• func PrintJobList()
• func Register(name, spec string, callback func()) error
• type Task

Constants

const (
	// CronTriggerNetwork 网络重置每天8点55分
	CronTriggerNetwork = "55 8 * * *"
	// CronTriggerInit 定制任务初始化cron定位9点
	CronTriggerInit = "0 9 * * *"
	// CronDefaultInterval 默认的执行频次
	CronDefaultInterval = "@every 10s"
	// CronTickInterval tick级别数据的更新频次
	CronTickInterval = "@every 1s"
)

Variables

var (
	ErrAlreadyExists = errors.New("the job already exists") // 任务已经存在
	ErrForbidden     = errors.New("the job was forbidden")  // 任务被禁止
)

Functions

func CheckoutCanSellStockList

func CheckoutCanSellStockList(sellStrategyId uint64, holdings []string) []string

CheckoutCanSellStockList 捡出T+HoldingPeriod日的股票列表

func DaemonService

func DaemonService()

DaemonService 守护进程服务入口

func IsTrading

func IsTrading(status int) bool

IsTrading 状态是否交易中

func PrintJobList

func PrintJobList()

PrintJobList 输出定时任务列表

func Register

func Register(name, spec string, callback func()) error

Register 注册定时任务

Types

type Task

type Task struct {
	Service func() // 任务函数
	// contains filtered or unexported fields
}

Task 定时任务

默认每10秒检测1次
排名不分先后