eth

package
v1.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 9, 2015 License: GPL-3.0 Imports: 36 Imported by: 0

Documentation

Overview

Package eth implements the Ethereum protocol.

Index

Constants

View Source 
const (
	NetworkId          = 1
	ProtocolMaxMsgSize = 10 * 1024 * 1024 // Maximum cap on the size of a protocol message
)
View Source 
const (
	StatusMsg = iota
	NewBlockHashesMsg
	TxMsg
	GetBlockHashesMsg
	BlockHashesMsg
	GetBlocksMsg
	BlocksMsg
	NewBlockMsg
	GetBlockHashesFromNumberMsg
)

eth protocol message codes

View Source 
const (
	ErrMsgTooLarge = iota
	ErrDecode
	ErrInvalidMsgCode
	ErrProtocolVersionMismatch
	ErrNetworkIdMismatch
	ErrGenesisBlockMismatch
	ErrNoStatusMsg
	ErrExtraStatusMsg
	ErrSuspendedPeer
)

Variables

View Source 
var ProtocolLengths = []uint64{9, 8}

Number of implemented message corresponding to different protocol versions.

View Source 
var ProtocolVersions = []uint{61, 60}

Supported versions of the eth protocol (first is primary).

Functions

This section is empty.

Types

type Config 

type Config struct {
	Name         string
	NetworkId    int
	GenesisNonce int
	GenesisFile  string
	GenesisBlock *types.Block // used by block tests
	Olympic      bool

	BlockChainVersion  int
	SkipBcVersionCheck bool // e.g. blockchain export
	DatabaseCache      int

	DataDir   string
	LogFile   string
	Verbosity int
	LogJSON   string
	VmDebug   bool
	NatSpec   bool
	AutoDAG   bool
	PowTest   bool
	ExtraData []byte

	MaxPeers        int
	MaxPendingPeers int
	Discovery       bool
	Port            string

	// Space-separated list of discovery node URLs
	BootNodes string

	// This key is used to identify the node on the network.
	// If nil, an ephemeral key is used.
	NodeKey *ecdsa.PrivateKey

	NAT  nat.Interface
	Shh  bool
	Dial bool

	Etherbase      common.Address
	GasPrice       *big.Int
	MinerThreads   int
	AccountManager *accounts.Manager
	SolcPath       string

	GpoMinGasPrice          *big.Int
	GpoMaxGasPrice          *big.Int
	GpoFullBlockRatio       int
	GpobaseStepDown         int
	GpobaseStepUp           int
	GpobaseCorrectionFactor int

	// NewDB is used to create databases.
	// If nil, the default is to create leveldb databases on disk.
	NewDB func(path string) (common.Database, error)
}

type Ethereum 

type Ethereum struct {
	SolcPath string

	GpoMinGasPrice          *big.Int
	GpoMaxGasPrice          *big.Int
	GpoFullBlockRatio       int
	GpobaseStepDown         int
	GpobaseStepUp           int
	GpobaseCorrectionFactor int

	Mining       bool
	MinerThreads int
	NatSpec      bool
	DataDir      string
	AutoDAG      bool
	PowTest      bool
	// contains filtered or unexported fields
}

func New 

func New(config *Config) (*Ethereum, error)

func (*Ethereum) AccountManager 

func (s *Ethereum) AccountManager() *accounts.Manager

func (*Ethereum) AddPeer added in v0.9.39 

func (self *Ethereum) AddPeer(nodeURL string) error

AddPeer connects to the given node and maintains the connection until the server is shut down. If the connection fails for any reason, the server will attempt to reconnect the peer.

func (*Ethereum) BlockProcessor added in v0.9.39 

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

func (*Ethereum) ChainDb 

func (s *Ethereum) ChainDb() common.Database

func (*Ethereum) ChainManager added in v0.9.39 

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

func (*Ethereum) ClientVersion added in v0.9.39 

func (s *Ethereum) ClientVersion() string

func (*Ethereum) DappDb added in v1.1.0 

func (s *Ethereum) DappDb() common.Database

func (*Ethereum) Downloader 

func (s *Ethereum) Downloader() *downloader.Downloader

func (*Ethereum) EthVersion 

func (s *Ethereum) EthVersion() int

func (*Ethereum) Etherbase 

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

func (*Ethereum) EventMux 

func (s *Ethereum) EventMux() *event.TypeMux

func (*Ethereum) IsListening 

func (s *Ethereum) IsListening() bool

func (*Ethereum) IsMining 

func (s *Ethereum) IsMining() bool

func (*Ethereum) MaxPeers added in v0.9.39 

func (s *Ethereum) MaxPeers() int

func (*Ethereum) Miner 

func (s *Ethereum) Miner() *miner.Miner

func (*Ethereum) Name added in v0.9.39 

func (s *Ethereum) Name() string

func (s *Ethereum) Logger() logger.LogSystem { return s.logger }

func (*Ethereum) NetVersion 

func (s *Ethereum) NetVersion() int

func (*Ethereum) NodeInfo added in v0.9.39 

func (s *Ethereum) NodeInfo() *NodeInfo

func (*Ethereum) PeerCount added in v0.9.39 

func (s *Ethereum) PeerCount() int

func (*Ethereum) Peers added in v0.9.39 

func (s *Ethereum) Peers() []*p2p.Peer

func (*Ethereum) PeersInfo added in v0.9.39 

func (s *Ethereum) PeersInfo() (peersinfo []*PeerInfo)

PeersInfo returns an array of PeerInfo objects describing connected peers

func (*Ethereum) ResetWithGenesisBlock 

func (s *Ethereum) ResetWithGenesisBlock(gb *types.Block)

func (*Ethereum) SetEtherbase 

func (self *Ethereum) SetEtherbase(etherbase common.Address)

set in js console via admin interface or wrapper from cli flags

func (*Ethereum) SetSolc added in v0.9.39 

func (self *Ethereum) SetSolc(solcPath string) (*compiler.Solidity, error)

set in js console via admin interface or wrapper from cli flags

func (*Ethereum) ShhVersion added in v0.9.39 

func (s *Ethereum) ShhVersion() int

func (*Ethereum) Solc added in v0.9.39 

func (self *Ethereum) Solc() (*compiler.Solidity, error)

func (*Ethereum) Start 

func (s *Ethereum) Start() error

Start the ethereum

func (*Ethereum) StartAutoDAG added in v0.9.39 

func (self *Ethereum) StartAutoDAG()

StartAutoDAG() spawns a go routine that checks the DAG every autoDAGcheckInterval by default that is 10 times per epoch in epoch n, if we past autoDAGepochHeight within-epoch blocks, it calls ethash.MakeDAG to pregenerate the DAG for the next epoch n+1 if it does not exist yet as well as remove the DAG for epoch n-1 the loop quits if autodagquit channel is closed, it can safely restart and stop any number of times. For any more sophisticated pattern of DAG generation, use CLI subcommand makedag

func (*Ethereum) StartForTest added in v0.9.39 

func (s *Ethereum) StartForTest()

func (*Ethereum) StartMining 

func (s *Ethereum) StartMining(threads int) error

func (*Ethereum) Stop 

func (s *Ethereum) Stop()

func (*Ethereum) StopAutoDAG added in v0.9.39 

func (self *Ethereum) StopAutoDAG()

stopAutoDAG stops automatic DAG pregeneration by quitting the loop

func (*Ethereum) StopMining 

func (s *Ethereum) StopMining()

func (*Ethereum) TxPool 

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

func (*Ethereum) WaitForShutdown added in v0.9.39 

func (s *Ethereum) WaitForShutdown()

This function will wait for a shutdown and resumes main thread execution

func (*Ethereum) Whisper added in v0.9.39 

func (s *Ethereum) Whisper() *whisper.Whisper

type GasPriceOracle added in v0.9.39 

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

func NewGasPriceOracle added in v0.9.39 

func NewGasPriceOracle(eth *Ethereum) (self *GasPriceOracle)

func (*GasPriceOracle) SuggestPrice added in v0.9.39 

func (self *GasPriceOracle) SuggestPrice() *big.Int

type NodeInfo 

type NodeInfo struct {
	Name       string
	NodeUrl    string
	NodeID     string
	IP         string
	DiscPort   int // UDP listening port for discovery protocol
	TCPPort    int // TCP listening port for RLPx
	Td         string
	ListenAddr string
}

type PeerInfo 

type PeerInfo struct {
	ID            string
	Name          string
	Caps          string
	RemoteAddress string
	LocalAddress  string
}

type ProtocolManager 

type ProtocolManager struct {
	SubProtocols []p2p.Protocol
	// contains filtered or unexported fields
}

func NewProtocolManager 

func NewProtocolManager(networkId int, mux *event.TypeMux, txpool txPool, pow pow.PoW, chainman *core.ChainManager) *ProtocolManager

NewProtocolManager returns a new ethereum sub protocol manager. The Ethereum sub protocol manages peers capable with the ethereum network.

func (*ProtocolManager) BroadcastBlock 

func (pm *ProtocolManager) BroadcastBlock(block *types.Block, propagate bool)

BroadcastBlock will either propagate a block to a subset of it's peers, or will only announce it's availability (depending what's requested).

func (*ProtocolManager) BroadcastTx added in v0.9.39 

func (pm *ProtocolManager) BroadcastTx(hash common.Hash, tx *types.Transaction)

BroadcastTx will propagate a transaction to all peers which are not known to already have the given transaction.

func (*ProtocolManager) Start 

func (pm *ProtocolManager) Start()

func (*ProtocolManager) Stop 

func (pm *ProtocolManager) Stop()

Source Files

View all Source files

Directories

Path Synopsis
Package downloader contains the manual full chain synchronisation.
 Package downloader contains the manual full chain synchronisation.
Package fetcher contains the block announcement based synchonisation.
 Package fetcher contains the block announcement based synchonisation.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.