peerinfo

Documentation

Index

• type PeerInfo
  • func New(tcpNode host.Host, peers []peer.ID, version string, lockHash []byte, ...) *PeerInfo
  • func NewForT(_ *testing.T, tcpNode host.Host, peers []peer.ID, version string, ...) *PeerInfo
  • func (p *PeerInfo) Run(ctx context.Context)

Types

type PeerInfo

type PeerInfo struct {
	// contains filtered or unexported fields
}

func New

func New(tcpNode host.Host, peers []peer.ID, version string, lockHash []byte, gitHash string,
	sendFunc p2p.SendReceiveFunc,
) *PeerInfo

New returns a new peer info protocol instance.

func NewForT

func NewForT(_ *testing.T, tcpNode host.Host, peers []peer.ID, version string, lockHash []byte, gitHash string,
	sendFunc p2p.SendReceiveFunc, registerHandler p2p.RegisterHandlerFunc,
	tickerProvider tickerProvider, nowFunc nowFunc, metricSubmitter metricSubmitter,
) *PeerInfo

NewForT returns a new peer info protocol instance for testing only.

func (*PeerInfo) Run

func (p *PeerInfo) Run(ctx context.Context)

Run runs the peer info protocol until the context is cancelled.