lp2p

package

v0.0.0-...-6be4821 Latest Latest Go to latest Published: Mar 26, 2024 License: Apache-2.0, MIT Imports: 20 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ribasushi/go-toolbox-interplanetary

Links

Open Source Insights

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)

Constants ¶

This section is empty.

Variables ¶

View Source

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)

Source Files ¶

View all Source files

lp2p.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL