ethutils

Documentation

Index

• Constants
• type ERC20Token
  • func (t *ERC20Token) BalanceOf(hexAddress string) (*big.Int, error)
• type EthCall
  • func NewEthCall(id string, abiDefinition string, address string, methodName string, ...) (*EthCall, error)
  • func NewEthCallFromConfig(cfg config.EthCall) (*EthCall, error)
  • func (ec *EthCall) Call(ctx context.Context, client *ethclient.Client) (interface{}, error)
  • func (ec EthCall) ContractAddress() common.Address
  • func (ec EthCall) ID() string
  • func (ec EthCall) MethodName() string
• type EthClient
  • func NewEthClient(rpcAddress string, log *logging.Logger) (*EthClient, error)
  • func (c *EthClient) BalanceAt(ctx context.Context, account common.Address) (*big.Int, error)
  • func (c *EthClient) BalanceWithoutZerosAt(ctx context.Context, account common.Address) (float64, error)
  • func (c *EthClient) Call(ctx context.Context, call *EthCall) (interface{}, error)
  • func (c *EthClient) GetAssetPoolBalanceForToken(hexTokenAddress, assetPoolAddress string) (*big.Int, error)
  • func (c *EthClient) GetERC20(hexTokenAddress string) (*ERC20Token, error)
  • func (c *EthClient) Height(ctx context.Context) (uint64, error)
  • func (c *EthClient) Ready(ctx context.Context) (bool, error)
• type EventsCounter
  • func NewEventsCounter(name string, address string, abiJSON string, initialCallPastBlocks uint64) (*EventsCounter, error)
  • func NewEventsCounterFromConfig(cfg config.EthEvents) (*EventsCounter, error)
  • func (e *EventsCounter) CallFilterLogs(ctx context.Context, client *EthClient) error
  • func (e EventsCounter) ContractAddress() string
  • func (e EventsCounter) Count() map[string]uint64
  • func (e EventsCounter) Name() string

Constants

const (
	AllEvents                    = "*"
	DefaultInitialCallPastBlocks = 128
)

Types

type ERC20Token

type ERC20Token struct {
	*IERC20.IERC20
	HexAddress string
}

func (*ERC20Token) BalanceOf

func (t *ERC20Token) BalanceOf(hexAddress string) (*big.Int, error)

type EthCall

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

func NewEthCall

func NewEthCall(
	id string,
	abiDefinition string,
	address string,
	methodName string,
	args []interface{},
	outputIndex int,
	transformOutput string,
) (*EthCall, error)

func NewEthCallFromConfig

func NewEthCallFromConfig(cfg config.EthCall) (*EthCall, error)

func (*EthCall) Call

func (ec *EthCall) Call(ctx context.Context, client *ethclient.Client) (interface{}, error)

func (EthCall) ContractAddress

func (ec EthCall) ContractAddress() common.Address

func (EthCall) ID

func (ec EthCall) ID() string

func (EthCall) MethodName

func (ec EthCall) MethodName() string

type EthClient

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

func NewEthClient

func NewEthClient(rpcAddress string, log *logging.Logger) (*EthClient, error)

func (*EthClient) BalanceAt

func (c *EthClient) BalanceAt(ctx context.Context, account common.Address) (*big.Int, error)

func (*EthClient) BalanceWithoutZerosAt

func (c *EthClient) BalanceWithoutZerosAt(ctx context.Context, account common.Address) (float64, error)

func (*EthClient) Call

func (c *EthClient) Call(ctx context.Context, call *EthCall) (interface{}, error)

func (*EthClient) GetAssetPoolBalanceForToken

func (c *EthClient) GetAssetPoolBalanceForToken(hexTokenAddress, assetPoolAddress string) (*big.Int, error)

func (*EthClient) GetERC20

func (c *EthClient) GetERC20(hexTokenAddress string) (*ERC20Token, error)

func (*EthClient) Height

func (c *EthClient) Height(ctx context.Context) (uint64, error)

func (*EthClient) Ready

func (c *EthClient) Ready(ctx context.Context) (bool, error)

type EventsCounter

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

func NewEventsCounter

func NewEventsCounter(name string, address string, abiJSON string, initialCallPastBlocks uint64) (*EventsCounter, error)

func NewEventsCounterFromConfig

func NewEventsCounterFromConfig(cfg config.EthEvents) (*EventsCounter, error)

func (*EventsCounter) CallFilterLogs

func (e *EventsCounter) CallFilterLogs(ctx context.Context, client *EthClient) error

func (EventsCounter) ContractAddress

func (e EventsCounter) ContractAddress() string

func (EventsCounter) Count

func (e EventsCounter) Count() map[string]uint64

Count returns result

func (EventsCounter) Name

func (e EventsCounter) Name() string