hs

README

hs

hs golang utils lib

Documentation

Index

• Constants
• func ConnectMongo(ctx context.Context, conf MongoConf) (*mongo.Database, error)
• func IsDuplicateError(err error) bool
• func MergeTick(o1, h1, l1, c1, v1, o2, h2, l2, c2, v2 float64) (open, high, low, close, volume float64)
• func NewZapLogger(level string, outputPaths, errorPaths []string) (*zap.Logger, error)
• func ParseJsonConfig(filename string, config interface{}) error
• type BroadcastConf
• type Candle
  • func NewCandle(capacity int) Candle
  • func (c *Candle) Add(other Candle)
  • func (c *Candle) Append(ticker Ticker)
  • func (c Candle) Length() int
  • func (c *Candle) Truncate()
• type ExchangeConf
• type Grid
• type GridStrategyConf
• type HistoryConf
• type LogConf
• type MongoConf
• type MySQLConf
• type RestGridStrategyConf
• type SQLiteConf
• type Ticker

Constants

const (
	GateIO = "gate"
	MXC    = "mxc"
	OKEx   = "okex"
	Huobi  = "huobi"
)

Functions

func ConnectMongo

func ConnectMongo(ctx context.Context, conf MongoConf) (*mongo.Database, error)

func IsDuplicateError

func IsDuplicateError(err error) bool

func MergeTick

func MergeTick(o1, h1, l1, c1, v1, o2, h2, l2, c2, v2 float64) (open, high, low, close, volume float64)

func NewZapLogger

func NewZapLogger(level string, outputPaths, errorPaths []string) (*zap.Logger, error)

func ParseJsonConfig

func ParseJsonConfig(filename string, config interface{}) error

Types

type BroadcastConf

type BroadcastConf = broadcast.Config

type Candle

type Candle struct {
	Capacity  int
	Timestamp []int64 // unix timestamp in seconds
	Open      []float64
	High      []float64
	Low       []float64
	Close     []float64
	Volume    []float64
}

func NewCandle

func NewCandle(capacity int) Candle

func (*Candle) Add

func (c *Candle) Add(other Candle)

func (*Candle) Append

func (c *Candle) Append(ticker Ticker)

func (Candle) Length

func (c Candle) Length() int

func (*Candle) Truncate

func (c *Candle) Truncate()

type ExchangeConf

type ExchangeConf struct {
	Name    string // see const below
	Label   string
	Symbols []string
	Key     string
	Secret  string
	Host    string
}

type Grid

type Grid struct {
	Id         int
	Price      decimal.Decimal
	AmountBuy  decimal.Decimal
	AmountSell decimal.Decimal
	TotalBuy   decimal.Decimal
	Order      uint64
}

type GridStrategyConf

type GridStrategyConf struct {
	MaxPrice float64
	MinPrice float64
	Number   int
	Total    float64
}

type HistoryConf

type HistoryConf struct {
	Prefix   string
	Interval string
}

type LogConf

type LogConf struct {
	Level   string
	Outputs []string
	Errors  []string
}

type MongoConf

type MongoConf struct {
	// mongodb://[username:password@]host1[:port1][,...hostN[:portN]][/[defaultauthdb][?options]]
	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"`
}

type RestGridStrategyConf

type RestGridStrategyConf struct {
	MaxPrice  float64
	MinPrice  float64
	Number    int
	Total     float64
	Rebalance bool
	Interval  string // sleep interval
}

type SQLiteConf

type SQLiteConf struct {
	Location string
}

type Ticker

type Ticker struct {
	Timestamp int64 // unix timestamp in seconds
	Open      float64
	High      float64
	Low       float64
	Close     float64
	Volume    float64
}