mongodb

package

v0.0.0-...-2e4c1a8 Latest Latest Go to latest Published: Feb 7, 2023 License: GPL-3.0 Imports: 6 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/weijun-sh/gethscan

Links

Open Source Insights

README ¶

Mongodb Collections

SyncInfo

Name	Type	Key
Number	uint64	`bson:"number"`
Hash	string	`bson:"hash"`
Timestamp	uint64	`bson:"timestamp"`

Blocks

Name	Type	Key
Number	uint64	`bson:"number"`
Hash	string	`bson:"hash"`
ParentHash	string	`bson:"parentHash"`
Nonce	string	`bson:"nonce"`
Miner	string	`bson:"miner"`
Difficulty	string	`bson:"difficulty"`
GasLimit	uint64	`bson:"gasLimit"`
GasUsed	uint64	`bson:"gasUsed"`
Timestamp	uint64	`bson:"timestamp"`

Transactions

Name	Type	Key
Hash	string	`bson:"hash"`
BlockNumber	uint64	`bson:"blockNumber"`
BlockHash	string	`bson:"blockHash"`
TransactionIndex	int	`bson:"transactionIndex"`
From	string	`bson:"from"`
To	string	`bson:"to"`
Value	string	`bson:"value"`
Nonce	uint64	`bson:"nonce"`
GasLimit	uint64	`bson:"gasLimit"`
GasUsed	uint64	`bson:"gasUsed"`
GasPrice	string	`bson:"gasPrice"`
Status	uint64	`bson:"status"`
Timestamp	uint64	`bson:"timestamp"`

Erc20Receipts	[]*Erc20Receipt	`bson:"erc20Receipts,omitempty"`
ExchangeReceipts	[]*ExchangeReceipt	`bson:"exchangeReceipts,omitempty"`

Note that Erc20Receipts and ExchangeReceipts is an array because a tx may have multiple receipt logs. And these fileds may be omitted if not exist.

Erc20Receipt

LogType can be Transfer or Approval

Erc20 is ERC20 contract address

Name	Type	Key
LogType	string	`bson:"logType"`
LogIndex	int	`bson:"logIndex"`
Erc20	string	`bson:"erc20"`
From	string	`bson:"from"`
To	string	`bson:"to"`
Value	string	`bson:"value"`

ExchangeReceipt

LogType can be AddLiquidity, RemoveLiquidity, TokenPurchase or EthPurchase

Pairs is read from config file

Name	Type	Key
LogType	string	`bson:"txnsType"`
LogIndex	int	`bson:"logIndex"`
Exchange	string	`bson:"exchange"`
Pairs	string	`bson:"pairs"`
Address	string	`bson:"address"`
TokenFromAmount	string	`bson:"tokenFromAmount"`
TokenToAmount	string	`bson:"tokenToAmount"`

Liquidity

one record per day

Name	Type	Key
Exchange	string	`bson:"exchange"`
Pairs	string	`bson:"pairs"`
Coin	string	`bson:"coin"`
Token	string	`bson:"token"`
Liquidity	string	`bson:"liquidity"`
BlockNumber	uint64	`bson:"blockNumber"`
BlockHash	string	`bson:"blockHash"`
Timestamp	uint64	`bson:"timestamp"`

Volume

one record per day

Name	Type	Key
Exchange	string	`bson:"exchange"`
Pairs	string	`bson:"pairs"`
CoinVolume24h	string	`bson:"cvolume24h"`
TokenVolume24h	string	`bson:"tvolume24h"`
BlockNumber	uint64	`bson:"blockNumber"`
BlockHash	string	`bson:"blockHash"`
Timestamp	uint64	`bson:"timestamp"`

Accounts

Name	Type	Key
Exchange	string	`bson:"exchange"`
Pairs	string	`bson:"pairs"`
Account	string	`bson:"account"`

LiquidityBalances

Name	Type	Key
Exchange	string	`bson:"exchange"`
Pairs	string	`bson:"pairs"`
Account	string	`bson:"account"`
BlockNumber	uint64	`bson:"blockNumber"`
Liquidity	string	`bson:"liquidity"`

VolumeHistory

Name	Type	Key
Exchange	string	`bson:"exchange"`
Pairs	string	`bson:"pairs"`
Account	string	`bson:"account"`
CoinAmount	string	`bson:"coinAmount"`
TokenAmount	string	`bson:"tokenAmount"`
BlockNumber	uint64	`bson:"blockNumber"`
Timestamp	uint64	`bson:"timestamp"`
TxHash	string	`bson:"txhash"`
LogType	string	`bson:"logType"`
LogIndex	int	`bson:"logIndex"`

Documentation ¶

Index ¶

func AddSwap(ms *MgoSwap, overwrite bool) (err error)
func AddSwapDeleted(ms *MgoSwap, overwrite bool) (err error)
func AddSwapPending(ms *MgoSwap, overwrite bool) (err error)
func FindSyncedBlockNumber(chain string) (uint64, error)
func InitSyncedBlockNumber(chain string, number uint64) error
func InsertSyncedBlockNumber(chain string, number uint64) error
func MongoServerInit(addrs []string, dbname, user, pass string)
func RemoveSwapPending(ms *MgoSwap) (err error)
func TryDoTimes(name string, f func() error) (err error)
func UpdateSwapPending(swap *MgoSwap)
func UpdateSyncedBlockNumber(chain string, number uint64) error
type MgoSwap
- func FindAllSwapPending(chain string, offset, limit int) ([]*MgoSwap, error)
- func FindswapPending(swap string) (*MgoSwap, error)
type SyncedBlock

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AddSwap ¶

func AddSwap(ms *MgoSwap, overwrite bool) (err error)

AddSwap and swap

func AddSwapDeleted ¶

func AddSwapDeleted(ms *MgoSwap, overwrite bool) (err error)

AddSwapDeleted add deleted

func AddSwapPending ¶

func AddSwapPending(ms *MgoSwap, overwrite bool) (err error)

AddSwapPending add pending

func FindSyncedBlockNumber ¶

func FindSyncedBlockNumber(chain string) (uint64, error)

func InitSyncedBlockNumber ¶

func InitSyncedBlockNumber(chain string, number uint64) error

func InsertSyncedBlockNumber ¶

func InsertSyncedBlockNumber(chain string, number uint64) error

func MongoServerInit ¶

func MongoServerInit(addrs []string, dbname, user, pass string)

MongoServerInit int mongodb server session

func RemoveSwapPending ¶

func RemoveSwapPending(ms *MgoSwap) (err error)

RemoveSwapPending add remove pending

func TryDoTimes ¶

func TryDoTimes(name string, f func() error) (err error)

TryDoTimes try do again if meet error

func UpdateSwapPending ¶

func UpdateSwapPending(swap *MgoSwap)

func UpdateSyncedBlockNumber ¶

func UpdateSyncedBlockNumber(chain string, number uint64) error

Types ¶

type MgoSwap ¶

type MgoSwap struct {
	Id         string `bson:"_id"`       //txid
	PairID     string `bson:"pairID"`    //"FXSv4"
	RpcMethod  string `bson:"rpcMethod"` //"swap.Swapin"
	SwapServer string `bson:"swapServer"`
	ChainID    string `bson:"chainid"`
	LogIndex   string `bson:"logIndex"`
	Chain      string `bson:"chain"`
	Timestamp  uint64 `bson:"timestamp"`
}

func FindAllSwapPending ¶

func FindAllSwapPending(chain string, offset, limit int) ([]*MgoSwap, error)

FindAllTokenAccounts find accounts

func FindswapPending ¶

func FindswapPending(swap string) (*MgoSwap, error)

--------------- find --------------------------------- FindswapPending find by swap

type SyncedBlock ¶

type SyncedBlock struct {
	Id          string `bson: "_id"` //"chain"
	Chain       string `bson: "chain"`
	BlockNumber uint64 `bson: "blocknumber"`
}

Source Files ¶

View all Source files

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