p2pd

package module
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 21, 2023 License: Apache-2.0, MIT Imports: 35 Imported by: 0

README

libp2p Daemon

GoDoc Discourse posts

A standalone deployment of a libp2p host, running in its own OS process and installing a set of virtual endpoints to enable co-local applications to: communicate with peers, handle protocols, interact with the DHT, participate in pubsub, etc. no matter the language they are developed in, nor whether a native libp2p implementation exists in that language.

Maintainance

The learning-at-home team maintains this fork because the upstream repository (libp2p/go-libp2p-daemon) is not maintained by its original developers anymore.

This fork is used for all networking in Hivemind and Petals projects. This allows us to have protocol-agnostic networking with NAT traversal & libp2p relay features.

Install

This repo uses Go modules. Note that go >=1.12 is required.

$ # outside your GOPATH
$ git clone https://github.com/learning-at-home/go-libp2p-daemon
$ cd go-libp2p-daemon
$ git checkout <release tag, e.g. v0.0.1>
$ go get ./...
$ go install ./...
$ p2pd

See available releases.

Usage

Check out the GoDocs.

Language Bindings

Daemon bindings enable applications written in other languages to interact with the libp2p daemon process programmatically, by exposing an idiomatic API that handles the socket dynamics and control protocol.

The following bindings exist so far (if you want yours added, please send a PR):

If you wish to implement bindings in a new language, refer to the spec for the daemon control protocol and API.

Contribute

Feel free to join in. All welcome. Open an issue!

This repository falls under the IPFS Code of Conduct.

License

MIT


The last gx published version of this module was: 0.0.20: QmVBYP5AGurRJGiyTcyoUf5Etyvf2vwxKd8DMaQgbpJF58

Documentation

Index

Constants

View Source
const BootstrapConnections = 4
View Source
const DefaultTimeout = 60 * time.Second

Variables

View Source
var BootstrapPeers = dht.DefaultBootstrapPeers

Functions

func BeginRelayDiscovery

func BeginRelayDiscovery(h host.Host, dht *dht.IpfsDHT, trustedRelays []string, peerSourceChan chan<- peer.AddrInfo) context.CancelFunc

func ConfigureRelayService

func ConfigureRelayService(opts []libp2p.Option, maxCircuits int, maxReservations int, relayBufferSize int, dataLimit int64, timeLimit time.Duration) []libp2p.Option

func MaybeConfigureAutoRelay

func MaybeConfigureAutoRelay(opts []libp2p.Option, relayDiscovery bool, trustedRelays []string) ([]libp2p.Option, chan peer.AddrInfo)

func ReadIdentity

func ReadIdentity(path string) (crypto.PrivKey, error)

func WriteIdentity

func WriteIdentity(k crypto.PrivKey, path string) error

Types

type Daemon

type Daemon struct {
	// contains filtered or unexported fields
}

func NewDaemon

func NewDaemon(
	ctx context.Context,
	maddr ma.Multiaddr,
	dhtMode string,
	relayDiscovery bool,
	trustedRelays []string,
	persistentConnMsgMaxSize int,
	opts ...libp2p.Option,
) (*Daemon, error)

func (*Daemon) Addrs

func (d *Daemon) Addrs() []ma.Multiaddr

func (*Daemon) Bootstrap

func (d *Daemon) Bootstrap() error

func (*Daemon) Close

func (d *Daemon) Close() error

func (*Daemon) DHTRoutingFactory

func (d *Daemon) DHTRoutingFactory(opts []dhtopts.Option) func(host.Host) (routing.PeerRouting, error)

func (*Daemon) EnablePubsub

func (d *Daemon) EnablePubsub(router string, sign, strict bool) error

func (*Daemon) EnableRelayV2 added in v0.5.0

func (d *Daemon) EnableRelayV2() error

func (*Daemon) ID

func (d *Daemon) ID() peer.ID

func (*Daemon) KillOnTimeout

func (d *Daemon) KillOnTimeout(timeout time.Duration)

func (*Daemon) Listener

func (d *Daemon) Listener() manet.Listener

func (*Daemon) Serve

func (d *Daemon) Serve() error

Directories

Path Synopsis
internal

Jump to

Keyboard shortcuts

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