Versions in this module Expand all Collapse all v0 v0.5.22 Jul 23, 2014 Changes in this version + const CapChainTy + const CapDefault + const CapPeerDiscTy + const CapTxTy + const DiscBadPeer + const DiscBadProto + const DiscConnDup + const DiscGenesisErr + const DiscProtoErr + const DiscQuitting + const DiscReRequested + const DiscReTcpSysErr + const DiscTooManyPeers + const ProtocolVersion + type Caps byte + func (c Caps) IsCap(cap Caps) bool + func (c Caps) String() string + type DiscReason byte + func (d DiscReason) String() string + type Ethereum struct + Addr net.Addr + MaxPeers int + Mining bool + Nonce uint64 + Port string + RpcServer *ethrpc.JsonRpcServer + func New(db ethutil.Database, clientIdentity ethwire.ClientIdentity, ...) (*Ethereum, error) + func (s *Ethereum) AddPeer(conn net.Conn) + func (s *Ethereum) BlockChain() *ethchain.BlockChain + func (s *Ethereum) Broadcast(msgType ethwire.MsgType, data []interface{}) + func (s *Ethereum) BroadcastMsg(msg *ethwire.Msg) + func (s *Ethereum) ClientIdentity() ethwire.ClientIdentity + func (s *Ethereum) ConnectToPeer(addr string) error + func (s *Ethereum) InOutPeers() []*Peer + func (s *Ethereum) InboundPeers() []*Peer + func (s *Ethereum) IsListening() bool + func (s *Ethereum) IsMining() bool + func (s *Ethereum) IsUpToDate() bool + func (s *Ethereum) KeyManager() *ethcrypto.KeyManager + func (s *Ethereum) OutboundPeers() []*Peer + func (s *Ethereum) PeerCount() int + func (s *Ethereum) Peers() *list.List + func (s *Ethereum) ProcessPeerList(addrs []string) + func (s *Ethereum) PushPeer(peer *Peer) + func (s *Ethereum) Reactor() *ethutil.ReactorEngine + func (s *Ethereum) ReapDeadPeerHandler() + func (s *Ethereum) RemovePeer(p *Peer) + func (s *Ethereum) Seed() + func (s *Ethereum) ServerCaps() Caps + func (s *Ethereum) Start(seed bool) + func (s *Ethereum) StateManager() *ethchain.StateManager + func (s *Ethereum) Stop() + func (s *Ethereum) TxPool() *ethchain.TxPool + func (s *Ethereum) WaitForShutdown() + type NAT interface + AddPortMapping func(protocol string, externalPort, internalPort int, description string, ...) (mappedExternalPort int, err error) + DeletePortMapping func(protocol string, externalPort, internalPort int) (err error) + GetExternalAddress func() (addr net.IP, err error) + func Discover() (nat NAT, err error) + func NewNatPMP(gateway net.IP) (nat NAT) + type Peer struct + func NewOutboundPeer(addr string, ethereum *Ethereum, caps Caps) *Peer + func NewPeer(conn net.Conn, ethereum *Ethereum, inbound bool) *Peer + func (p *Peer) CatchupWithPeer(blockHash []byte) + func (p *Peer) Connected() *int32 + func (p *Peer) FindCommonParentBlock() + func (p *Peer) HandleInbound() + func (p *Peer) HandleOutbound() + func (p *Peer) Host() []byte + func (p *Peer) Inbound() bool + func (p *Peer) LastPong() int64 + func (p *Peer) LastSend() time.Time + func (p *Peer) PingTime() string + func (p *Peer) Port() uint16 + func (p *Peer) QueueMessage(msg *ethwire.Msg) + func (p *Peer) RlpData() []interface{} + func (p *Peer) SetVersion(version string) + func (p *Peer) Start() + func (p *Peer) Stop() + func (p *Peer) String() string + func (p *Peer) SyncWithPeerToLastKnown() + func (p *Peer) Version() string