ethereum

Documentation

Index

• Constants
• Variables
• type Config
  • func ParseChainConfig(chainCfg *core.ChainConfig) (*Config, error)
  • func (c *Config) BlockstorePath() string
  • func (c *Config) BridgeContract() common.Address
  • func (c *Config) ChainId() msg.ChainId
  • func (c *Config) Erc20HandlerContract() common.Address
  • func (c *Config) FreshStart() bool
  • func (c *Config) From() string
  • func (c *Config) KeystorePath() string
  • func (c *Config) SetStartBlock(blk *big.Int)
  • func (c *Config) StartBlock() *big.Int
• type Connection
  • func NewConnection(cfg *Config, kp *secp256k1.Keypair, log log15.Logger) *Connection
  • func (c *Connection) CallOpts() *bind.CallOpts
  • func (c *Connection) Client() *ethclient.Client
  • func (c *Connection) Close()
  • func (c *Connection) Connect() error
  • func (c *Connection) EnsureHasBytecode(addr ethcommon.Address) error
  • func (c *Connection) Keypair() *secp256k1.Keypair
  • func (c *Connection) LatestBlock() (*big.Int, error)
  • func (c *Connection) LockAndUpdateOpts() error
  • func (c *Connection) Opts() *bind.TransactOpts
  • func (c *Connection) SafeEstimateGas(ctx context.Context) (*big.Int, error)
  • func (c *Connection) UnlockOpts()
  • func (c *Connection) WaitForBlock(block *big.Int) error
• type GasRes

Constants

const (
	DefaultGasLimit = 10e5
	DefaultGasPrice = 300e9

	EthChainId = msg.ChainId(2)
)

Variables

var (
	BlockRetryInterval = time.Second * 5
)

var ZeroAddress = common.HexToAddress("0x0000000000000000000000000000000000000000")

Types

type Config

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

Config encapsulates all necessary parameters in ethereum compatible forms

func ParseChainConfig

func ParseChainConfig(chainCfg *core.ChainConfig) (*Config, error)

parseChainConfig uses a core.ChainConfig to construct a corresponding Config

func (*Config) BlockstorePath

func (c *Config) BlockstorePath() string

func (*Config) BridgeContract

func (c *Config) BridgeContract() common.Address

func (*Config) ChainId

func (c *Config) ChainId() msg.ChainId

func (*Config) Erc20HandlerContract

func (c *Config) Erc20HandlerContract() common.Address

func (*Config) FreshStart

func (c *Config) FreshStart() bool

func (*Config) From

func (c *Config) From() string

func (*Config) KeystorePath

func (c *Config) KeystorePath() string

func (*Config) SetStartBlock

func (c *Config) SetStartBlock(blk *big.Int)

func (*Config) StartBlock

func (c *Config) StartBlock() *big.Int

type Connection

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

func NewConnection

func NewConnection(cfg *Config, kp *secp256k1.Keypair, log log15.Logger) *Connection

NewConnection returns an uninitialized connection, must call Connection.Connect() before using.

func (*Connection) CallOpts

func (c *Connection) CallOpts() *bind.CallOpts

func (*Connection) Client

func (c *Connection) Client() *ethclient.Client

func (*Connection) Close

func (c *Connection) Close()

Close terminates the client connection and stops any running routines

func (*Connection) Connect

func (c *Connection) Connect() error

Connect starts the ethereum WS connection

func (*Connection) EnsureHasBytecode

func (c *Connection) EnsureHasBytecode(addr ethcommon.Address) error

EnsureHasBytecode asserts if contract code exists at the specified address

func (*Connection) Keypair

func (c *Connection) Keypair() *secp256k1.Keypair

func (*Connection) LatestBlock

func (c *Connection) LatestBlock() (*big.Int, error)

LatestBlock returns the latest block from the current chain

func (*Connection) LockAndUpdateOpts

func (c *Connection) LockAndUpdateOpts() error

LockAndUpdateOpts acquires a lock on the opts before updating the nonce and gas price.

func (*Connection) Opts

func (c *Connection) Opts() *bind.TransactOpts

func (*Connection) SafeEstimateGas

func (c *Connection) SafeEstimateGas(ctx context.Context) (*big.Int, error)

func (*Connection) UnlockOpts

func (c *Connection) UnlockOpts()

func (*Connection) WaitForBlock

func (c *Connection) WaitForBlock(block *big.Int) error

WaitForBlock will poll for the block number until the current block is equal or greater than

type GasRes

type GasRes struct {
	Status  string `json:"status"`
	Message string `json:"message"`
	Result  struct {
		LastBlock       string `json:"LastBlock"`
		SafeGasPrice    string `json:"SafeGasPrice"`
		ProposeGasPrice string `json:"ProposeGasPrice"`
		FastGasPrice    string `json:"FastGasPrice"`
	} `json:"result"`
}