biz

Jan 16, 2025

Changes in this version

+ func RefreshJobs(pairs []string, pairTfScores map[string]map[string]float64, showLog bool, ...) (map[string]map[string]int, *errs.Error)

+ func RefreshPairs(showLog bool, pBar *utils.StagedPrg) ([]string, map[string]map[string]float64, *errs.Error)

+ func RestoreVars(backup *VarsBackup)

+ type FnOdCb = func(od *ormo.InOutOrder, isEnter bool)

type IOrderMgr

+ ExitAndFill func(sess *ormo.Queries, orders []*ormo.InOutOrder, req *strat.ExitReq) *errs.Error

+ RelayOrders func(sess *ormo.Queries, orders []*ormo.InOutOrder) *errs.Error

type LiveOrderMgr

+ func (o *LiveOrderMgr) ExitAndFill(sess *ormo.Queries, orders []*ormo.InOutOrder, req *strat.ExitReq) *errs.Error

type LocalOrderMgr

+ func (o *LocalOrderMgr) ExitAndFill(sess *ormo.Queries, orders []*ormo.InOutOrder, req *strat.ExitReq) *errs.Error

type OrderMgr

+ func (o *OrderMgr) RelayOrders(sess *ormo.Queries, orders []*ormo.InOutOrder) *errs.Error

+ type VarsBackup struct

+ AccInfoJobs map[string]map[string]map[string]*strat.StratJob

+ AccJobs map[string]map[string]map[string]*strat.StratJob

+ AccLiveOdMgrs map[string]*LiveOrderMgr

+ AccOdMgrs map[string]IOrderMgr

+ AccWallets map[string]*BanWallets

+ BatchTasks map[string]*strat.BatchMap

+ Envs map[string]*ta.BarEnv

+ ForbidJobs map[string]map[string]bool

+ HistODs []*ormo.InOutOrder

+ LastBarMs int64

+ LastBatchMS int64

+ NoEnterUntil map[string]int64

+ OdBooks map[string]*banexg.OrderBook

+ OrmoBackup *ormo.VarsBackup

+ PairCopiedMs map[string][2]int64

+ PairMap map[string]bool

+ PairStrats map[string]map[string]*strat.TradeStrat

+ Pairs []string

+ TfPairHits map[string]map[string]int

+ func BackupVars() *VarsBackup

Dec 31, 2024

Changes in this version

+ func InitDataDir() *errs.Error

Dec 29, 2024

Changes in this version

+ func GetAllOdMgr() map[string]IOrderMgr

Dec 27, 2024

Changes in this version

+ func SetupComsExg(args *config.CmdArgs) *errs.Error

type OrderMgr

+ BarMS int64

Oct 30, 2024

Changes in this version

+ func RunHistKline(args *RunHistArgs) *errs.Error

+ type RunHistArgs struct

+ End int64

+ ExsList []*orm.ExSymbol

+ OnBar func(bar *orm.InfoKline, nexts []*orm.InfoKline)

+ OnEnvEnd func(bar *banexg.PairTFKline, adj *orm.AdjInfo)

+ Start int64

+ TfWarms map[string]int

+ VerCh chan int

+ ViewNextNum int

Sep 30, 2024

Changes in this version

+ const AmtDust

+ var AInfer_ServiceDesc = grpc.ServiceDesc

+ var FeaFeeder_ServiceDesc = grpc.ServiceDesc

+ var FeaGenerators = map[string]FnFeaStream

+ var File_aifea_proto protoreflect.FileDescriptor

+ func AddBatchJob(account, tf string, job *strat.StratJob, isInfo bool)

+ func AutoRefreshPairs(dp data.IProvider)

+ func CalcCorrelation(args *config.CmdArgs) *errs.Error

+ func CleanUpOdMgr() *errs.Error

+ func ExportAdjFactors(args *config.CmdArgs) *errs.Error

+ func ExportKlines(args *config.CmdArgs) *errs.Error

+ func InitFakeWallets(symbols ...string)

+ func InitLiveOrderMgr(callBack func(od *orm.InOutOrder, isEnter bool))

+ func InitLocalOrderMgr(callBack func(od *orm.InOutOrder, isEnter bool))

+ func InitOdSubs()

+ func LoadCalendars(args *config.CmdArgs) *errs.Error

+ func LoadRefreshPairs(dp data.IProvider) *errs.Error

+ func LoadZipKline(inPath string, fid int, file *zip.File, arg interface{}) *errs.Error

+ func MakeCheckFatalStop(maxIntv int) func()

+ func PurgeKlines(args *config.CmdArgs) *errs.Error

+ func RegisterAInferServer(s grpc.ServiceRegistrar, srv AInferServer)

+ func RegisterFeaFeederServer(s grpc.ServiceRegistrar, srv FeaFeederServer)

+ func ResetVars()

+ func RunDataServer(args *config.CmdArgs) *errs.Error

+ func SetupComs(args *config.CmdArgs) *errs.Error

+ func StartLiveOdMgr()

+ func TryFireBatches(currMS int64) int

+ func VerifyTriggerOds()

+ func WatchLiveBalances()

+ type AInferClient interface

+ Trade func(ctx context.Context, in *ArrMap, opts ...grpc.CallOption) (*ArrMap, error)

+ Trend func(ctx context.Context, in *ArrMap, opts ...grpc.CallOption) (*ArrMap, error)

+ func NewAInferClient(cc grpc.ClientConnInterface) AInferClient

+ type AInferServer interface

+ Trade func(context.Context, *ArrMap) (*ArrMap, error)

+ Trend func(context.Context, *ArrMap) (*ArrMap, error)

+ type ArrMap struct

+ Codes []string

+ Mats map[string]*NumArr

+ func (*ArrMap) Descriptor() ([]byte, []int)

+ func (*ArrMap) ProtoMessage()

+ func (x *ArrMap) GetCodes() []string

+ func (x *ArrMap) GetMats() map[string]*NumArr

+ func (x *ArrMap) ProtoReflect() protoreflect.Message

+ func (x *ArrMap) Reset()

+ func (x *ArrMap) String() string

+ type BanWallets struct

+ Account string

+ IsWatch bool

+ Items map[string]*ItemWallet

+ func GetWallets(account string) *BanWallets

+ func (w *BanWallets) AvaLegal(symbols []string) float64

+ func (w *BanWallets) Cancel(odKey string, symbol string, addAmount float64, fromPending bool)

+ func (w *BanWallets) ConfirmOdEnter(od *orm.InOutOrder, enterPrice float64)

+ func (w *BanWallets) ConfirmOdExit(od *orm.InOutOrder, exitPrice float64)

+ func (w *BanWallets) ConfirmPending(odKey string, srcKey string, srcAmount float64, tgtKey string, ...) bool

+ func (w *BanWallets) CostAva(odKey string, symbol string, amount float64, negative bool, minRate float64) (float64, *errs.Error)

+ func (w *BanWallets) CostFrozen(odKey string, symbol string, amount float64) float64

+ func (w *BanWallets) CutPart(srcKey string, tgtKey string, symbol string, rate float64)

+ func (w *BanWallets) DumpAvas() map[string]float64

+ func (w *BanWallets) EnterOd(od *orm.InOutOrder) (float64, *errs.Error)

+ func (w *BanWallets) ExitOd(od *orm.InOutOrder, baseAmount float64)

+ func (w *BanWallets) FiatValue(withUpol bool, symbols ...string) float64

+ func (w *BanWallets) Get(code string) *ItemWallet

+ func (w *BanWallets) GetAmountByLegal(symbol string, legalCost float64) float64

+ func (w *BanWallets) GetWithdrawLegal(symbols []string) float64

+ func (w *BanWallets) SetWallets(data map[string]float64)

+ func (w *BanWallets) TotalLegal(symbols []string, withUPol bool) float64

+ func (w *BanWallets) TryUpdateStakePctAmt()

+ func (w *BanWallets) UnrealizedPOLLegal(symbols []string) float64

+ func (w *BanWallets) UpdateOds(odList []*orm.InOutOrder, currency string) *errs.Error

+ func (w *BanWallets) WithdrawLegal(amount float64, symbols []string)

+ type DataServer struct

+ func (s *DataServer) SubFeatures(req *SubReq, rsp FeaFeeder_SubFeaturesServer) error

+ type FeaFeederClient interface

+ SubFeatures func(ctx context.Context, in *SubReq, opts ...grpc.CallOption) (FeaFeeder_SubFeaturesClient, error)

+ func NewFeaFeederClient(cc grpc.ClientConnInterface) FeaFeederClient

+ type FeaFeederServer interface

+ SubFeatures func(*SubReq, FeaFeeder_SubFeaturesServer) error

+ type FeaFeeder_SubFeaturesClient interface

+ Recv func() (*ArrMap, error)

+ type FeaFeeder_SubFeaturesServer interface

+ Send func(*ArrMap) error

+ type FnFeaStream = func(exsList []*orm.ExSymbol, req *SubReq, rsp FeaFeeder_SubFeaturesServer) error

+ type FuncApplyMyTrade = func(od *orm.InOutOrder, subOd *orm.ExOrder, trade *banexg.MyTrade) *errs.Error

+ type FuncHandleIOrder = func(order *orm.InOutOrder) *errs.Error

+ type FuncHandleMyOrder = func(trade *banexg.Order) bool

+ type IOrderMgr interface

+ CleanUp func() *errs.Error

+ EnterOrder func(sess *orm.Queries, env *banta.BarEnv, req *strat.EnterReq, doCheck bool) (*orm.InOutOrder, *errs.Error)

+ ExitOpenOrders func(sess *orm.Queries, pairs string, req *strat.ExitReq) ([]*orm.InOutOrder, *errs.Error)

+ ExitOrder func(sess *orm.Queries, od *orm.InOutOrder, req *strat.ExitReq) (*orm.InOutOrder, *errs.Error)

+ OnEnvEnd func(bar *banexg.PairTFKline, adj *orm.AdjInfo) *errs.Error

+ ProcessOrders func(sess *orm.Queries, env *banta.BarEnv, enters []*strat.EnterReq, ...) ([]*orm.InOutOrder, []*orm.InOutOrder, *errs.Error)

+ UpdateByBar func(allOpens []*orm.InOutOrder, bar *orm.InfoKline) *errs.Error

+ func GetOdMgr(account string) IOrderMgr

+ type IOrderMgrLive interface

+ ConsumeOrderQueue func()

+ SyncExgOrders func() ([]*orm.InOutOrder, []*orm.InOutOrder, []*orm.InOutOrder, *errs.Error)

+ TrialUnMatchesForever func()

+ WatchMyTrades func()

+ type ItemWallet struct

+ Available float64

+ Coin string

+ Frozens map[string]float64

+ Pendings map[string]float64

+ UnrealizedPOL float64

+ UsedUPol float64

+ Withdraw float64

+ func (iw *ItemWallet) FiatValue(withUpol bool) float64

+ func (iw *ItemWallet) Reset()

+ func (iw *ItemWallet) SetFrozen(odKey string, amount float64, withAvailable bool) *errs.Error

+ func (iw *ItemWallet) SetMargin(odKey string, amount float64) *errs.Error

+ func (iw *ItemWallet) Total(withUpol bool) float64

+ type LiveOrderMgr struct

+ func GetLiveOdMgr(account string) *LiveOrderMgr

+ func (o *LiveOrderMgr) CleanUp() *errs.Error

+ func (o *LiveOrderMgr) ConsumeOrderQueue()

+ func (o *LiveOrderMgr) OnEnvEnd(bar *banexg.PairTFKline, adj *orm.AdjInfo) *errs.Error

+ func (o *LiveOrderMgr) ProcessOrders(sess *orm.Queries, env *banta.BarEnv, enters []*strat.EnterReq, ...) ([]*orm.InOutOrder, []*orm.InOutOrder, *errs.Error)

+ func (o *LiveOrderMgr) SyncExgOrders() ([]*orm.InOutOrder, []*orm.InOutOrder, []*orm.InOutOrder, *errs.Error)

+ func (o *LiveOrderMgr) TrialUnMatchesForever()

+ func (o *LiveOrderMgr) WatchLeverages()

+ func (o *LiveOrderMgr) WatchMyTrades()

+ type LocalOrderMgr struct

+ func (o *LocalOrderMgr) CleanUp() *errs.Error

+ func (o *LocalOrderMgr) OnEnvEnd(bar *banexg.PairTFKline, adj *orm.AdjInfo) *errs.Error

+ func (o *LocalOrderMgr) ProcessOrders(sess *orm.Queries, env *banta.BarEnv, enters []*strat.EnterReq, ...) ([]*orm.InOutOrder, []*orm.InOutOrder, *errs.Error)

+ func (o *LocalOrderMgr) UpdateByBar(allOpens []*orm.InOutOrder, bar *orm.InfoKline) *errs.Error

+ type NumArr struct

+ Data []float64

+ Shape []int32

+ func (*NumArr) Descriptor() ([]byte, []int)

+ func (*NumArr) ProtoMessage()

+ func (x *NumArr) GetData() []float64

+ func (x *NumArr) GetShape() []int32

+ func (x *NumArr) ProtoReflect() protoreflect.Message

+ func (x *NumArr) Reset()

+ func (x *NumArr) String() string

+ type OdQItem struct

+ Action string

+ Order *orm.InOutOrder

+ type OrderMgr struct

+ Account string

+ func (o *OrderMgr) CleanUp() *errs.Error

+ func (o *OrderMgr) CutOrder(od *orm.InOutOrder, enterRate, exitRate float64) *orm.InOutOrder

+ func (o *OrderMgr) EnterOrder(sess *orm.Queries, env *banta.BarEnv, req *strat.EnterReq, doCheck bool) (*orm.InOutOrder, *errs.Error)

+ func (o *OrderMgr) ExitOpenOrders(sess *orm.Queries, pairs string, req *strat.ExitReq) ([]*orm.InOutOrder, *errs.Error)

+ func (o *OrderMgr) ExitOrder(sess *orm.Queries, od *orm.InOutOrder, req *strat.ExitReq) (*orm.InOutOrder, *errs.Error)

+ func (o *OrderMgr) ProcessOrders(sess *orm.Queries, env *banta.BarEnv, enters []*strat.EnterReq, ...) ([]*orm.InOutOrder, []*orm.InOutOrder, *errs.Error)

+ func (o *OrderMgr) UpdateByBar(allOpens []*orm.InOutOrder, bar *orm.InfoKline) *errs.Error

+ type PairValItem struct

+ AvgVol float64

+ ExpireMS int64

+ LastVol float64

+ type SubReq struct

+ Codes []string

+ End int64

+ Exchange string

+ Market string

+ Sample int32

+ Start int64

+ Task string

+ func (*SubReq) Descriptor() ([]byte, []int)

+ func (*SubReq) ProtoMessage()

+ func (x *SubReq) GetCodes() []string

+ func (x *SubReq) GetEnd() int64

+ func (x *SubReq) GetExchange() string

+ func (x *SubReq) GetMarket() string

+ func (x *SubReq) GetSample() int32

+ func (x *SubReq) GetStart() int64

+ func (x *SubReq) GetTask() string

+ func (x *SubReq) ProtoReflect() protoreflect.Message

+ func (x *SubReq) Reset()

+ func (x *SubReq) String() string

+ type Trader struct

+ func (t *Trader) ExecOrders(odMgr IOrderMgr, jobs map[string]*strat.StratJob, env *ta.BarEnv, ...) *errs.Error

+ func (t *Trader) FeedKline(bar *orm.InfoKline) *errs.Error

+ func (t *Trader) OnEnvEnd(bar *banexg.PairTFKline, adj *orm.AdjInfo)

+ func (t *Trader) OnEnvJobs(bar *orm.InfoKline) (*ta.BarEnv, *errs.Error)

+ type UnimplementedAInferServer struct

+ func (UnimplementedAInferServer) Trade(context.Context, *ArrMap) (*ArrMap, error)

+ func (UnimplementedAInferServer) Trend(context.Context, *ArrMap) (*ArrMap, error)

+ type UnimplementedFeaFeederServer struct

+ func (UnimplementedFeaFeederServer) SubFeatures(*SubReq, FeaFeeder_SubFeaturesServer) error

+ type UnsafeAInferServer interface

+ type UnsafeFeaFeederServer interface

+ type VolPrice struct

+ BuyPrice float64

+ ExpireMS int64

+ SellPrice float64