This section is empty.


This section is empty.


This section is empty.


type Peer

type Peer struct {

	Outbound, Persistent bool
	// contains filtered or unexported fields

func NewPeer

func NewPeer(ip net.IP) *Peer

    NewPeer creates and starts a new mock peer. If the ip is nil, random routable address is used.

    func (*Peer) CloseConn

    func (mp *Peer) CloseConn() error

    func (*Peer) FlushStop

    func (mp *Peer) FlushStop()

    func (*Peer) Get

    func (mp *Peer) Get(key string) interface{}

    func (*Peer) ID

    func (mp *Peer) ID() p2p.ID

    func (*Peer) IsOutbound

    func (mp *Peer) IsOutbound() bool

    func (*Peer) IsPersistent

    func (mp *Peer) IsPersistent() bool

    func (*Peer) NodeInfo

    func (mp *Peer) NodeInfo() p2p.NodeInfo

    func (*Peer) RemoteAddr

    func (mp *Peer) RemoteAddr() net.Addr

    func (*Peer) RemoteIP

    func (mp *Peer) RemoteIP() net.IP

    func (*Peer) Send

    func (mp *Peer) Send(chID byte, msgBytes []byte) bool

    func (*Peer) Set

    func (mp *Peer) Set(key string, value interface{})

    func (*Peer) SocketAddr

    func (mp *Peer) SocketAddr() *p2p.NetAddress

    func (*Peer) Status

    func (mp *Peer) Status() conn.ConnectionStatus

    func (*Peer) TrySend

    func (mp *Peer) TrySend(chID byte, msgBytes []byte) bool

    type Reactor

    type Reactor struct {

    func NewReactor

    func NewReactor() *Reactor

    func (*Reactor) AddPeer

    func (r *Reactor) AddPeer(peer p2p.Peer)

    func (*Reactor) GetChannels

    func (r *Reactor) GetChannels() []*conn.ChannelDescriptor

    func (*Reactor) Receive

    func (r *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte)

    func (*Reactor) RemovePeer

    func (r *Reactor) RemovePeer(peer p2p.Peer, reason interface{})

    Source Files