common

package

v0.0.5 Latest Latest Go to latest Published: May 7, 2022 License: BSD-3-Clause Imports: 15 Imported by: 23

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ztrade/base

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func Copy(dst, src string) (err error)
func CopyWithMainPkg(dst, src string) (err error)
func FloatAdd(a, b float64) float64
func FloatDiv(a, b float64) float64
func FloatMul(a, b float64) float64
func FloatSub(a, b float64) float64
func FormatFloat(n float64, precision int) float64
func GetBinSizeDuration(str string) (duration time.Duration, err error)
func GetExecDir() string
func MergeKlineChan(klines chan []interface{}, srcDuration, dstDuration time.Duration) (rets chan []interface{})
func OpenURL(strURL string) error
func ParseBinSizes(str string) (durations []time.Duration, err error)
func ParseBinStrs(str string) (strs []string)
type CandleFn
type KlineMerge
- func NewKlineMerge(src, dst time.Duration) *KlineMerge
- func NewKlineMergeStr(src, dst string) *KlineMerge
- func (km *KlineMerge) GetDst() int64
- func (km *KlineMerge) GetDstDuration() time.Duration
- func (km *KlineMerge) GetSrc() int64
- func (km *KlineMerge) GetSrcDuration() time.Duration
- func (km *KlineMerge) IsFirst() bool
- func (km *KlineMerge) NeedMerge() bool
- func (km *KlineMerge) Update(data interface{}) (ret interface{})
type Param
type ParamData
- func (d ParamData) GetFloat(key string, defaultValue float64) float64
- func (d ParamData) GetString(key, defaultValue string) string
type VBalance
- func NewVBalance() *VBalance
- func (b *VBalance) AddTrade(tr Trade) (profit float64, err error)
- func (b *VBalance) Get() (total float64)
- func (b *VBalance) GetFeeTotal() (fee float64)
- func (b *VBalance) Pos() (pos float64)
- func (b *VBalance) Set(total float64)
- func (b *VBalance) SetFee(fee float64)

Constants ¶

View Source

const (
	DefaultBinSizes = "1m, 5m, 15m, 30m, 1h, 4h, 1d"
)

Variables ¶

View Source

var (
	Day  = time.Hour * 24
	Week = time.Hour * 24 * 7
)

View Source

var (
	ErrNoBalance = errors.New("no balance")
)

Functions ¶

func Copy ¶

func Copy(dst, src string) (err error)

func CopyWithMainPkg ¶

func CopyWithMainPkg(dst, src string) (err error)

func FloatAdd ¶

func FloatAdd(a, b float64) float64

FloatAdd return a*b

func FloatDiv ¶

func FloatDiv(a, b float64) float64

FloatDiv return a/b

func FloatMul ¶

func FloatMul(a, b float64) float64

FloatMul return a*b

func FloatSub ¶

func FloatSub(a, b float64) float64

FloatSub return a-b

func FormatFloat ¶

func FormatFloat(n float64, precision int) float64

FormatFloat format float with precision

func GetBinSizeDuration ¶

func GetBinSizeDuration(str string) (duration time.Duration, err error)

GetBinSizeDuration get duration of the binsize

func GetExecDir ¶

func GetExecDir() string

GetExecDir return exec dir

func MergeKlineChan ¶

func MergeKlineChan(klines chan []interface{}, srcDuration, dstDuration time.Duration) (rets chan []interface{})

MergeKlineChan merge kline data

func OpenURL ¶

func OpenURL(strURL string) error

func ParseBinSizes ¶

func ParseBinSizes(str string) (durations []time.Duration, err error)

ParseBinSizes parse binsizes

func ParseBinStrs ¶

func ParseBinStrs(str string) (strs []string)

ParseBinStrs parse binsizes to strs

Types ¶

type CandleFn ¶

type CandleFn func(candle *trademodel.Candle)

type KlineMerge ¶

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

KlineMerge merge kline to new duration

func NewKlineMerge ¶

func NewKlineMerge(src, dst time.Duration) *KlineMerge

NewKlineMerge merge kline constructor

func NewKlineMergeStr ¶

func NewKlineMergeStr(src, dst string) *KlineMerge

NewKlineMergeStr new KlineMerge with string duration

func (*KlineMerge) GetDst ¶

func (km *KlineMerge) GetDst() int64

GetDst return kline dst duration secs

func (*KlineMerge) GetDstDuration ¶

func (km *KlineMerge) GetDstDuration() time.Duration

GetDstDuration get kline dst duration

func (*KlineMerge) GetSrc ¶

func (km *KlineMerge) GetSrc() int64

GetSrc return kline source duration secs

func (*KlineMerge) GetSrcDuration ¶

func (km *KlineMerge) GetSrcDuration() time.Duration

GetSrcDuration get kline source duration

func (*KlineMerge) IsFirst ¶

func (km *KlineMerge) IsFirst() bool

IsFirst is first time

func (*KlineMerge) NeedMerge ¶

func (km *KlineMerge) NeedMerge() bool

NeedMerge is kline need merge

func (*KlineMerge) Update ¶

func (km *KlineMerge) Update(data interface{}) (ret interface{})

Update update candle, and return new kline candle return nil if no new kline candle

type Param ¶

type Param struct {
	Name string
	Type string
	Info string
}

type ParamData ¶

type ParamData map[string]interface{}

func (ParamData) GetFloat ¶

func (d ParamData) GetFloat(key string, defaultValue float64) float64

func (ParamData) GetString ¶

func (d ParamData) GetString(key, defaultValue string) string

type VBalance ¶

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

func NewVBalance ¶

func NewVBalance() *VBalance

func (*VBalance) AddTrade ¶

func (b *VBalance) AddTrade(tr Trade) (profit float64, err error)

func (*VBalance) Get ¶

func (b *VBalance) Get() (total float64)

func (*VBalance) GetFeeTotal ¶

func (b *VBalance) GetFeeTotal() (fee float64)

func (*VBalance) Pos ¶

func (b *VBalance) Pos() (pos float64)

func (*VBalance) Set ¶

func (b *VBalance) Set(total float64)

func (*VBalance) SetFee ¶

func (b *VBalance) SetFee(fee float64)

Source Files ¶

View all Source files

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