Versions in this module Expand all Collapse all v1 v1.0.0 Sep 1, 2023 Changes in this version + type Peer struct + func NewPeer(t mockConstructorTestingTNewPeer) *Peer + func (_m *Peer) CloseConn() error + func (_m *Peer) FlushStop() + func (_m *Peer) Get(_a0 string) interface{} + func (_m *Peer) GetRemovalFailed() bool + func (_m *Peer) ID() p2p.ID + func (_m *Peer) IsOutbound() bool + func (_m *Peer) IsPersistent() bool + func (_m *Peer) IsRunning() bool + func (_m *Peer) NodeInfo() p2p.NodeInfo + func (_m *Peer) OnReset() error + func (_m *Peer) OnStart() error + func (_m *Peer) OnStop() + func (_m *Peer) Quit() <-chan struct{} + func (_m *Peer) RemoteAddr() net.Addr + func (_m *Peer) RemoteIP() net.IP + func (_m *Peer) Reset() error + func (_m *Peer) Send(_a0 byte, _a1 []byte) bool + func (_m *Peer) Set(_a0 string, _a1 interface{}) + func (_m *Peer) SetLogger(_a0 log.Logger) + func (_m *Peer) SetRemovalFailed() + func (_m *Peer) SocketAddr() *p2p.NetAddress + func (_m *Peer) Start() error + func (_m *Peer) Status() conn.ConnectionStatus + func (_m *Peer) Stop() error + func (_m *Peer) String() string + func (_m *Peer) TrySend(_a0 byte, _a1 []byte) bool + type PeerEnvelopeSender struct + func NewPeerEnvelopeSender(t mockConstructorTestingTNewPeerEnvelopeSender) *PeerEnvelopeSender + func (_m *PeerEnvelopeSender) CloseConn() error + func (_m *PeerEnvelopeSender) FlushStop() + func (_m *PeerEnvelopeSender) Get(_a0 string) interface{} + func (_m *PeerEnvelopeSender) GetRemovalFailed() bool + func (_m *PeerEnvelopeSender) ID() p2p.ID + func (_m *PeerEnvelopeSender) IsOutbound() bool + func (_m *PeerEnvelopeSender) IsPersistent() bool + func (_m *PeerEnvelopeSender) IsRunning() bool + func (_m *PeerEnvelopeSender) NodeInfo() p2p.NodeInfo + func (_m *PeerEnvelopeSender) OnReset() error + func (_m *PeerEnvelopeSender) OnStart() error + func (_m *PeerEnvelopeSender) OnStop() + func (_m *PeerEnvelopeSender) Quit() <-chan struct{} + func (_m *PeerEnvelopeSender) RemoteAddr() net.Addr + func (_m *PeerEnvelopeSender) RemoteIP() net.IP + func (_m *PeerEnvelopeSender) Reset() error + func (_m *PeerEnvelopeSender) Send(_a0 byte, _a1 []byte) bool + func (_m *PeerEnvelopeSender) SendEnvelope(_a0 p2p.Envelope) bool + func (_m *PeerEnvelopeSender) Set(_a0 string, _a1 interface{}) + func (_m *PeerEnvelopeSender) SetLogger(_a0 log.Logger) + func (_m *PeerEnvelopeSender) SetRemovalFailed() + func (_m *PeerEnvelopeSender) SocketAddr() *p2p.NetAddress + func (_m *PeerEnvelopeSender) Start() error + func (_m *PeerEnvelopeSender) Status() conn.ConnectionStatus + func (_m *PeerEnvelopeSender) Stop() error + func (_m *PeerEnvelopeSender) String() string + func (_m *PeerEnvelopeSender) TrySend(_a0 byte, _a1 []byte) bool + func (_m *PeerEnvelopeSender) TrySendEnvelope(_a0 p2p.Envelope) bool
Go to main page