rpc

Documentation

Index

• func GetBlocksFromLogs(logs []types.Log) []uint64
• func GetBlocksTimestamp(rpc *Client, blockNumbers []uint64) map[uint64]time.Time
• func GetFilters(start uint64, end uint64) ethereum.FilterQuery
• func GetLatestBlockNumber(rpc *Client) uint64
• func GetLogs(rpc *Client, filter ethereum.FilterQuery) []types.Log
• func WeiToEther(wei *big.Int) *big.Float
• type Client
  • func New() *Client
  • func (rpc *Client) Close()
  • func (rpc *Client) GetClient() *ethclient.Client
• type Sale
  • func GetSaleFromTx(tx *types.Transaction) (string, Sale)
  • func GetSalesFromLogs(rpc *Client, blocksTimestamp map[uint64]time.Time, logs []types.Log) []Sale

Functions

func GetBlocksFromLogs

func GetBlocksFromLogs(logs []types.Log) []uint64

func GetBlocksTimestamp

func GetBlocksTimestamp(rpc *Client, blockNumbers []uint64) map[uint64]time.Time

func GetFilters

func GetFilters(start uint64, end uint64) ethereum.FilterQuery

func GetLatestBlockNumber

func GetLatestBlockNumber(rpc *Client) uint64

func GetLogs

func GetLogs(rpc *Client, filter ethereum.FilterQuery) []types.Log

func WeiToEther

func WeiToEther(wei *big.Int) *big.Float

Types

type Client

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

func New

func New() *Client

func (*Client) Close

func (rpc *Client) Close()

func (*Client) GetClient

func (rpc *Client) GetClient() *ethclient.Client

type Sale

type Sale struct {
	TxHash     string
	ID         int
	StartPrice float64
	EndPrice   float64
	Timestamp  time.Time
}

func GetSaleFromTx

func GetSaleFromTx(tx *types.Transaction) (string, Sale)

func GetSalesFromLogs

func GetSalesFromLogs(rpc *Client, blocksTimestamp map[uint64]time.Time, logs []types.Log) []Sale