mock

package

v0.33.1-dev1 Latest Latest Go to latest Published: Feb 26, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Peer struct {
	*service.BaseService

	Outbound, Persistent bool
	// contains filtered or unexported fields
}

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 (mp *Peer) CloseConn() error

func (mp *Peer) FlushStop()

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

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

func (mp *Peer) IsOutbound() bool

func (mp *Peer) IsPersistent() bool

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

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

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

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

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

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

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

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

type Reactor struct {
	p2p.BaseReactor
}

func NewReactor() *Reactor

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

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

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

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