structs

Documentation

Index

• type PairPrice
• type PurchaseInfo
  • func GetUserPurchasesByTokenPair(rdb *redis.Client, tokenAddress, baseAddress string) ([]PurchaseInfo, error)
  • func (purchase *PurchaseInfo) HasPurchasedToken(rdb *redis.Client) (bool, error)
  • func (purchase *PurchaseInfo) RemovePurchaseInfoFromRedis(rdb *redis.Client) error
  • func (purchase *PurchaseInfo) SavePurchaseInfoToRedis(rdb *redis.Client) error
• type ReadyTrade
  • func (r *ReadyTrade) Send(rdb *redis.Client, ec *ethclient.Client) (*types.Transaction, error)
• type TokenPair
  • func GetAllDistinctTokenPairs(rdb *redis.Client) ([]TokenPair, error)
  • func GetAllPurchasedTokenPairsForUser(rdb *redis.Client, userBotSettingID string) ([]TokenPair, error)
• type TradeSend
• type TransactionData
  • func (t TransactionData) MarshalJSON() ([]byte, error)
  • func (t *TransactionData) ToMessage() string
  • func (t *TransactionData) UnmarshalJSON(data []byte) error
• type UserBotSetting
  • func GetUserBotSettingById(id string, rds *redis.Client) (*UserBotSetting, error)
  • func MapToUserBotSetting(setting map[string]string) (*UserBotSetting, error)
  • func (s *UserBotSetting) AnalyzeTransaction(t TransactionData, client *ethclient.Client, rds *redis.Client) (*ReadyTrade, error)
  • func (s *UserBotSetting) SellAllTransaction(rdb *redis.Client, client *ethclient.Client) ([]*ReadyTrade, error)
  • func (s *UserBotSetting) StopWinTransaction(price *big.Float, purchase PurchaseInfo, token *token.Token) (*ReadyTrade, error)
  • func (s *UserBotSetting) UnmarshalJSON(data []byte) error

Types

type PairPrice

type PairPrice struct {
	TokenAddress string `json:"token_address"`
	BaseAddress  string `json:"base_address"`
	Price        string `json:"price"`
}

type PurchaseInfo

type PurchaseInfo struct {
	UserBotSettingID string `json:"user_bot_setting_id"`
	TokenAddress     string `json:"token_address"`
	BaseAddress      string `json:"base_address"`
	PurchasePrice    string `json:"purchase_price"`
	Time             int64  `json:"time"`
}

func GetUserPurchasesByTokenPair

func GetUserPurchasesByTokenPair(rdb *redis.Client, tokenAddress, baseAddress string) ([]PurchaseInfo, error)

获取某个代币对下的所有买入信息

func (*PurchaseInfo) HasPurchasedToken

func (purchase *PurchaseInfo) HasPurchasedToken(rdb *redis.Client) (bool, error)

func (*PurchaseInfo) RemovePurchaseInfoFromRedis

func (purchase *PurchaseInfo) RemovePurchaseInfoFromRedis(rdb *redis.Client) error

删除买入信息

func (*PurchaseInfo) SavePurchaseInfoToRedis

func (purchase *PurchaseInfo) SavePurchaseInfoToRedis(rdb *redis.Client) error

第一次买入，存入 redis

type ReadyTrade

type ReadyTrade struct {
	Token0      string `json:"token0"`
	Token1      string `json:"token1"`
	DefiAddress string `json:"defi_address"`
	ChainId     int64  `json:"chain_id"`
	Amount      string `json:"amount"`
	Account     string `json:"account"`
	IsBuy       bool   `json:"is_buy"`
	SettingId   string `json:"setting_id"`
	Type        int8   `json:"type"` // 1-正常分析(百分比买卖) 2-止盈分析(涨幅超过用户设置的全部卖出) 3-停止运行全部卖出
}

func (*ReadyTrade) Send

func (r *ReadyTrade) Send(rdb *redis.Client, ec *ethclient.Client) (*types.Transaction, error)

type TokenPair

type TokenPair struct {
	TokenAddress string
	BaseAddress  string
}

func GetAllDistinctTokenPairs

func GetAllDistinctTokenPairs(rdb *redis.Client) ([]TokenPair, error)

获取平台所有已买入的代币对

func GetAllPurchasedTokenPairsForUser

func GetAllPurchasedTokenPairsForUser(rdb *redis.Client, userBotSettingID string) ([]TokenPair, error)

获取用户的所有币对儿

type TradeSend

type TradeSend struct {
	Transaction *types.Transaction
	Token0      common.Address
	Token1      common.Address
	DefiAddress common.Address
	Price       *big.Float
	Setting     *UserBotSetting
	IsBuy       bool
	Error       error
}

type TransactionData

type TransactionData struct {
	ChainId     *big.Int
	Hash        common.Hash
	From        common.Address
	To          common.Address
	Value       *big.Int
	Gas         uint64
	GasPrice    *big.Int
	Data        string
	BlockNumber *big.Int
}

交易

func (TransactionData) MarshalJSON

func (t TransactionData) MarshalJSON() ([]byte, error)

func (*TransactionData) ToMessage

func (t *TransactionData) ToMessage() string

func (*TransactionData) UnmarshalJSON

func (t *TransactionData) UnmarshalJSON(data []byte) error

type UserBotSetting

type UserBotSetting struct {
	ID              int64          `json:"id"`
	WhaleAddress    common.Address `json:"whale_address"`
	WhaleName       string         `json:"whale_name"`
	ChainID         *big.Int       `json:"chain_id"`
	ListenBase      string         `json:"listen_base"`
	MinWethAmount   *big.Int       `json:"min_weth_amount"`
	MinBusdAmount   *big.Int       `json:"min_busd_amount"`
	MinUsdtAmount   *big.Int       `json:"min_usdt_amount"`
	MinUsdcAmount   *big.Int       `json:"min_usdc_amount"`
	SellAllWethLine *big.Int       `json:"sell_all_weth_line"`
	SellAllBusdLine *big.Int       `json:"sell_all_busd_line"`
	SellAllUsdtLine *big.Int       `json:"sell_all_usdt_line"`
	SellAllUsdcLine *big.Int       `json:"sell_all_usdc_line"`
	StopAt          int64          `json:"stop_at"`
	IsSellAll       int8           `json:"is_sell_all"`
	StopWin         int64          `json:"stop_win"`
	StopWinMin      int64          `json:"stop_win_min"`
	AvoidHoneyPot   int8           `json:"avoid_honey_pot"`
	IsZero          int8           `json:"is_zero"`
	PrivateKey      string         `json:"private_key"`
}

用户配置

func GetUserBotSettingById

func GetUserBotSettingById(id string, rds *redis.Client) (*UserBotSetting, error)

func MapToUserBotSetting

func MapToUserBotSetting(setting map[string]string) (*UserBotSetting, error)

func (*UserBotSetting) AnalyzeTransaction

func (s *UserBotSetting) AnalyzeTransaction(t TransactionData, client *ethclient.Client, rds *redis.Client) (*ReadyTrade, error)

分析交易

func (*UserBotSetting) SellAllTransaction

func (s *UserBotSetting) SellAllTransaction(rdb *redis.Client, client *ethclient.Client) ([]*ReadyTrade, error)

全部卖出- 停止跟单

func (*UserBotSetting) StopWinTransaction

func (s *UserBotSetting) StopWinTransaction(price *big.Float, purchase PurchaseInfo, token *token.Token) (*ReadyTrade, error)

止盈交易 price 现在价格 purchase 购买信息 token 要卖出的代币

func (*UserBotSetting) UnmarshalJSON

func (s *UserBotSetting) UnmarshalJSON(data []byte) error