Versions in this module Expand all Collapse all v0 v0.9.0 Jun 5, 2022 Changes in this version + func MaxNodeInfoSize() int + type ConnFilterFunc func(p2p.ConnSet, net.Conn, []net.IP) error + type ErrCurrentlyDialingOrExistingAddress struct + Addr string + func (e ErrCurrentlyDialingOrExistingAddress) Error() string + type ErrFilterTimeout struct + func (e ErrFilterTimeout) Error() string + type ErrNetAddressInvalid struct + Addr string + Err error + func (e ErrNetAddressInvalid) Error() string + type ErrNetAddressLookup struct + Addr string + Err error + func (e ErrNetAddressLookup) Error() string + type ErrNetAddressNoID struct + Addr string + func (e ErrNetAddressNoID) Error() string + type ErrRejected struct + func (e ErrRejected) Addr() p2p.NetAddress + func (e ErrRejected) Error() string + func (e ErrRejected) IsAuthFailure() bool + func (e ErrRejected) IsDuplicate() bool + func (e ErrRejected) IsFiltered() bool + func (e ErrRejected) IsIncompatible() bool + func (e ErrRejected) IsNodeInfoInvalid() bool + func (e ErrRejected) IsSelf() bool + type ErrSwitchAuthenticationFailure struct + Dialed *p2p.NetAddress + Got p2p.ID + func (e ErrSwitchAuthenticationFailure) Error() string + type ErrSwitchConnectToSelf struct + Addr *p2p.NetAddress + func (e ErrSwitchConnectToSelf) Error() string + type ErrSwitchDuplicatePeerID struct + ID p2p.ID + func (e ErrSwitchDuplicatePeerID) Error() string + type ErrSwitchDuplicatePeerIP struct + IP net.IP + func (e ErrSwitchDuplicatePeerIP) Error() string + type ErrTransportClosed struct + func (e ErrTransportClosed) Error() string + type IPResolver interface + LookupIPAddr func(context.Context, string) ([]net.IPAddr, error) + type MultiplexTransport struct + func NewMultiplexTransport(nodeInfo p2p.NodeInfo, nodeKey p2p.NodeKey, mConfig conn.MConnConfig) *MultiplexTransport + func (mt *MultiplexTransport) Accept(cfg PeerConfig) (p2p.Peer, error) + func (mt *MultiplexTransport) AddChannel(chID byte) + func (mt *MultiplexTransport) Cleanup(p p2p.Peer) + func (mt *MultiplexTransport) Close() error + func (mt *MultiplexTransport) Dial(addr p2p.NetAddress, cfg PeerConfig) (p2p.Peer, error) + func (mt *MultiplexTransport) Listen(addr p2p.NetAddress) error + func (mt *MultiplexTransport) NetAddress() p2p.NetAddress + type MultiplexTransportOption func(*MultiplexTransport) + func MultiplexTransportConnFilters(filters ...ConnFilterFunc) MultiplexTransportOption + func MultiplexTransportFilterTimeout(timeout time.Duration) MultiplexTransportOption + func MultiplexTransportMaxIncomingConnections(n int) MultiplexTransportOption + func MultiplexTransportResolver(resolver IPResolver) MultiplexTransportOption + type PeerConfig struct + type PeerOption func(*peer) + func PeerMetrics(metrics *p2p.Metrics) PeerOption + type Transport interface + Accept func(PeerConfig) (p2p.Peer, error) + Cleanup func(p2p.Peer) + Dial func(p2p.NetAddress, PeerConfig) (p2p.Peer, error) + NetAddress func() p2p.NetAddress