libp2p

Documentation

Index

• Constants
• Variables
• func ErrorOptOut(val string) fx.Option
• func FloodSub() fx.Option
• func NewHost(lc fx.Lifecycle, ds datastore.Batching, optsList Libp2pOptsIn) (host.Host, routing.Routing, error)
• func OptsOut(opt libp2p.Option) fx.Option
• type BwOut
  • func BandwidthReporter() BwOut
• type ID
• type Libp2pOptsIn
• type Libp2pOptsOut

Constants

const (
	FloodSubID = protocol.ID("/dropfloodsub/1.0.0")
)

Variables

var LibP2P = fx.Options(
	fx.Provide(BandwidthReporter),
	LibP2PDefaultOpts,
	FloodSub(),
	fx.Provide(NewHost),
)

var LibP2PDefaultOpts = fx.Options(
	OptsOut(libp2p.DefaultTransports),
	OptsOut(libp2p.NATPortMap()),
	OptsOut(libp2p.EnableAutoRelay()),
	OptsOut(libp2p.EnableNATService()),
	OptsOut(libp2p.Security(libp2ptls.ID, libp2ptls.New)),
	OptsOut(libp2p.Security(secio.ID, secio.New)),
)

Functions

func ErrorOptOut

func ErrorOptOut(val string) fx.Option

func FloodSub

func FloodSub() fx.Option

func NewHost

func NewHost(
	lc fx.Lifecycle,
	ds datastore.Batching,
	optsList Libp2pOptsIn,
) (host.Host, routing.Routing, error)

func OptsOut

func OptsOut(opt libp2p.Option) fx.Option

Types

type BwOut

type BwOut struct {
	fx.Out

	Opts     libp2p.Option `group:"libp2p_opts"`
	Reporter *metrics.BandwidthCounter
}

func BandwidthReporter

func BandwidthReporter() BwOut

type ID

type ID struct {
	PeerID  string
	PrivKey string `json:",omitempty"`
}

type Libp2pOptsIn

type Libp2pOptsIn struct {
	fx.In

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

type Libp2pOptsOut

type Libp2pOptsOut struct {
	fx.Out

	Opts libp2p.Option `group:"libp2p_opts"`
}