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 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
• type Exchange
• type ExchangeConf
• type Grid
• type GridStrategyConf
• type HistoryConf
• type MongoConf
• type MySQLConf
• type RestAPI
• type RestGridStrategyConf
• type SQLiteConf
• type Ticker
• type WsAPI

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 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

type Exchange

type Exchange interface {
	RestAPI
	WsAPI
}

common exchange interface, for all symbols, all crypto-exchanges

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 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 RestAPI

type RestAPI interface {
	GetSpotBalance() (map[string]decimal.Decimal, error)
	GetCandle(symbol, clientId, period string, from, to time.Time) (Candle, error)

	PlaceOrder(orderType, symbol, clientOrderId string, price, amount decimal.Decimal) (uint64, error)
	CancelOrder(orderId uint64) error
}

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
}

type WsAPI

type WsAPI interface {
	SubscribeCandlestick(ctx context.Context, symbol, clientId string, responseHandler websocketclientbase.ResponseHandler)
}