dev

package
v0.2.30 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 9, 2026 License: AGPL-3.0 Imports: 39 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BroadcastStatus

func BroadcastStatus()

func BroadcastWS

func BroadcastWS(tag string, msg map[string]interface{})

func GetSymbolsHandler added in v0.2.18

func GetSymbolsHandler(c *fiber.Ctx) error

GetSymbolsHandler 获取交易品种列表

func MergeConfig

func MergeConfig(inText string, skips ...string) (string, error)

func Run

func Run(args []string) error

func RunDataTools

func RunDataTools(args *DataToolsArgs) *errs.Error

RunDataTools 执行数据工具任务

Types

type CmdArgs

type CmdArgs struct {
	Port       int
	Host       string
	Configs    config.ArrString
	ConfigData string
	DataDir    string
	LogLevel   string
	LogFile    string
	TimeZone   string
	DBFile     string
}

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 数据工具任务管理器

func (*DataToolsManager) EndTask

func (m *DataToolsManager) EndTask()

EndTask 结束任务

func (*DataToolsManager) StartTask

func (m *DataToolsManager) StartTask() error

StartTask 开始一个任务

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 ServerStatus struct {
	DirtyBin bool `json:"dirtyBin"`
	Building bool `json:"building"`
}

type WsClient

type WsClient struct {
	Conn *websocket.Conn

	Tags map[string]interface{}
	// contains filtered or unexported fields
}

func NewWsClient

func NewWsClient(c *websocket.Conn) *WsClient

func (*WsClient) Close

func (c *WsClient) Close()

func (*WsClient) HandleForever

func (c *WsClient) HandleForever()

func (*WsClient) WriteMsg

func (c *WsClient) WriteMsg(msg map[string]interface{})

Jump to

Keyboard shortcuts

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