lp2p

Documentation

Index

• Variables
• func ConnectAndProtect(ctx context.Context, nodeHost Host, ai AddrInfo) (closer func(), tookMsecs int64, err error)
• func NewPlainNodeTCP(withTimeout time.Duration) (lp2phost.Host, *infomempeerstore.PeerStore, error)
• type AddrInfo
  • func AddrInfoFromLp2p(ai lp2ppeer.AddrInfo) AddrInfo
  • func AssembleAddrInfo[M interface{ ... }](pID *PeerID, addrs []M) (AddrInfo, error)
  • func (ai *AddrInfo) ToLp2p() lp2ppeer.AddrInfo
• type Host
• type PeerID
• type RPCTook
  • func ExecCborRPC(ctx context.Context, nodeHost Host, peerAddr AddrInfo, proto lp2pproto.ID, ...) (RPCTook, error)

Variables

var DefaultRPCTimeout = time.Duration(5 * time.Minute)

Functions

func ConnectAndProtect

func ConnectAndProtect(ctx context.Context, nodeHost Host, ai AddrInfo) (closer func(), tookMsecs int64, err error)

func NewPlainNodeTCP

func NewPlainNodeTCP(withTimeout time.Duration) (lp2phost.Host, *infomempeerstore.PeerStore, error)

Types

type AddrInfo

type AddrInfo struct {
	PeerID     *PeerID               `json:"peerid"`
	MultiAddrs []multiaddr.Multiaddr `json:"multiaddrs"`
}

AddrInfo is a better annotated version of lp2ppeer.AddrInfo

func AddrInfoFromLp2p

func AddrInfoFromLp2p(ai lp2ppeer.AddrInfo) AddrInfo

func AssembleAddrInfo

func AssembleAddrInfo[M interface{ ~string | ~[]byte }](pID *PeerID, addrs []M) (AddrInfo, error)

func (*AddrInfo) ToLp2p

func (ai *AddrInfo) ToLp2p() lp2ppeer.AddrInfo

type Host

type Host = lp2phost.Host

type PeerID

type PeerID = lp2ppeer.ID

type RPCTook

type RPCTook struct {
	LocalPeerID      *PeerID `json:"dialing_peerid"`
	PeerConnectMsecs *int64  `json:"peer_connect_took_msecs,omitempty"`
	StreamOpenMsecs  *int64  `json:"stream_open_took_msecs,omitempty"`
	StreamWriteMsecs *int64  `json:"stream_write_took_msecs,omitempty"`
	StreamReadMsecs  *int64  `json:"stream_read_took_msecs,omitempty"`
}

func ExecCborRPC

func ExecCborRPC(
	ctx context.Context, nodeHost Host,
	peerAddr AddrInfo, proto lp2pproto.ID,
	args interface{}, resp interface{},
) (RPCTook, error)