Documentation
¶
Index ¶
- func BroadcastStatus()
- func BroadcastWS(tag string, msg map[string]interface{})
- func GetSymbolsHandler(c *fiber.Ctx) error
- func MergeConfig(inText string, skips ...string) (string, error)
- func Run(args []string) error
- func RunDataTools(args *DataToolsArgs) *errs.Error
- type CmdArgs
- type DataToolsArgs
- type DataToolsManager
- type FileNode
- type FnDataTool
- type ServerStatus
- type WsClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BroadcastStatus ¶
func BroadcastStatus()
func BroadcastWS ¶
func GetSymbolsHandler ¶ added in v0.2.18
GetSymbolsHandler 获取交易品种列表
Types ¶
type DataToolsArgs ¶
type DataToolsArgs struct {
Action string `json:"action" validate:"required"`
Folder string `json:"folder"`
Exchange string `json:"exchange"`
ExgReal string `json:"exgReal"`
Market string `json:"market"`
Exg banexg.BanExchange
Pairs []string `json:"pairs"`
Periods []string `json:"periods"`
StartMs int64 `json:"startMs"`
EndMs int64 `json:"endMs"`
Force bool `json:"force"`
Concurrency int `json:"concurrency"`
Config string `json:"config"`
}
type DataToolsManager ¶
type DataToolsManager struct {
// contains filtered or unexported fields
}
DataToolsManager 数据工具任务管理器
type FileNode ¶
type FileNode struct {
Path string `json:"path"` // 相对路径
Size int64 `json:"size,omitempty"` // 文件大小(文件夹时忽略)
Stamp int64 `json:"stamp,omitempty"` // 最后修改时间戳(文件夹时忽略)
}
FileNode 表示文件树的节点
type FnDataTool ¶ added in v0.1.21
type FnDataTool = func(args *DataToolsArgs, pBar *utils.StagedPrg) *errs.Error
type ServerStatus ¶
type WsClient ¶
type WsClient struct {
Conn *websocket.Conn
Tags map[string]interface{}
// contains filtered or unexported fields
}
func NewWsClient ¶
func (*WsClient) HandleForever ¶
func (c *WsClient) HandleForever()
Click to show internal directories.
Click to hide internal directories.