p2p

package module

Go to main page

Versions in this module

v1

v1.1.0

Sep 5, 2019

Changes in this version

type Peer

+ func (peer *Peer) SendMsg(msg *InternalMsg) error

v1.0.0

Apr 18, 2019

Changes in this version

type AddressManager

+ func (addrManager *AddressManager) GetAddressAttemptInfo(addr *common.NetAddress) (attemptNum uint32, lastAttemptTime time.Time)

+ func (addrManager *AddressManager) ResetAddressAttemptInfo(addr *common.NetAddress)

+ func (addrManager *AddressManager) UpdateAddressAttemptInfo(addr *common.NetAddress)

+ type AttemptInfo struct

+ AttemptNum uint32

+ LastAttemptTime atomic.Value

+ type DebugHandler struct

+ func NewDebugHandler(p2p *P2P, center types.EventCenter, debugServer string) *DebugHandler

+ func (this *DebugHandler) BroadCastMsgEventSubscriber(msg interface{})

+ func (this *DebugHandler) RecvMsgEventSubscriber(msg interface{})

+ func (this *DebugHandler) ReportNeighborHandler()

+ func (this *DebugHandler) Start()

+ func (this *DebugHandler) Stop()

type Peer

+ func (peer *Peer) IsOutBound() bool

+ type PeerCom struct

v0

v0.2.0

Dec 6, 2018

Changes in this version

+ const MAX_BUF_LEN

+ const WRITE_DEADLINE

+ func LocalState() uint64

+ type AddressManager struct

+ func NewAddressManager(filePath string) *AddressManager

+ func (addrManager *AddressManager) AddAddress(addr *common.NetAddress)

+ func (addrManager *AddressManager) AddAddresses(addrs []*common.NetAddress)

+ func (addrManager *AddressManager) AddLocalAddress(port int32) error

+ func (addrManager *AddressManager) AddOurAddress(addr *common.NetAddress)

+ func (addrManager *AddressManager) GetAddress() (*common.NetAddress, error)

+ func (addrManager *AddressManager) GetAddressCount() int

+ func (addrManager *AddressManager) GetAddresses() []*common.NetAddress

+ func (addrManager *AddressManager) GetAllAddress() []*common.NetAddress

+ func (addrManager *AddressManager) IsOurAddress(addr *common.NetAddress) bool

+ func (addrManager *AddressManager) NeedMoreAddrs() bool

+ func (addrManager *AddressManager) OurAddresses() []*common.NetAddress

+ func (addrManager *AddressManager) RemoveAddress(addr *common.NetAddress)

+ func (addrManager *AddressManager) Save()

+ func (addrManager *AddressManager) Start()

+ func (addrManager *AddressManager) Stop()

+ type InternalMsg struct

+ From *common.NetAddress

+ Payload message.Message

+ RespTo chan interface{}

+ To *common.NetAddress

+ type P2P struct

+ func NewP2P(config *config.P2PConfig) (*P2P, error)

+ func (service *P2P) BroadCast(msg message.Message)

+ func (service *P2P) Gather(peerFilter PeerFilter, reqMsg message.Message) error

+ func (service *P2P) GetInBountPeersCount() int

+ func (service *P2P) GetOutBountPeersCount() int

+ func (service *P2P) GetPeerByAddress(addr *common.NetAddress) *Peer

+ func (service *P2P) GetPeers() []*Peer

+ func (service *P2P) MessageChan() <-chan *InternalMsg

+ func (service *P2P) SendMsg(peerAddr *common.NetAddress, msg message.Message) error

+ func (service *P2P) Start() error

+ func (service *P2P) Stop()

+ type P2PAPI interface

+ BroadCast func(msg message.Message)

+ Gather func(peerFilter PeerFilter, reqMsg message.Message) error

+ MessageChan func() <-chan *InternalMsg

+ SendMsg func(peerAddr *common.NetAddress, msg message.Message) error

+ Start func() error

+ Stop func()

+ type Peer struct

+ func NewInboundPeer(serverAddr, addr *common.NetAddress, msgChan chan<- *InternalMsg, ...) *Peer

+ func NewOutboundPeer(serverAddr, addr *common.NetAddress, persistent bool, ...) *Peer

+ func (peer *Peer) Channel() chan<- *InternalMsg

+ func (peer *Peer) CurrentState() uint64

+ func (peer *Peer) GetAddr() *common.NetAddress

+ func (peer *Peer) GetState() uint64

+ func (peer *Peer) IsPersistent() bool

+ func (peer *Peer) KnownMsg(msg message.Message) bool

+ func (peer *Peer) SetState(state uint64)

+ func (peer *Peer) Start() error

+ func (peer *Peer) Stop()

+ type PeerConn struct

+ func NewPeerConn(conn net.Conn, recvChan chan message.Message) *PeerConn

+ func (peerConn *PeerConn) SendMessage(msg message.Message) error

+ func (peerConn *PeerConn) Start()

+ func (peerConn *PeerConn) Stop()

+ type PeerFilter func(peerState uint64) bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL