reader

package
v0.0.30 Latest Latest
Warning

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

 Go to latest Published: May 1, 2024 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DEFAULT_ETHERSCAN_APIKEY string = "UBB257TI824FC7HUSPT66KZUMGBPRN3IWV"
	DEFAULT_BSCSCAN_APIKEY   string = "62TU8Z81F7ESNJT38ZVRBSX7CNN4QZSP5I"
	DEFAULT_TOMOSCAN_APIKEY  string = ""
)
View Source 
const TIMEOUT time.Duration = 4 * time.Second

Variables

View Source 
var DEFAULT_ADDRESS string = "0x0000000000000000000000000000000000000000"

Functions

This section is empty.

Types

type EthReader 

type EthReader struct {
	// contains filtered or unexported fields
}

func NewBSCReader 

func NewBSCReader() *EthReader

func NewBSCReaderWithCustomNodes 

func NewBSCReaderWithCustomNodes(nodes map[string]string) *EthReader

func NewBSCTestnetReader 

func NewBSCTestnetReader() *EthReader

func NewBSCTestnetReaderWithCustomNodes 

func NewBSCTestnetReaderWithCustomNodes(nodes map[string]string) *EthReader

func NewEthReader 

func NewEthReader() *EthReader

func NewEthReaderGeneric 

func NewEthReaderGeneric(nodes map[string]string, be BlockExplorer) *EthReader

func NewEthReaderWithCustomNodes 

func NewEthReaderWithCustomNodes(nodes map[string]string) *EthReader

func NewKovanReader 

func NewKovanReader() *EthReader

func NewKovanReaderWithCustomNodes 

func NewKovanReaderWithCustomNodes(nodes map[string]string) *EthReader

func NewMaticReader 

func NewMaticReader() *EthReader

func NewMaticReaderWithCustomNodes 

func NewMaticReaderWithCustomNodes(nodes map[string]string) *EthReader

func NewMumbaiReader 

func NewMumbaiReader() *EthReader

func NewMumbaiReaderWithCustomNodes 

func NewMumbaiReaderWithCustomNodes(nodes map[string]string) *EthReader

func NewRinkebyReader 

func NewRinkebyReader() *EthReader

func NewRinkebyReaderWithCustomNodes 

func NewRinkebyReaderWithCustomNodes(nodes map[string]string) *EthReader

func NewRopstenReader 

func NewRopstenReader() *EthReader

func NewRopstenReaderWithCustomNodes 

func NewRopstenReaderWithCustomNodes(nodes map[string]string) *EthReader

func NewTomoReader 

func NewTomoReader() *EthReader

func NewTomoReaderWithCustomNodes 

func NewTomoReaderWithCustomNodes(nodes map[string]string) *EthReader

func (*EthReader) AddressFromContract 

func (self *EthReader) AddressFromContract(
	contract string,
	method string,
) (*common.Address, error)

func (*EthReader) AddressFromContractWithABI added in v0.0.30 

func (self *EthReader) AddressFromContractWithABI(
	contract string,
	abi *abi.ABI,
	method string,
) (*common.Address, error)

func (*EthReader) CheckDynamicFeeTxAvailable added in v0.0.30 

func (self *EthReader) CheckDynamicFeeTxAvailable() (bool, error)

CheckDynamicFeeTxAvailable use to detect if current network that connect via node url is support dynamic fee tx, this is done by a trick where we check if block info contain baseFee > 0, that may not always work but should enough for now.

func (*EthReader) CurrentBlock 

func (self *EthReader) CurrentBlock() (uint64, error)

func (*EthReader) ERC20Allowance 

func (self *EthReader) ERC20Allowance(
	caddr string,
	owner string,
	spender string,
) (*big.Int, error)

func (*EthReader) ERC20Balance 

func (self *EthReader) ERC20Balance(caddr string, user string) (*big.Int, error)

func (*EthReader) ERC20Decimal 

func (self *EthReader) ERC20Decimal(caddr string) (uint64, error)

func (*EthReader) ERC20Symbol added in v0.0.27 

func (self *EthReader) ERC20Symbol(caddr string) (string, error)

func (*EthReader) EstimateExactGas 

func (self *EthReader) EstimateExactGas(
	from, to string,
	priceGwei float64,
	value *big.Int,
	data []byte,
) (uint64, error)

func (*EthReader) EstimateGas 

func (self *EthReader) EstimateGas(
	from, to string,
	priceGwei, value float64,
	data []byte,
) (uint64, error)

func (*EthReader) GetABI 

func (self *EthReader) GetABI(address string) (*abi.ABI, error)

func (*EthReader) GetABIString 

func (self *EthReader) GetABIString(address string) (string, error)

func (*EthReader) GetBalance 

func (self *EthReader) GetBalance(address string) (balance *big.Int, err error)

func (*EthReader) GetCode 

func (self *EthReader) GetCode(address string) (code []byte, err error)

func (*EthReader) GetGasPriceWeiSuggestion 

func (self *EthReader) GetGasPriceWeiSuggestion() (*big.Int, error)

func (*EthReader) GetLogs 

func (self *EthReader) GetLogs(
	fromBlock, toBlock int,
	addresses []string,
	topic string,
) ([]types.Log, error)

if toBlock < 0, it will query to the latest block

func (*EthReader) GetMinedNonce 

func (self *EthReader) GetMinedNonce(address string) (nonce uint64, err error)

func (*EthReader) GetPendingNonce 

func (self *EthReader) GetPendingNonce(address string) (nonce uint64, err error)

func (*EthReader) GetSuggestedGasTipCap added in v0.0.30 

func (self *EthReader) GetSuggestedGasTipCap() (float64, error)

func (*EthReader) HeaderByNumber 

func (self *EthReader) HeaderByNumber(number int64) (*types.Header, error)

func (*EthReader) HistoryERC20Allowance 

func (self *EthReader) HistoryERC20Allowance(
	atBlock int64,
	caddr string,
	owner string,
	spender string,
) (*big.Int, error)

func (*EthReader) HistoryERC20Balance 

func (self *EthReader) HistoryERC20Balance(
	atBlock int64,
	caddr string,
	user string,
) (*big.Int, error)

func (*EthReader) HistoryERC20Decimal 

func (self *EthReader) HistoryERC20Decimal(atBlock int64, caddr string) (int64, error)

func (*EthReader) ImplementationOf added in v0.0.30 

func (self *EthReader) ImplementationOf(atBlock int64, caddr string) (common.Address, error)

func (*EthReader) ImplementationOfEIP1967 added in v0.0.30 

func (self *EthReader) ImplementationOfEIP1967(
	atBlock int64,
	caddr string,
) (common.Address, error)

func (*EthReader) ReadContract 

func (self *EthReader) ReadContract(
	result interface{},
	caddr string,
	method string,
	args ...interface{},
) error

func (*EthReader) ReadContractToBytes 

func (self *EthReader) ReadContractToBytes(
	atBlock int64,
	from string,
	caddr string,
	abi *abi.ABI,
	method string,
	args ...interface{},
) ([]byte, error)

func (*EthReader) ReadContractWithABI 

func (self *EthReader) ReadContractWithABI(
	result interface{},
	caddr string,
	abi *abi.ABI,
	method string,
	args ...interface{},
) error

func (*EthReader) ReadContractWithABIAndFrom 

func (self *EthReader) ReadContractWithABIAndFrom(
	result interface{},
	from string,
	caddr string,
	abi *abi.ABI,
	method string,
	args ...interface{},
) error

func (*EthReader) ReadHistoryContract 

func (self *EthReader) ReadHistoryContract(
	atBlock int64,
	result interface{},
	caddr string,
	method string,
	args ...interface{},
) error

func (*EthReader) ReadHistoryContractWithABI 

func (self *EthReader) ReadHistoryContractWithABI(
	atBlock int64,
	result interface{},
	caddr string,
	abi *abi.ABI,
	method string,
	args ...interface{},
) error

func (*EthReader) RecommendedGasPrice 

func (self *EthReader) RecommendedGasPrice() (float64, error)

func (*EthReader) StorageAt added in v0.0.30 

func (self *EthReader) StorageAt(atBlock int64, caddr string, slot string) ([]byte, error)

func (*EthReader) SuggestedGasSettings added in v0.0.30 

func (self *EthReader) SuggestedGasSettings() (maxGasPriceGwei, maxTipGwei float64, err error)

func (*EthReader) TransactionByHash 

func (self *EthReader) TransactionByHash(
	txHash string,
) (tx *Transaction, isPending bool, err error)

func (*EthReader) TransactionReceipt 

func (self *EthReader) TransactionReceipt(txHash string) (receipt *types.Receipt, err error)

func (*EthReader) TxInfoFromHash 

func (self *EthReader) TxInfoFromHash(tx string) (TxInfo, error)

type EthereumNode 

type EthereumNode interface {
	NodeName() string
	NodeURL() string
	EstimateGas(
		from, to string,
		priceGwei float64,
		value *big.Int,
		data []byte,
	) (gas uint64, err error)
	GetCode(address string) (code []byte, err error)
	GetBalance(address string) (balance *big.Int, err error)
	GetMinedNonce(address string) (nonce uint64, err error)
	GetPendingNonce(address string) (nonce uint64, err error)
	TransactionReceipt(txHash string) (receipt *types.Receipt, err error)
	TransactionByHash(txHash string) (tx *common.Transaction, isPending bool, err error)
	// Call(result interface{}, method string, args ...interface{}) error
	GetGasPriceSuggestion() (*big.Int, error)
	SuggestedGasPrice() (*big.Int, error)
	SuggestedGasTipCap() (*big.Int, error)
	ReadContractToBytes(
		atBlock int64,
		from string,
		caddr string,
		abi *abi.ABI,
		method string,
		args ...interface{},
	) ([]byte, error)
	StorageAt(atBlock int64, caddr string, slot string) ([]byte, error)
	HeaderByNumber(number int64) (*types.Header, error)
	GetLogs(fromBlock, toBlock int, addresses []string, topic string) ([]types.Log, error)
	CurrentBlock() (uint64, error)
}

type MCOneResultHandler 

type MCOneResultHandler func(result interface{}) error
var DO_NOTHING_MC_ONE_RESULT_HANDLER MCOneResultHandler = func(result interface{}) error { return nil }

type MultipleCall 

type MultipleCall struct {
	// contains filtered or unexported fields
}

func NewMultiCall 

func NewMultiCall(r *EthReader, mcContract string) *MultipleCall

func (*MultipleCall) Do 

func (mc *MultipleCall) Do(atBlock int64) (block int64, err error)

func (*MultipleCall) Register 

func (mc *MultipleCall) Register(
	result interface{},
	caddr string,
	abi *abi.ABI,
	method string,
	args ...interface{},
) *MultipleCall

func (*MultipleCall) RegisterWithHook 

func (mc *MultipleCall) RegisterWithHook(
	result interface{},
	hook MCOneResultHandler,
	caddr string,
	abi *abi.ABI,
	method string,
	args ...interface{},
) *MultipleCall

type OneNodeReader 

type OneNodeReader struct {
	// contains filtered or unexported fields
}

func NewOneNodeReader 

func NewOneNodeReader(name, url string) *OneNodeReader

func (*OneNodeReader) Client 

func (self *OneNodeReader) Client() (*rpc.Client, error)

func (*OneNodeReader) CurrentBlock 

func (self *OneNodeReader) CurrentBlock() (uint64, error)

func (*OneNodeReader) EstimateGas 

func (self *OneNodeReader) EstimateGas(from, to string, priceGwei float64, value *big.Int, data []byte) (uint64, error)

func (*OneNodeReader) EthClient 

func (self *OneNodeReader) EthClient() (*ethclient.Client, error)

func (*OneNodeReader) GetBalance 

func (self *OneNodeReader) GetBalance(address string) (balance *big.Int, err error)

func (*OneNodeReader) GetCode 

func (self *OneNodeReader) GetCode(address string) (code []byte, err error)

func (*OneNodeReader) GetGasPriceSuggestion 

func (self *OneNodeReader) GetGasPriceSuggestion() (*big.Int, error)

func (*OneNodeReader) GetLogs 

func (self *OneNodeReader) GetLogs(fromBlock, toBlock int, addresses []string, topic string) ([]types.Log, error)

func (*OneNodeReader) GetMinedNonce 

func (self *OneNodeReader) GetMinedNonce(address string) (nonce uint64, err error)

func (*OneNodeReader) GetPendingNonce 

func (self *OneNodeReader) GetPendingNonce(address string) (nonce uint64, err error)

func (*OneNodeReader) HeaderByNumber 

func (self *OneNodeReader) HeaderByNumber(number int64) (*types.Header, error)

func (*OneNodeReader) NodeName 

func (self *OneNodeReader) NodeName() string

func (*OneNodeReader) NodeURL 

func (self *OneNodeReader) NodeURL() string

func (*OneNodeReader) ReadContractToBytes 

func (self *OneNodeReader) ReadContractToBytes(atBlock int64, from string, caddr string, abi *abi.ABI, method string, args ...interface{}) ([]byte, error)

func (*OneNodeReader) StorageAt added in v0.0.30 

func (self *OneNodeReader) StorageAt(atBlock int64, contractAddr string, slot string) ([]byte, error)

func (*OneNodeReader) SuggestedGasPrice added in v0.0.30 

func (self *OneNodeReader) SuggestedGasPrice() (*big.Int, error)

func (*OneNodeReader) SuggestedGasTipCap added in v0.0.30 

func (self *OneNodeReader) SuggestedGasTipCap() (*big.Int, error)

func (*OneNodeReader) TransactionByHash 

func (self *OneNodeReader) TransactionByHash(txHash string) (tx *Transaction, isPending bool, err error)

func (*OneNodeReader) TransactionReceipt 

func (self *OneNodeReader) TransactionReceipt(txHash string) (receipt *types.Receipt, err error)

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.