ethrpc

Documentation

Index

• func WaitForTxnReceipt(ctx context.Context, provider *Provider, txHash common.Hash) (*types.Receipt, error)
• type Config
  • func (c *Config) AddNode(nodeConfig NodeConfig)
• type NodeConfig
• type Provider
  • func NewProvider(ethURL string, optClient ...*http.Client) (*Provider, error)
  • func NewProviderWithConfig(config *Config, optClient ...*http.Client) (*Provider, error)
  • func (s *Provider) BlockByHash(ctx context.Context, hash common.Hash) (*types.Block, error)
  • func (s *Provider) BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)
  • func (s *Provider) ChainID(ctx context.Context) (*big.Int, error)
  • func (s *Provider) Dial() error
  • func (s *Provider) QueryContract(ctx context.Context, contractAddress string, ...) ([]string, error)
  • func (s *Provider) SendRawTransaction(ctx context.Context, signedTxHex string) (common.Hash, error)
  • func (s *Provider) TransactionDetails(ctx context.Context, txnHash common.Hash) (bool, *types.Receipt, *types.Transaction, string, error)

Functions

func WaitForTxnReceipt

func WaitForTxnReceipt(ctx context.Context, provider *Provider, txHash common.Hash) (*types.Receipt, error)

Types

type Config

type Config struct {
	Nodes []NodeConfig

	ChaindID int // expected ChainID so we confirm on connect..
	TestMode bool
}

func (*Config) AddNode

func (c *Config) AddNode(nodeConfig NodeConfig)

type NodeConfig

type NodeConfig struct {
	URL                 string
	MaxRequestPerSecond float64
}

type Provider

type Provider struct {
	*ethclient.Client
	Config *Config
	RPC    *rpc.Client
	// contains filtered or unexported fields
}

func NewProvider

func NewProvider(ethURL string, optClient ...*http.Client) (*Provider, error)

func NewProviderWithConfig

func NewProviderWithConfig(config *Config, optClient ...*http.Client) (*Provider, error)

func (*Provider) BlockByHash

func (s *Provider) BlockByHash(ctx context.Context, hash common.Hash) (*types.Block, error)

func (*Provider) BlockByNumber

func (s *Provider) BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)

func (*Provider) ChainID

func (s *Provider) ChainID(ctx context.Context) (*big.Int, error)

func (*Provider) Dial

func (s *Provider) Dial() error

func (*Provider) QueryContract

func (s *Provider) QueryContract(ctx context.Context, contractAddress string, inputAbiExpr, outputAbiExpr string, args []string) ([]string, error)

ie, QueryContext(context.Background(), "0xabcdef..", "balanceOf(uint256)", "uint256", []string{"1"})

func (*Provider) SendRawTransaction

func (s *Provider) SendRawTransaction(ctx context.Context, signedTxHex string) (common.Hash, error)

func (*Provider) TransactionDetails

func (s *Provider) TransactionDetails(ctx context.Context, txnHash common.Hash) (bool, *types.Receipt, *types.Transaction, string, error)