go-ethereum

Dec 21, 2014

Changes in this version

+ const NetVersion

+ const P2PVersion

+ const ProtocolVersion

+ func PastPeers() []string

+ type BlockPool struct

+ BlocksProcessed int

+ ChainLength int

+ func NewBlockPool(eth *Ethereum) *BlockPool

+ func (self *BlockPool) Add(b *types.Block, peer *Peer)

+ func (self *BlockPool) AddHash(hash []byte, peer *Peer)

+ func (self *BlockPool) AddNew(b *types.Block, peer *Peer)

+ func (self *BlockPool) Blocks() (blocks types.Blocks)

+ func (self *BlockPool) DistributeHashes()

+ func (self *BlockPool) FetchHashes(peer *Peer) bool

+ func (self *BlockPool) HasCommonHash(hash []byte) bool

+ func (self *BlockPool) HasLatestHash() bool

+ func (self *BlockPool) Len() int

+ func (self *BlockPool) Remove(hash []byte)

+ func (self *BlockPool) Reset()

+ func (self *BlockPool) Start()

+ func (self *BlockPool) Stop()

+ type Caps byte

+ const CapChainTy

+ const CapDefault

+ const CapPeerDiscTy

+ const CapTxTy

+ func (c Caps) IsCap(cap Caps) bool

+ func (c Caps) String() string

+ type ChainSyncEvent struct

+ InSync bool

+ type DiscReason byte

+ const DiscBadPeer

+ const DiscBadProto

+ const DiscConnDup

+ const DiscGenesisErr

+ const DiscProtoErr

+ const DiscQuitting

+ const DiscReTcpSysErr

+ const DiscRequested

+ const DiscTooManyPeers

+ func (d DiscReason) String() string

+ type Ethereum struct

+ Addr net.Addr

+ MaxPeers int

+ Mining bool

+ Nonce uint64

+ Port string

+ RpcServer *rpc.JsonRpcServer

+ func New(db ethutil.Database, clientIdentity wire.ClientIdentity, ...) (*Ethereum, error)

+ func (s *Ethereum) AddPeer(conn net.Conn)

+ func (s *Ethereum) BlockManager() *core.BlockManager

+ func (s *Ethereum) BlockPool() *BlockPool

+ func (s *Ethereum) Broadcast(msgType wire.MsgType, data []interface{})

+ func (s *Ethereum) BroadcastMsg(msg *wire.Msg)

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

+ func (s *Ethereum) ClientIdentity() wire.ClientIdentity

+ func (s *Ethereum) ConnectToPeer(addr string) error

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

+ func (s *Ethereum) HighestTDPeer() (td *big.Int)

+ 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() *crypto.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) RemovePeer(p *Peer)

+ func (s *Ethereum) Seed()

+ func (s *Ethereum) ServerCaps() Caps

+ func (s *Ethereum) Start(seed bool)

+ func (s *Ethereum) Stop()

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

+ func (s *Ethereum) WaitForShutdown()

+ func (self *Ethereum) BlacklistPeer(peer *Peer)

+ func (self *Ethereum) Db() ethutil.Database

+ func (self *Ethereum) GetFilter(id int) *core.Filter

+ func (self *Ethereum) InstallFilter(filter *core.Filter) (id int)

+ func (self *Ethereum) UninstallFilter(id int)

+ 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) Connected() *int32

+ 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 *wire.Msg)

+ func (p *Peer) RlpData() []interface{}

+ func (p *Peer) SetVersion(version string)

+ func (p *Peer) Start()

+ func (p *Peer) Stop()

+ func (p *Peer) StopWithReason(reason DiscReason)

+ func (p *Peer) String() string

+ func (p *Peer) Version() string

+ func (self *Peer) Caps() *ethutil.Value

+ func (self *Peer) Connect(addr string) (conn net.Conn, err error)

+ func (self *Peer) FetchBlocks(hashes [][]byte)

+ func (self *Peer) FetchHashes() bool

+ func (self *Peer) FetchingHashes() bool

+ func (self *Peer) IsCap(cap string) bool

+ type PeerListEvent struct

+ Peers *list.List