libp2p

Documentation

Index

• Variables
• func AddrFilters(filters []string) func() (opts Libp2pOpts, err error)
• func AddrsFactory(announce []string, noAnnounce []string) func() (opts Libp2pOpts, err error)
• func AutoNATService(throttle *config.AutoNATThrottleConfig) func() Libp2pOpts
• func BaseRouting(lc fx.Lifecycle, in BaseIpfsRouting) (out p2pRouterOut, dr *ddht.DHT)
• 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 Peerstore(lc fx.Lifecycle) peerstore.Peerstore
• 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, error)
• func Relay(disable, enableHop bool) func() (opts Libp2pOpts, err error)
• func Routing(in p2pOnlineRoutingIn) routing.Routing
• func Security(enabled 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
• func TopicDiscovery() interface{}
• type BaseIpfsRouting
• type HostOption
• type Libp2pOpts
  • func BandwidthCounter() (opts Libp2pOpts, reporter *metrics.BandwidthCounter)
• type P2PHostIn
• type P2PHostOut
  • func Host(mctx helpers.MetricsCtx, lc fx.Lifecycle, params P2PHostIn) (out P2PHostOut, err error)
• type PNetFingerprint
• type Router
• type RoutingOption

Variables

var (
	DHTOption       RoutingOption = constructDHTRouting(dht.ModeAuto)
	DHTClientOption               = constructDHTRouting(dht.ModeClient)
	DHTServerOption               = constructDHTRouting(dht.ModeServer)
	NilRouterOption               = nilrouting.ConstructNilRouting
)

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

var DefaultTransports = simpleOpt(libp2p.DefaultTransports)

var NatPortMap = simpleOpt(libp2p.NATPortMap())

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

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

Functions

func AddrFilters

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

func AddrsFactory

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

func AutoNATService

func AutoNATService(throttle *config.AutoNATThrottleConfig) func() Libp2pOpts

func BaseRouting

func BaseRouting(lc fx.Lifecycle, in BaseIpfsRouting) (out p2pRouterOut, dr *ddht.DHT)

func ConnectionManager

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

func DiscoveryHandler

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

func FloodSub

func FloodSub(pubsubOptions ...pubsub.Option) interface{}

func GossipSub

func GossipSub(pubsubOptions ...pubsub.Option) interface{}

func PNet

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

func PNetChecker

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

func Peerstore

func Peerstore(lc fx.Lifecycle) peerstore.Peerstore

func PstoreAddSelfKeys

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

func PubsubRouter

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

func Relay

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

func Routing

func Routing(in p2pOnlineRoutingIn) routing.Routing

func Security

func Security(enabled bool) interface{}

func SetupDiscovery

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

func SmuxTransport

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

func StartListening

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

func TopicDiscovery

func TopicDiscovery() interface{}

Types

type BaseIpfsRouting

type BaseIpfsRouting routing.Routing

type HostOption

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

var DefaultHostOption HostOption = constructPeerHost

type Libp2pOpts

type Libp2pOpts struct {
	fx.Out

	Opts []libp2p.Option `group:"libp2p"`
}

func BandwidthCounter

func BandwidthCounter() (opts Libp2pOpts, reporter *metrics.BandwidthCounter)

type P2PHostIn

type P2PHostIn struct {
	fx.In

	Repo          repo.Repo
	Validator     record.Validator
	HostOption    HostOption
	RoutingOption RoutingOption
	ID            peer.ID
	Peerstore     peerstore.Peerstore

	Opts [][]libp2p.Option `group:"libp2p"`
}

type P2PHostOut

type P2PHostOut struct {
	fx.Out

	Host    host.Host
	Routing BaseIpfsRouting
}

func Host

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

type PNetFingerprint

type PNetFingerprint []byte

type Router

type Router struct {
	routing.Routing

	Priority int // less = more important
}

type RoutingOption

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