Versions in this module Expand all Collapse all v0 v0.8.4 Feb 20, 2015 Changes in this version + const BlockHashesMsg + const BlocksMsg + const ErrDecode + const ErrExtraStatusMsg + const ErrGenesisBlockMismatch + const ErrInsufficientChainInfo + const ErrInvalidBlock + const ErrInvalidMsgCode + const ErrInvalidPoW + const ErrMsgTooLarge + const ErrNetworkIdMismatch + const ErrNoStatusMsg + const ErrProtocolVersionMismatch + const ErrUnrequestedBlock + const GetBlockHashesMsg + const GetBlocksMsg + const GetTxMsg + const NetworkId + const NewBlockMsg + const ProtocolLength + const ProtocolMaxMsgSize + const ProtocolVersion + const StatusMsg + const TxMsg + func EthProtocol(txPool txPool, chainManager chainManager, blockPool blockPool) p2p.Protocol + func ProtocolError(code int, format string, params ...interface{}) (err *protocolError) + func ReadPeers(path string) (ips []string, err error) + func WritePeers(path string, addresses []string) + type BlockPool struct + func NewBlockPool(hasBlock func(hash []byte) bool, insertChain func(types.Blocks) error, ...) *BlockPool + func (self *BlockPool) AddBlock(block *types.Block, peerId string) + func (self *BlockPool) AddBlockHashes(next func() ([]byte, bool), peerId string) + func (self *BlockPool) AddPeer(td *big.Int, currentBlockHash []byte, peerId string, ...) (best bool) + func (self *BlockPool) Purge() + func (self *BlockPool) RemovePeer(peerId string) + func (self *BlockPool) Start() + func (self *BlockPool) Stop() + func (self *BlockPool) Wait(t time.Duration) + type Config struct + BootNodes string + DataDir string + Dial bool + KeyManager *crypto.KeyManager + KeyRing string + KeyStore string + LogFile string + LogFormat string + LogLevel int + MaxPeers int + MinerThreads int + NAT nat.Interface + Name string + NodeKey *ecdsa.PrivateKey + Port string + Shh bool + type Ethereum struct + Mining bool + RpcServer rpc.RpcServer + WsServer rpc.RpcServer + func New(config *Config) (*Ethereum, error) + func (s *Ethereum) BlockPool() *BlockPool + func (s *Ethereum) BlockProcessor() *core.BlockProcessor + func (s *Ethereum) ChainManager() *core.ChainManager + func (s *Ethereum) Coinbase() []byte + func (s *Ethereum) Db() ethutil.Database + func (s *Ethereum) EventMux() *event.TypeMux + func (s *Ethereum) IsListening() bool + func (s *Ethereum) KeyManager() *crypto.KeyManager + func (s *Ethereum) Logger() ethlogger.LogSystem + func (s *Ethereum) MaxPeers() int + func (s *Ethereum) Miner() *miner.Miner + func (s *Ethereum) Name() string + func (s *Ethereum) PeerCount() int + func (s *Ethereum) Peers() []*p2p.Peer + func (s *Ethereum) Start() error + func (s *Ethereum) Stop() + func (s *Ethereum) TxPool() *core.TxPool + func (s *Ethereum) WaitForShutdown() + func (s *Ethereum) Whisper() *whisper.Whisper + func (self *Ethereum) SuggestPeer(nodeURL string) error v0.8.4-1 Feb 20, 2015