dev

Documentation

Index

• func BroadcastStatus()
• func BroadcastWS(tag string, msg map[string]interface{})
• func MergeConfig(inText string) (string, error)
• func Run(args []string) error
• func RunDataTools(args *DataToolsArgs) *errs.Error
• type CmdArgs
• type DataToolsArgs
• type DataToolsManager
  • func (m *DataToolsManager) EndTask()
  • func (m *DataToolsManager) StartTask() error
• type FileNode
• type ServerStatus
• type WsClient
  • func NewWsClient(c *websocket.Conn) *WsClient
  • func (c *WsClient) Close()
  • func (c *WsClient) HandleForever()
  • func (c *WsClient) WriteMsg(msg map[string]interface{})

Functions

func BroadcastStatus

func BroadcastStatus()

func BroadcastWS

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

func MergeConfig

func MergeConfig(inText 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
	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" validate:"required"`
	ExgReal  string `json:"exgReal"`
	Market   string `json:"market" validate:"required"`
	Exg      banexg.BanExchange
	Pairs    []string `json:"pairs"`
	Periods  []string `json:"periods"`
	StartMs  int64    `json:"startMs"`
	EndMs    int64    `json:"endMs"`
	Force    bool     `json:"force"`
}

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 ServerStatus

type ServerStatus struct {
	BinDirty bool `json:"binDirty"`
	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{})