libp2p

Jun 9, 2022

Changes in this version

+ const NetLimitDefaultFilename

+ const NetLimitTraceFilename

+ var NoResourceMgrError = fmt.Errorf(...)

+ func AutoRelayFeeder(cfgPeering config.Peering) func(fx.Lifecycle, host.Host, AddrInfoChan, *ddht.DHT)

+ func NetLimit(mgr network.ResourceManager, scope string) (rcmgr.BasicLimitConfig, error)

+ func NetSetLimit(mgr network.ResourceManager, repo repo.Repo, scope string, ...) error

+ func ResourceManager(cfg config.SwarmConfig) interface

+ type AddrInfoChan chan peer.AddrInfo

+ type NetStatOut struct

+ Peers map[string]network.ScopeStat

+ Protocols map[string]network.ScopeStat

+ Services map[string]network.ScopeStat

+ System *network.ScopeStat

+ Transient *network.ScopeStat

+ func NetStat(mgr network.ResourceManager, scope string) (NetStatOut, error)

Dec 8, 2021

Changes in this version

+ func ForceReachability(val *config.OptionalString) func() (opts Libp2pOpts, err error)

+ func HolePunching(flag config.Flag, hasRelayClient bool) func() (opts Libp2pOpts, err error)

+ func RelayService(enable bool, relayOpts config.RelayService) func() (opts Libp2pOpts, err error)

+ func RelayTransport(enableRelay bool) func() (opts Libp2pOpts, err error)

+ func StaticRelays(relays []string) func() (opts Libp2pOpts, err error)

Jun 22, 2021

Changes in this version

type Libp2pOpts

+ func MultiaddrResolver(rslv *madns.Resolver) (opts Libp2pOpts, err error)

Jun 19, 2020

Changes in this version

+ func Transports(tptConfig config.Transports) interface

Apr 28, 2020

Changes in this version

+ var AutoRelay = simpleOpt(libp2p.ChainOptions(libp2p.EnableAutoRelay(), libp2p.DefaultStaticRelays()))

+ var DHTServerOption = constructDHTRouting(dht.ModeServer)

+ var UserAgent = simpleOpt(libp2p.UserAgent(version.UserAgent))

+ func TopicDiscovery() interface

Jan 30, 2020

Changes in this version

+ func Peerstore(lc fx.Lifecycle) peerstore.Peerstore

May 30, 2019

Changes in this version

+ var AutoRealy = simpleOpt(libp2p.EnableAutoRelay())

+ var DefaultTransports = simpleOpt(libp2p.DefaultTransports)

+ var NatPortMap = simpleOpt(libp2p.NATPortMap())

+ var QUIC = simpleOpt(libp2p.Transport(libp2pquic.NewTransport))

+ func AddrFilters(filters []string) func() (opts Libp2pOpts, err error)

+ func AddrsFactory(announce []string, noAnnounce []string) func() (opts Libp2pOpts, err error)

+ func AutoNATService(quic bool) ...

+ func BaseRouting(lc fx.Lifecycle, in BaseIpfsRouting) (out p2pRouterOut, dr *dht.IpfsDHT)

+ func ConnectionManager(low, high int, grace time.Duration) func() (opts Libp2pOpts, err error)

+ func DiscoveryHandler(mctx helpers.MetricsCtx, lc fx.Lifecycle, host host.Host) *discoveryHandler

+ func FloodSub(pubsubOptions ...pubsub.Option) interface

+ func GossipSub(pubsubOptions ...pubsub.Option) interface

+ func PNet(repo repo.Repo) (opts Libp2pOpts, fp PNetFingerprint, err error)

+ func PNetChecker(repo repo.Repo, ph host.Host, lc fx.Lifecycle) error

+ func PstoreAddSelfKeys(id peer.ID, sk crypto.PrivKey, ps peerstore.Peerstore) error

+ func PubsubRouter(mctx helpers.MetricsCtx, lc fx.Lifecycle, in p2pPSRoutingIn) (p2pRouterOut, *namesys.PubsubValueStore)

+ func Relay(disable, enableHop bool) func() (opts Libp2pOpts, err error)

+ func Routing(in p2pOnlineRoutingIn) routing.IpfsRouting

+ func Security(enabled, preferTLS bool) interface

+ func SetupDiscovery(mdns bool, mdnsInterval int) func(helpers.MetricsCtx, fx.Lifecycle, host.Host, *discoveryHandler) error

+ func SmuxTransport(mplex bool) func() (opts Libp2pOpts, err error)

+ func StartListening(addresses []string) func(host host.Host) error

+ type BaseIpfsRouting routing.IpfsRouting

+ type HostOption func(ctx context.Context, id peer.ID, ps peerstore.Peerstore, ...) (host.Host, error)

+ var DefaultHostOption HostOption = constructPeerHost

+ type Libp2pOpts struct

+ Opts []libp2p.Option

+ func BandwidthCounter() (opts Libp2pOpts, reporter metrics.Reporter)

+ type P2PHostIn struct

+ HostOption HostOption

+ ID peer.ID

+ Opts [][]libp2p.Option

+ Peerstore peerstore.Peerstore

+ Repo repo.Repo

+ RoutingOption RoutingOption

+ Validator record.Validator

+ type P2PHostOut struct

+ Host host.Host

+ Routing BaseIpfsRouting

+ func Host(mctx helpers.MetricsCtx, lc fx.Lifecycle, params P2PHostIn) (out P2PHostOut, err error)

+ type PNetFingerprint []byte

+ type Router struct

+ Priority int

+ type RoutingOption func(context.Context, host.Host, datastore.Batching, record.Validator) (routing.IpfsRouting, error)

+ var DHTClientOption RoutingOption = constructClientDHTRouting

+ var DHTOption RoutingOption = constructDHTRouting

+ var NilRouterOption RoutingOption = nilrouting.ConstructNilRouting