database

package
v1.8.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 27, 2022 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConnectDB 

func ConnectDB(dbName string, mongoAddr string) error

func DBCheckKeyimagesUsed 

func DBCheckKeyimagesUsed(list []string, shardID int) ([]bool, error)

func DBCheckTxsExist 

func DBCheckTxsExist(txList []string, shardID int) ([]bool, error)

func DBCreateClientAssistantIndex added in v1.8.0 

func DBCreateClientAssistantIndex() error

func DBCreateCoinV1Index 

func DBCreateCoinV1Index() error

func DBCreateCoinV2Index 

func DBCreateCoinV2Index() error

func DBCreateInstructionIndex added in v1.8.0 

func DBCreateInstructionIndex() error

func DBCreateKeyimageIndex 

func DBCreateKeyimageIndex() error

func DBCreateLiquidityIndex added in v1.8.0 

func DBCreateLiquidityIndex() error

func DBCreatePNodeDeviceIndex added in v1.8.0 

func DBCreatePNodeDeviceIndex() error

func DBCreateProcessorIndex added in v1.8.0 

func DBCreateProcessorIndex() error

func DBCreateShieldIndex 

func DBCreateShieldIndex() error

func DBCreateTokenIndex added in v1.1.0 

func DBCreateTokenIndex() error

func DBCreateTradeIndex 

func DBCreateTradeIndex() error

func DBCreateTxIndex 

func DBCreateTxIndex() error

func DBCreateTxPendingIndex 

func DBCreateTxPendingIndex() error

func DBDeleteOrderProgress added in v1.8.0 

func DBDeleteOrderProgress(list []shared.LimitOrderStatus) error

func DBDeletePDEPoolData added in v1.8.0 

func DBDeletePDEPoolData(list []shared.PoolInfoData) error

func DBDeletePDEPoolShareData added in v1.8.0 

func DBDeletePDEPoolShareData(list []shared.PoolShareData) error

func DBDeletePDEPoolStakeData added in v1.8.0 

func DBDeletePDEPoolStakeData(list []shared.PoolStakeData) error

func DBDeletePDEPoolStakerData added in v1.8.0 

func DBDeletePDEPoolStakerData(list []shared.PoolStakerData) error

func DBDeletePendingTxs 

func DBDeletePendingTxs(list []string) error

func DBDeleteRewardRecord added in v1.8.0 

func DBDeleteRewardRecord(height uint64) error

func DBFindPair added in v1.8.0 

func DBFindPair(prefix string) ([]shared.PoolInfoData, error)

func DBGetAllCoinV2OfOTAkey added in v1.8.0 

func DBGetAllCoinV2OfOTAkey(shardID int, tokenID, otakey string, offset int64) ([]shared.CoinData, error)

func DBGetAllCustomTokenInfo added in v1.8.0 

func DBGetAllCustomTokenInfo() ([]shared.CustomTokenInfo, error)

func DBGetAllExtraTokenInfo added in v1.8.0 

func DBGetAllExtraTokenInfo() ([]shared.ExtraTokenInfo, error)

func DBGetAllKeyImages 

func DBGetAllKeyImages(tokenID string, shardID int) ([]shared.KeyImageData, error)

func DBGetAllTokenInfo added in v1.8.0 

func DBGetAllTokenInfo() ([]shared.TokenInfoData, error)

func DBGetBasePriceToken added in v1.8.0 

func DBGetBasePriceToken() (string, error)

func DBGetBeaconInstructionByTx added in v1.8.0 

func DBGetBeaconInstructionByTx(txhash string) (*shared.InstructionBeaconData, error)

func DBGetBridgeState added in v1.8.1 

func DBGetBridgeState(version int) (string, error)

func DBGetBridgeTokens added in v1.8.0 

func DBGetBridgeTokens() ([]shared.TokenInfoData, error)

func DBGetCoinInfo 

func DBGetCoinInfo() (map[int]uint64, map[int]uint64, map[int]uint64, map[int]uint64, error)

func DBGetCoinTokenV1OfShardCount added in v1.1.0 

func DBGetCoinTokenV1OfShardCount(shardID int) int64

func DBGetCoinV1ByIndexes 

func DBGetCoinV1ByIndexes(indexes []uint64, shardID int, tokenID string) ([]shared.CoinDataV1, error)

func DBGetCoinV1ByPubkey 

func DBGetCoinV1ByPubkey(tokenID, pubkey string, offset int64, limit int64) ([]shared.CoinData, error)

func DBGetCoinV1OfShardCount 

func DBGetCoinV1OfShardCount(shardID int, tokenID string) int64

func DBGetCoinV1PubkeyInfo 

func DBGetCoinV1PubkeyInfo(key string) (*shared.KeyInfoData, error)

func DBGetCoinV2ByPubkey added in v1.8.0 

func DBGetCoinV2ByPubkey(pubkeys []string) ([]shared.CoinData, error)

func DBGetCoinV2OfOTAkeyCount 

func DBGetCoinV2OfOTAkeyCount(shardID int, tokenID, otakey string) (uint64, error)

func DBGetCoinV2OfShardCount 

func DBGetCoinV2OfShardCount(shardID int, tokenID string) (int64, error)

func DBGetCoinV2PubkeyInfo 

func DBGetCoinV2PubkeyInfo(key string) (*shared.KeyInfoData, error)

func DBGetCoinV2PubkeyInfoByOTAsecret added in v1.8.0 

func DBGetCoinV2PubkeyInfoByOTAsecret(key string) (*shared.KeyInfoData, error)

func DBGetCoinsByIndex 

func DBGetCoinsByIndex(idx uint64, shardID int, tokenID string) (*shared.CoinData, error)

func DBGetCoinsByOTAKey 

func DBGetCoinsByOTAKey(shardID int, tokenID, OTASecret string, offset, limit int64) ([]shared.CoinData, error)

func DBGetCoinsV2ByShardID added in v1.8.0 

func DBGetCoinsV2ByShardID(shardID int, tokenID string, limit, offset int64) ([]shared.CoinData, error)

func DBGetCountTxByPubkey added in v1.1.0 

func DBGetCountTxByPubkey(pubkey string, tokenID string, txversion int) (int64, error)

func DBGetCustomTokenInfoByTokenID added in v1.8.0 

func DBGetCustomTokenInfoByTokenID(tokenids []string) ([]shared.CustomTokenInfo, error)

func DBGetDefaultPool added in v1.8.0 

func DBGetDefaultPool(includeQualify bool) (map[string]struct{}, error)

func DBGetDefaultTokens added in v1.8.0 

func DBGetDefaultTokens() ([]string, error)

func DBGetDeviceByDeviceQRCode added in v1.8.0 

func DBGetDeviceByDeviceQRCode(qrCode string) (*shared.PNodeDevice, error)

func DBGetExtraTokenInfo added in v1.8.0 

func DBGetExtraTokenInfo(tokenID string) (*shared.ExtraTokenInfo, error)

func DBGetExtraTokenInfoByTokenID added in v1.8.0 

func DBGetExtraTokenInfoByTokenID(tokenids []string) ([]shared.ExtraTokenInfo, error)

func DBGetIndexerStats 

func DBGetIndexerStats(indexerID int) (uint64, error)

func DBGetLastCoinV2OfOTAkey added in v1.8.0 

func DBGetLastCoinV2OfOTAkey(shardID int, tokenID, otakey string) (uint64, error)

func DBGetLatestTradeTx added in v1.8.0 

func DBGetLatestTradeTx(isswap bool) ([]shared.TradeOrderData, error)

func DBGetLatestTxByShardID added in v1.1.0 

func DBGetLatestTxByShardID(shardID int, limit int64) ([]shared.TxData, error)

func DBGetLimitOrderStatusByPairID added in v1.8.0 

func DBGetLimitOrderStatusByPairID(pairid string) ([]shared.LimitOrderStatus, error)

func DBGetNFTByOTAKey added in v1.8.0 

func DBGetNFTByOTAKey(shardID int, OTASecret string, offset, limit int64) (map[string][]shared.CoinData, error)

func DBGetNFTCount added in v1.8.0 

func DBGetNFTCount() (int64, error)

func DBGetNFTInfo added in v1.8.0 

func DBGetNFTInfo() ([]shared.TokenInfoData, error)

func DBGetPDEContributeRespond 

func DBGetPDEContributeRespond(address string, limit int64, offset int64) ([]shared.ContributionData, error)

func DBGetPDEPoolPairRewardAPY added in v1.8.0 

func DBGetPDEPoolPairRewardAPY(poolid string) (*shared.RewardAPYTracking, error)

func DBGetPDEState 

func DBGetPDEState(version int) (string, error)

func DBGetPDEStateWithHeight added in v1.8.0 

func DBGetPDEStateWithHeight(version int, height uint64) (*shared.PDEStateData, error)

func DBGetPDETXWithdrawFeeRespond added in v1.8.0 

func DBGetPDETXWithdrawFeeRespond(pubkey []string, limit int64, offset int64) ([]shared.TxData, error)

func DBGetPDETXWithdrawRespond added in v1.8.0 

func DBGetPDETXWithdrawRespond(pubkey []string, limit int64, offset int64) ([]shared.TxData, error)

func DBGetPDEV3ContributeRespond added in v1.8.0 

func DBGetPDEV3ContributeRespond(nftID string, limit int64, offset int64) ([]shared.ContributionData, error)

func DBGetPDEV3ContributeWaiting added in v1.8.0 

func DBGetPDEV3ContributeWaiting(nftID string, limit int64, offset int64) ([]shared.ContributionData, error)

func DBGetPDEV3WithdrawFeeRespond added in v1.8.0 

func DBGetPDEV3WithdrawFeeRespond(nftID, poolID string, limit int64, offset int64) ([]shared.WithdrawContributionFeeData, error)

func DBGetPDEV3WithdrawRespond added in v1.8.0 

func DBGetPDEV3WithdrawRespond(nftID, poolID string, limit int64, offset int64) ([]shared.WithdrawContributionData, error)

func DBGetPDEWithdrawByRespondTx added in v1.8.0 

func DBGetPDEWithdrawByRespondTx(txlist []string) ([]shared.WithdrawContributionData, error)

func DBGetPDEWithdrawFeeByRespondTx added in v1.8.0 

func DBGetPDEWithdrawFeeByRespondTx(txlist []string) ([]shared.WithdrawContributionFeeData, error)

func DBGetPDEWithdrawFeeRespond 

func DBGetPDEWithdrawFeeRespond(address []string, limit int64, offset int64) ([]shared.WithdrawContributionFeeData, error)

func DBGetPairsByID added in v1.8.0 

func DBGetPairsByID(list []string) ([]shared.PairInfoData, error)

func DBGetPdexPairs added in v1.8.0 

func DBGetPdexPairs() ([]shared.PairInfoData, error)

func DBGetPendingCoins 

func DBGetPendingCoins() ([]string, error)

func DBGetPendingLimitOrderByNftID added in v1.8.0 

func DBGetPendingLimitOrderByNftID(nftIDs []string) ([]shared.TradeOrderData, error)

func DBGetPendingLiquidityWithdraw added in v1.8.0 

func DBGetPendingLiquidityWithdraw(limit int64, offset int64) ([]shared.WithdrawContributionData, error)

func DBGetPendingLiquidityWithdrawFee added in v1.8.0 

func DBGetPendingLiquidityWithdrawFee(limit int64, offset int64) ([]shared.WithdrawContributionFeeData, error)

func DBGetPendingOrder added in v1.8.0 

func DBGetPendingOrder(limit int64, offset int64) ([]shared.TradeOrderData, error)

func DBGetPendingOrderByPairID added in v1.8.0 

func DBGetPendingOrderByPairID(pairID string) ([]shared.TradeOrderData, error)

func DBGetPendingRequestStakingPool added in v1.8.0 

func DBGetPendingRequestStakingPool(limit int64, offset int64) ([]shared.PoolStakeHistoryData, error)

func DBGetPendingTxDetail 

func DBGetPendingTxDetail(txhash string) (string, error)

func DBGetPendingTxs 

func DBGetPendingTxs() (map[int][]string, error)

func DBGetPendingTxsData 

func DBGetPendingTxsData() ([]string, error)

func DBGetPendingUnstakingPool added in v1.8.0 

func DBGetPendingUnstakingPool(limit int64, offset int64) ([]shared.PoolStakeHistoryData, error)

func DBGetPendingWithdrawOrder added in v1.8.0 

func DBGetPendingWithdrawOrder(limit int64, offset int64) ([]shared.TradeOrderData, error)

func DBGetPendingWithdrawRewardStakingPool added in v1.8.0 

func DBGetPendingWithdrawRewardStakingPool(limit int64, offset int64) ([]shared.PoolStakeRewardHistoryData, error)

func DBGetPoolPairsByPairID added in v1.8.0 

func DBGetPoolPairsByPairID(pairID string) ([]shared.PoolInfoData, error)

func DBGetPoolPairsByPoolID added in v1.8.0 

func DBGetPoolPairsByPoolID(poolID []string) ([]shared.PoolInfoData, error)

func DBGetProcessorState added in v1.8.0 

func DBGetProcessorState(processor string) (*shared.ProcessorState, error)

func DBGetQualifyPools added in v1.8.0 

func DBGetQualifyPools() (map[string]struct{}, error)

func DBGetReceiveTxByPubkey 

func DBGetReceiveTxByPubkey(pubkey string, tokenID string, txversion int, limit int64, offset int64) ([]shared.TxData, error)

func DBGetRewardRecordByPoolID added in v1.8.0 

func DBGetRewardRecordByPoolID(poolid string, limit int64) ([]shared.RewardRecord, error)

func DBGetSendTxByKeyImages 

func DBGetSendTxByKeyImages(keyimages []string) ([]shared.TxData, error)

func DBGetShare added in v1.8.0 

func DBGetShare(nftID string) ([]shared.PoolShareData, error)

func DBGetShieldWithRespond added in v1.8.0 

func DBGetShieldWithRespond(fromtime uint64, offset int64) ([]shared.TxData, error)

func DBGetStableCoinID added in v1.8.0 

func DBGetStableCoinID() ([]string, error)

func DBGetStakePoolRewardHistory added in v1.8.0 

func DBGetStakePoolRewardHistory(nftid, tokenid string, limit, offset int64) ([]shared.PoolStakeRewardHistoryData, error)

func DBGetStakePools added in v1.8.0 

func DBGetStakePools() ([]shared.PoolStakeData, error)

func DBGetStakingInfo added in v1.8.0 

func DBGetStakingInfo(nftid string) ([]shared.PoolStakerData, error)

func DBGetStakingPoolHistory added in v1.8.0 

func DBGetStakingPoolHistory(nftid, tokenid string, limit, offset int64) ([]shared.PoolStakeHistoryData, error)

func DBGetStartCoinV2OfOTAkey added in v1.8.0 

func DBGetStartCoinV2OfOTAkey(shardID int, tokenID, otakey string) (uint64, error)

func DBGetSubmittedOTAKeys 

func DBGetSubmittedOTAKeys(indexerID int, offset int64) ([]shared.SubmittedOTAKeyData, error)

func DBGetTokenByTokenID added in v1.8.0 

func DBGetTokenByTokenID(tokenids []string) ([]shared.TokenInfoData, error)

func DBGetTokenCount 

func DBGetTokenCount() (int64, error)

func DBGetTokenMkcap added in v1.8.0 

func DBGetTokenMkcap(symbols []string) ([]shared.TokenMarketCap, error)

func DBGetTokenPrice added in v1.8.0 

func DBGetTokenPrice(tokenID string) (*shared.TokenPrice, error)

func DBGetTokenPriority added in v1.8.0 

func DBGetTokenPriority() ([]string, error)

func DBGetTop10PairHighestCap added in v1.8.0 

func DBGetTop10PairHighestCap() ([]shared.PairRanking, error)

func DBGetTradeInfoAndStatus added in v1.8.0 

func DBGetTradeInfoAndStatus(requestTx string) (*shared.TradeOrderData, *shared.LimitOrderStatus, error)

func DBGetTradeStatus added in v1.8.0 

func DBGetTradeStatus(requestTx []string) (map[string]shared.LimitOrderStatus, error)

func DBGetTxByHash 

func DBGetTxByHash(txHashes []string) ([]shared.TxData, error)

func DBGetTxByMetaAndOTA added in v1.8.0 

func DBGetTxByMetaAndOTA(pubkey string, metatype int, limit int64, offset int64) ([]shared.TxData, error)

func DBGetTxShield 

func DBGetTxShield(pubkey, tokenID string, limit int64, offset int64) ([]shared.ShieldData, error)

func DBGetTxTradeFromPoolAndNFT added in v1.8.0 

func DBGetTxTradeFromPoolAndNFT(poolid, nftid string, limit, offset int64) ([]shared.TradeOrderData, error)

func DBGetTxTradeFromTxRequest added in v1.8.0 

func DBGetTxTradeFromTxRequest(requestList []string) ([]shared.TradeOrderData, error)

func DBGetTxTradeFromTxRespond added in v1.8.0 

func DBGetTxTradeFromTxRespond(respondList []string) ([]shared.TradeOrderData, error)

func DBGetTxTradeRespond 

func DBGetTxTradeRespond(pubkey string, limit int64, offset int64) ([]shared.TxData, error)

func DBGetTxUnshield 

func DBGetTxUnshield(pubkey, tokenID string, limit int64, offset int64) ([]shared.TxData, error)

func DBGetTxV2ByPubkey 

func DBGetTxV2ByPubkey(pubkeys []string) ([]shared.TxData, []string, error)

func DBGetUnknownCoinsV2 

func DBGetUnknownCoinsV2(shardID int, tokenID string, fromidx, limit int64) ([]shared.CoinData, error)

func DBGetUnknownCoinsV21 added in v1.1.0 

func DBGetUnknownCoinsV21(shardID int, tokenID string, fromidx, limit int64) ([]shared.CoinData, error)

func DBGetUnknownCoinsV22 added in v1.1.0 

func DBGetUnknownCoinsV22(shardID int, tokenID string, fromidx, toidx, limit int64) ([]shared.CoinData, error)

func DBIsTokenNFT added in v1.8.0 

func DBIsTokenNFT(tokenid string) bool

func DBSaveBridgeState added in v1.8.1 

func DBSaveBridgeState(state string, height uint64, version int) error

func DBSaveCoins 

func DBSaveCoins(list []shared.CoinData) (error, []shared.CoinDataV1)

func DBSaveCustomTokenInfo added in v1.8.0 

func DBSaveCustomTokenInfo(list []shared.CustomTokenInfo) error

func DBSaveExtraTokenInfo added in v1.8.0 

func DBSaveExtraTokenInfo(list []shared.ExtraTokenInfo) error

func DBSaveInstructionBeacon added in v1.8.0 

func DBSaveInstructionBeacon(list []shared.InstructionBeaconData) error

func DBSavePDEContribute 

func DBSavePDEContribute(list []shared.ContributionData) error

func DBSavePDEStakeHistory added in v1.8.0 

func DBSavePDEStakeHistory(list []shared.PoolStakeHistoryData) error

func DBSavePDEStakeRewardHistory added in v1.8.0 

func DBSavePDEStakeRewardHistory(list []shared.PoolStakeRewardHistoryData) error

func DBSavePDEState 

func DBSavePDEState(state string, height uint64, version int) error

func DBSavePDEWithdraw 

func DBSavePDEWithdraw(list []shared.WithdrawContributionData) error

func DBSavePDEWithdrawFee 

func DBSavePDEWithdrawFee(list []shared.WithdrawContributionFeeData) error

func DBSavePairRanking added in v1.8.0 

func DBSavePairRanking(list []shared.PairRanking) error

func DBSavePendingTx 

func DBSavePendingTx(list []shared.CoinPendingData) error

func DBSavePoolPairs added in v1.8.0 

func DBSavePoolPairs(pools []shared.PoolInfoData) error

func DBSaveRewardRecord added in v1.8.0 

func DBSaveRewardRecord(list []shared.RewardRecord) error

func DBSaveSubmittedOTAKeys 

func DBSaveSubmittedOTAKeys(keys []shared.SubmittedOTAKeyData) error

func DBSaveTXs 

func DBSaveTXs(list []shared.TxData) error

func DBSaveTokenInfo 

func DBSaveTokenInfo(list []shared.TokenInfoData) error

func DBSaveTokenMkCap added in v1.8.0 

func DBSaveTokenMkCap(list []shared.TokenMarketCap) error

func DBSaveTokenPrice added in v1.8.0 

func DBSaveTokenPrice(list []shared.TokenPrice) error

func DBSaveTradeOrder added in v1.8.0 

func DBSaveTradeOrder(orders []shared.TradeOrderData) error

func DBSaveTxShield 

func DBSaveTxShield(list []shared.ShieldData) error

func DBSaveTxTrade 

func DBSaveTxTrade(list []shared.TradeOrderData) error

func DBSaveTxUnShield 

func DBSaveTxUnShield(list []shared.ShieldData) error

func DBSaveUsedKeyimage 

func DBSaveUsedKeyimage(list []shared.KeyImageData) error

func DBSetQualifyPools added in v1.8.0 

func DBSetQualifyPools(pools string) error

func DBUpdateCoinV1PubkeyInfo 

func DBUpdateCoinV1PubkeyInfo(list map[string]map[string]shared.CoinInfo) error

func DBUpdateCoinV2PubkeyInfo 

func DBUpdateCoinV2PubkeyInfo(list map[string]map[string]shared.CoinInfo) error

func DBUpdateCoins 

func DBUpdateCoins(list []shared.CoinData, ctx context.Context) error

func DBUpdateCoinsTx added in v1.8.0 

func DBUpdateCoinsTx(coinPubkey, txhash string) error

func DBUpdateKeyInfoV2 

func DBUpdateKeyInfoV2(doc interface{}, key *shared.KeyInfoData, ctx context.Context) error

func DBUpdateOrderProgress added in v1.8.0 

func DBUpdateOrderProgress(list []shared.LimitOrderStatus) error

func DBUpdatePDEContributeRespond added in v1.8.0 

func DBUpdatePDEContributeRespond(list []shared.ContributionData) error

func DBUpdatePDELiquidityWithdrawFeeStatus added in v1.8.0 

func DBUpdatePDELiquidityWithdrawFeeStatus(list []shared.WithdrawContributionFeeData) error

func DBUpdatePDELiquidityWithdrawStatus added in v1.8.0 

func DBUpdatePDELiquidityWithdrawStatus(list []shared.WithdrawContributionData) error

func DBUpdatePDEPairListData added in v1.8.0 

func DBUpdatePDEPairListData(list []shared.PairInfoData) error

func DBUpdatePDEPoolInfoData added in v1.8.0 

func DBUpdatePDEPoolInfoData(list []shared.PoolInfoData) error

func DBUpdatePDEPoolPairRewardAPY added in v1.8.0 

func DBUpdatePDEPoolPairRewardAPY(list []shared.RewardAPYTracking) error

func DBUpdatePDEPoolShareData added in v1.8.0 

func DBUpdatePDEPoolShareData(list []shared.PoolShareData) error

func DBUpdatePDEPoolStakeData added in v1.8.0 

func DBUpdatePDEPoolStakeData(list []shared.PoolStakeData) error

func DBUpdatePDEPoolStakerData added in v1.8.0 

func DBUpdatePDEPoolStakerData(list []shared.PoolStakerData) error

func DBUpdatePDEStakeRewardHistory added in v1.8.0 

func DBUpdatePDEStakeRewardHistory(list []shared.PoolStakeRewardHistoryData) error

func DBUpdatePDEStakingHistory added in v1.8.0 

func DBUpdatePDEStakingHistory(list []shared.PoolStakeHistoryData) error

func DBUpdatePDETradeWithdrawStatus added in v1.8.0 

func DBUpdatePDETradeWithdrawStatus(list []shared.TradeOrderData) error

func DBUpdatePDEUnstakingPoolStatus added in v1.8.0 

func DBUpdatePDEUnstakingPoolStatus(list []shared.PoolStakeHistoryData) error

func DBUpdatePDEWithdraw added in v1.8.0 

func DBUpdatePDEWithdraw(list []shared.WithdrawContributionData) error

func DBUpdatePDEWithdrawFee added in v1.8.0 

func DBUpdatePDEWithdrawFee(list []shared.WithdrawContributionFeeData) error

func DBUpdatePDEWithdrawRewardStakingStatus added in v1.8.0 

func DBUpdatePDEWithdrawRewardStakingStatus(list []shared.PoolStakeRewardHistoryData) error

func DBUpdateProcessorState added in v1.8.0 

func DBUpdateProcessorState(processor string, state string) error

func DBUpdateRequestStakingPoolStatus added in v1.8.0 

func DBUpdateRequestStakingPoolStatus(list []shared.PoolStakeHistoryData) error

func DBUpdateShieldData added in v1.8.0 

func DBUpdateShieldData(list []shared.ShieldData) error

func DBUpdateTokenInfoPrice added in v1.8.0 

func DBUpdateTokenInfoPrice(tokenList []shared.TokenInfoData) error

func DBUpdateTradeOrder added in v1.8.0 

func DBUpdateTradeOrder(orders []shared.TradeOrderData) error

func DBUpdateTxPubkeyReceiverAndTokenID added in v1.8.0 

func DBUpdateTxPubkeyReceiverAndTokenID(txHashes []string, pubKey, tokenID string, ctx context.Context) error

func DBUpdateTxsWithPubkeyReceiver added in v1.8.0 

func DBUpdateTxsWithPubkeyReceiver(list []shared.TxData) error

func DBUpdateWithdrawTradeOrderReq added in v1.8.0 

func DBUpdateWithdrawTradeOrderReq(orders []shared.TradeOrderData) error

func DBUpdateWithdrawTradeOrderRes added in v1.8.0 

func DBUpdateWithdrawTradeOrderRes(orders []shared.TradeOrderData) error

Types

This section is empty.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.