node

Documentation

Index

• type Config
• type GridConf
• type History
• type MongoConf
• type MySQLConf
• type Node
  • func New(configFilename string) *Node
  • func (n *Node) Close()
  • func (n *Node) Grid(ctx context.Context) error
  • func (n *Node) Init(ctx context.Context)
  • func (n *Node) Profit(ctx context.Context, label, start, end string) error
  • func (n *Node) PullCandle(ctx context.Context) error
  • func (n *Node) Snapshot(ctx context.Context, label string) error
• type User
• type WsNode
  • func (n *WsNode) Close()
  • func (n *WsNode) Grid(ctx context.Context) error
  • func (n *WsNode) Init(ctx context.Context, cfg Config)
  • func (n *WsNode) Snapshot(ctx context.Context, label string) error
  • func (n *WsNode) SubBalanceForEx(ctx context.Context, ex exchange.Exchange, updateCh chan exchange.Balance)
  • func (n *WsNode) SubscribeBalance(ctx context.Context, label string) error

Types

type Config

type Config struct {
	Users   []User
	Mongo   MongoConf
	MySQL   MySQLConf
	History History
	Grid    GridConf
}

type GridConf

type GridConf struct {
	Interval   string
	Percentage float64
	Fund       float64
	MaxGrid    int
}

type History

type History struct {
	Prefix   string
	Interval string `json:"interval"`
}

type MongoConf

type MongoConf struct {
	URI         string `json:"uri"`
	Database    string `json:"database"`
	MaxPoolSize uint64 `json:"maxPoolSize"`
	MinPoolSize uint64 `json:"minPoolSize"`
	AppName     string `json:"appName"`
}

type MySQLConf

type MySQLConf struct {
	URI   string `json:"uri"`
	Table string
}

type Node

type Node struct {
	// contains filtered or unexported fields
}

func New

func New(configFilename string) *Node

func (*Node) Close

func (n *Node) Close()

func (*Node) Grid

func (n *Node) Grid(ctx context.Context) error

func (*Node) Init

func (n *Node) Init(ctx context.Context)

func (*Node) Profit

func (n *Node) Profit(ctx context.Context, label, start, end string) error

func (*Node) PullCandle

func (n *Node) PullCandle(ctx context.Context) error

func (*Node) Snapshot

func (n *Node) Snapshot(ctx context.Context, label string) error

type User

type User struct {
	Exchange string
	Label    string
	Pair     string // 交易对

	PricePrecision  int     `json:"pricePrecision"`
	AmountPrecision int     `json:"amountPrecision"`
	MinAmount       float64 `json:"minAmount"`

	APIKeyPair exchange.APIKeyPair `json:"APIKeyPair"`
}

type WsNode

type WsNode struct {
	// contains filtered or unexported fields
}

func (*WsNode) Close

func (n *WsNode) Close()

func (*WsNode) Grid

func (n *WsNode) Grid(ctx context.Context) error

func (*WsNode) Init

func (n *WsNode) Init(ctx context.Context, cfg Config)

func (*WsNode) Snapshot

func (n *WsNode) Snapshot(ctx context.Context, label string) error

func (*WsNode) SubBalanceForEx

func (n *WsNode) SubBalanceForEx(ctx context.Context, ex exchange.Exchange, updateCh chan exchange.Balance)

func (*WsNode) SubscribeBalance

func (n *WsNode) SubscribeBalance(ctx context.Context, label string) error