rpc

Documentation

Index

• type BlockFilterId
• type ChainSpec
  • func (chain *ChainSpec) CheckMismatch(chain2 *ChainSpec) []string
• type ExecutionClient
  • func NewExecutionClient(name, endpoint string, headers map[string]string, sshcfg *sshtunnel.SshConfig, ...) (*ExecutionClient, error)
  • func (ec *ExecutionClient) GetAdminNodeInfo(ctx context.Context) (*p2p.NodeInfo, error)
  • func (ec *ExecutionClient) GetAdminPeers(ctx context.Context) ([]*p2p.PeerInfo, error)
  • func (ec *ExecutionClient) GetBalanceAt(ctx context.Context, wallet common.Address, blockNumber *big.Int) (*big.Int, error)
  • func (ec *ExecutionClient) GetBlockByHash(ctx context.Context, hash common.Hash) (*types.Block, error)
  • func (ec *ExecutionClient) GetChainSpec(ctx context.Context) (*ChainSpec, error)
  • func (ec *ExecutionClient) GetClientVersion(ctx context.Context) (string, error)
  • func (ec *ExecutionClient) GetEthClient() *ethclient.Client
  • func (ec *ExecutionClient) GetFilterChanges(ctx context.Context, filterId BlockFilterId) ([]string, error)
  • func (ec *ExecutionClient) GetHeaderByHash(ctx context.Context, hash common.Hash) (*types.Header, error)
  • func (ec *ExecutionClient) GetHeaderByNumber(ctx context.Context, number uint64) (*types.Header, error)
  • func (ec *ExecutionClient) GetLatestBlock(ctx context.Context) (*types.Block, error)
  • func (ec *ExecutionClient) GetLatestHeader(ctx context.Context) (*types.Header, error)
  • func (ec *ExecutionClient) GetNodeSyncing(ctx context.Context) (*SyncStatus, error)
  • func (ec *ExecutionClient) GetNonceAt(ctx context.Context, wallet common.Address, blockNumber *big.Int) (uint64, error)
  • func (ec *ExecutionClient) GetTransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)
  • func (ec *ExecutionClient) Initialize(ctx context.Context) error
  • func (ec *ExecutionClient) NewBlockFilter(ctx context.Context) (BlockFilterId, error)
  • func (ec *ExecutionClient) SendTransaction(ctx context.Context, tx *types.Transaction) error
  • func (ec *ExecutionClient) UninstallBlockFilter(ctx context.Context, filterId BlockFilterId) (bool, error)
• type SyncStatus
  • func (s *SyncStatus) Percent() float64

Types

type BlockFilterId

type BlockFilterId string

type ChainSpec

type ChainSpec struct {
	ChainID string
}

func (*ChainSpec) CheckMismatch

func (chain *ChainSpec) CheckMismatch(chain2 *ChainSpec) []string

type ExecutionClient

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

func NewExecutionClient

func NewExecutionClient(name, endpoint string, headers map[string]string, sshcfg *sshtunnel.SshConfig, logger logrus.FieldLogger) (*ExecutionClient, error)

NewExecutionClient is used to create a new execution client

func (*ExecutionClient) GetAdminNodeInfo

func (ec *ExecutionClient) GetAdminNodeInfo(ctx context.Context) (*p2p.NodeInfo, error)

func (*ExecutionClient) GetAdminPeers

func (ec *ExecutionClient) GetAdminPeers(ctx context.Context) ([]*p2p.PeerInfo, error)

func (*ExecutionClient) GetBalanceAt

func (ec *ExecutionClient) GetBalanceAt(ctx context.Context, wallet common.Address, blockNumber *big.Int) (*big.Int, error)

func (*ExecutionClient) GetBlockByHash

func (ec *ExecutionClient) GetBlockByHash(ctx context.Context, hash common.Hash) (*types.Block, error)

func (*ExecutionClient) GetChainSpec

func (ec *ExecutionClient) GetChainSpec(ctx context.Context) (*ChainSpec, error)

func (*ExecutionClient) GetClientVersion

func (ec *ExecutionClient) GetClientVersion(ctx context.Context) (string, error)

func (*ExecutionClient) GetEthClient

func (ec *ExecutionClient) GetEthClient() *ethclient.Client

func (*ExecutionClient) GetFilterChanges

func (ec *ExecutionClient) GetFilterChanges(ctx context.Context, filterId BlockFilterId) ([]string, error)

func (*ExecutionClient) GetHeaderByHash

func (ec *ExecutionClient) GetHeaderByHash(ctx context.Context, hash common.Hash) (*types.Header, error)

func (*ExecutionClient) GetHeaderByNumber

func (ec *ExecutionClient) GetHeaderByNumber(ctx context.Context, number uint64) (*types.Header, error)

func (*ExecutionClient) GetLatestBlock

func (ec *ExecutionClient) GetLatestBlock(ctx context.Context) (*types.Block, error)

func (*ExecutionClient) GetLatestHeader

func (ec *ExecutionClient) GetLatestHeader(ctx context.Context) (*types.Header, error)

func (*ExecutionClient) GetNodeSyncing

func (ec *ExecutionClient) GetNodeSyncing(ctx context.Context) (*SyncStatus, error)

func (*ExecutionClient) GetNonceAt

func (ec *ExecutionClient) GetNonceAt(ctx context.Context, wallet common.Address, blockNumber *big.Int) (uint64, error)

func (*ExecutionClient) GetTransactionReceipt

func (ec *ExecutionClient) GetTransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)

func (*ExecutionClient) Initialize

func (ec *ExecutionClient) Initialize(ctx context.Context) error

func (*ExecutionClient) NewBlockFilter

func (ec *ExecutionClient) NewBlockFilter(ctx context.Context) (BlockFilterId, error)

func (*ExecutionClient) SendTransaction

func (ec *ExecutionClient) SendTransaction(ctx context.Context, tx *types.Transaction) error

func (*ExecutionClient) UninstallBlockFilter

func (ec *ExecutionClient) UninstallBlockFilter(ctx context.Context, filterId BlockFilterId) (bool, error)

type SyncStatus

type SyncStatus struct {
	IsSyncing     bool
	StartingBlock uint64
	CurrentBlock  uint64
	HighestBlock  uint64
}

func (*SyncStatus) Percent

func (s *SyncStatus) Percent() float64