eth

Documentation

Index

• type Client
  • func NewClinet(uri string) *Client
  • func (c *Client) GetEthereumTxs() error
  • func (c *Client) GetMempoolTxs(tokenAddr eth_common.Address, tokenName string, tokenDecimals int) []common.Transaction
  • func (c *Client) GetTxs(contractAddr eth_common.Address, blocks int64, tokenName string, decimals int) []common.Transaction
  • func (c *Client) SyncLatestBlocks() error
• type Keeper
  • func NewKeeper(url string, isTestnet bool) *Keeper
  • func (k *Keeper) BroadcastTx(w rest.ResponseWriter, r *rest.Request)
  • func (k *Keeper) GetTxs(w rest.ResponseWriter, r *rest.Request)
  • func (k *Keeper) SetToken(token string, tokenName string, decimlas int)
  • func (k *Keeper) Start()
  • func (k *Keeper) Stop()
  • func (k *Keeper) UpdateTxs()

Types

type Client

type Client struct {
	*ethclient.Client
	// contains filtered or unexported fields
}

func NewClinet

func NewClinet(uri string) *Client

func (*Client) GetEthereumTxs

func (c *Client) GetEthereumTxs() error

func (*Client) GetMempoolTxs

func (c *Client) GetMempoolTxs(tokenAddr eth_common.Address, tokenName string, tokenDecimals int) []common.Transaction

func (*Client) GetTxs

func (c *Client) GetTxs(contractAddr eth_common.Address, blocks int64, tokenName string, decimals int) []common.Transaction

func (*Client) SyncLatestBlocks

func (c *Client) SyncLatestBlocks() error

type Keeper

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

func NewKeeper

func NewKeeper(url string, isTestnet bool) *Keeper

func (*Keeper) BroadcastTx

func (k *Keeper) BroadcastTx(w rest.ResponseWriter, r *rest.Request)

func (*Keeper) GetTxs

func (k *Keeper) GetTxs(w rest.ResponseWriter, r *rest.Request)

func (*Keeper) SetToken

func (k *Keeper) SetToken(token string, tokenName string, decimlas int)

func (*Keeper) Start

func (k *Keeper) Start()

func (*Keeper) Stop

func (k *Keeper) Stop()

func (*Keeper) UpdateTxs

func (k *Keeper) UpdateTxs()