Versions in this module Expand all Collapse all v0 v0.0.2 Mar 21, 2024 v0.0.1 Mar 13, 2024 Changes in this version + var ERR_INVALID_AMOUNT = errors.New("err_invalid_amount") + var ERR_NO_ENOUGH_BALANCE = errors.New("err_no_enough_balance") + var LpName = "lp-golang" + var LpVersion = "v0.5.1" + func LpToAddMsg(lp coreSchema.Lp) routerSchema.LpMsgAdd + func LpToRemoveMsg(lp coreSchema.Lp) routerSchema.LpMsgRemove + type Lp struct + func New(chainID int64, apiEnabled bool, rsdk *RSDK) *Lp + func (l *Lp) Close() + func (l *Lp) Run(configPath string) + func (l *Lp) UpdateLiquidity() error + type RSDK struct + AccID string + EverSDK *sdk.SDK + func NewRSDK(wsURL, httpURL string, everSDK *sdk.SDK) *RSDK + func (r *RSDK) AddLiquidity(msg schema.LpMsgAdd) error + func (r *RSDK) Close() + func (r *RSDK) GetBalance(tokenTag string) (amount string, err error) + func (r *RSDK) GetInfo() (info schema.InfoRes, err error) + func (r *RSDK) GetLps() (lps []coreSchema.Lp, err error) + func (r *RSDK) RejectOrder(msg schema.LpMsgOrder) error + func (r *RSDK) RemoveLiquidity(msg schema.LpMsgRemove) error + func (r *RSDK) SignOrder(msg schema.LpMsgOrder) error + func (r *RSDK) SubscribeLpAddResponseOnce() <-chan *schema.LpMsgAddResponse + func (r *RSDK) SubscribeLpRemoveResponseOnce() <-chan *schema.LpMsgRemoveResponse + func (r *RSDK) SubscribeOrder() <-chan *schema.LpMsgOrder + func (r *RSDK) SubscribeOrderStatus() <-chan *schema.OrderMsgStatus + func (r *RSDK) SubscribeReconnect() <-chan struct{} + type WDB struct + func NewWDB(dbDir string) *WDB + func (w *WDB) CreateOrder(order *schema.Order, tx *gorm.DB) error + func (w *WDB) GetOrders(page, count int) (orders []*schema.Order, err error) + func (w *WDB) Migrate()
Go to main page