mock

Documentation

Index

• type Peer
  • func NewPeer(ip net.IP) *Peer
  • 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

Types

type Peer

type Peer struct {
	*cmn.BaseService

	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