eth

Documentation

Overview

Package eth implements the Ethereum protocol.

Index

• Constants
• func Loop(ctx context.Context, db ethdb.RwKV, sync *stagedsync.StagedSync, ...)
• func SendPendingTxsToRpcDaemon(txPool *core.TxPool, notifier *remotedbserver.Events)
• type Config
• type Ethereum
  • func New(stack *node.Node, config *ethconfig.Config, gitCommit string) (*Ethereum, error)
  • func (s *Ethereum) APIs() []rpc.API
  • func (s *Ethereum) ChainKV() ethdb.RwKV
  • func (s *Ethereum) Etherbase() (eb common.Address, err error)
  • func (s *Ethereum) IsMining() bool
  • func (s *Ethereum) NetVersion() (uint64, error)
  • func (s *Ethereum) Protocols() []p2p.Protocol
  • func (s *Ethereum) Start() error
  • func (s *Ethereum) StartMining(ctx context.Context, kv ethdb.RwKV, mining *stagedsync.StagedSync, ...) error
  • func (s *Ethereum) Stop() error
  • func (s *Ethereum) TxPool() *core.TxPool

Constants

const AccountRangeMaxResults = 256

AccountRangeMaxResults is the maximum number of results to be returned per call

Functions

func Loop

func Loop(ctx context.Context, db ethdb.RwKV, sync *stagedsync.StagedSync, controlServer *download.ControlServerImpl, notifier stagedsync.ChainEventNotifier, stateStream bool, waitForDone chan struct{})

Deprecated - use stages.StageLoop

func SendPendingTxsToRpcDaemon

func SendPendingTxsToRpcDaemon(txPool *core.TxPool, notifier *remotedbserver.Events)

Types

type Config

type Config = ethconfig.Config

Config contains the configuration options of the ETH protocol. Deprecated: use ethconfig.Config instead.

type Ethereum

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

Ethereum implements the Ethereum full node service.

func New

func New(stack *node.Node, config *ethconfig.Config, gitCommit string) (*Ethereum, error)

New creates a new Ethereum object (including the initialisation of the common Ethereum object)

func (*Ethereum) APIs

func (s *Ethereum) APIs() []rpc.API

func (*Ethereum) ChainKV

func (s *Ethereum) ChainKV() ethdb.RwKV

func (*Ethereum) Etherbase

func (s *Ethereum) Etherbase() (eb common.Address, err error)

func (*Ethereum) IsMining

func (s *Ethereum) IsMining() bool

func (*Ethereum) NetVersion

func (s *Ethereum) NetVersion() (uint64, error)

func (*Ethereum) Protocols

func (s *Ethereum) Protocols() []p2p.Protocol

Protocols returns all the currently configured network protocols to start.

func (*Ethereum) Start

func (s *Ethereum) Start() error

Start implements node.Lifecycle, starting all internal goroutines needed by the Ethereum protocol implementation.

func (*Ethereum) StartMining

func (s *Ethereum) StartMining(ctx context.Context, kv ethdb.RwKV, mining *stagedsync.StagedSync, cfg params.MiningConfig, gasPrice *uint256.Int, quitCh chan struct{}) error

StartMining starts the miner with the given number of CPU threads. If mining is already running, this method adjust the number of threads allowed to use and updates the minimum price required by the transaction pool.

func (*Ethereum) Stop

func (s *Ethereum) Stop() error

Stop implements node.Service, terminating all internal goroutines used by the Ethereum protocol.

func (*Ethereum) TxPool

func (s *Ethereum) TxPool() *core.TxPool