mock

Documentation

Index

• type Peer
  • func NewPeer() *Peer
  • func (*Peer) Close() error
  • func (*Peer) Connection() conn.Connection
  • func (*Peer) Direction() peer.Direction
  • func (a *Peer) Handshake() proto.Handshake
  • func (a *Peer) ID() string
  • func (*Peer) Reconnect() error
  • func (a *Peer) RemoteAddr() proto.TCPAddr
  • func (a *Peer) SendMessage(m proto.Message)

Types

type Peer

type Peer struct {
	Addr                  string
	SendMessageCalledWith []proto.Message
	IncomeCh              chan peer.ProtoMessage
	HandshakeField        proto.Handshake
	RemoteAddress         proto.TCPAddr
	// contains filtered or unexported fields
}

func NewPeer

func NewPeer() *Peer

func (*Peer) Close

func (*Peer) Close() error

func (*Peer) Connection

func (*Peer) Connection() conn.Connection

func (*Peer) Direction

func (*Peer) Direction() peer.Direction

func (*Peer) Handshake

func (a *Peer) Handshake() proto.Handshake

func (*Peer) ID

func (a *Peer) ID() string

func (*Peer) Reconnect

func (*Peer) Reconnect() error

func (*Peer) RemoteAddr

func (a *Peer) RemoteAddr() proto.TCPAddr

func (*Peer) SendMessage

func (a *Peer) SendMessage(m proto.Message)