p2pd

README

libp2p Daemon

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.

🚧 This project is not actively maintained and is unsupported! 🚧

It has reached viable PoC stage but is not being actively worked on or maintained. If you want to play around with libp2p, go ahead and try this project out. However:

• There is little documentation and no support.
• The libp2p version used in this project will not be actively updated.

In other words: DO NOT USE IN PRODUCTION

Install

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

$ # outside your GOPATH
$ git clone https://github.com/libp2p/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):

• Go (reference implementation): see the p2pclient package in this repo.
• Python: py-libp2p-daemon-bindings.
• Gerbil: gerbil-libp2p.
• Nim: nim-libp2p
• Elixir: elixir-libp2p

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
• Variables
• func ReadIdentity(path string) (crypto.PrivKey, error)
• func WriteIdentity(k crypto.PrivKey, path string) error
• type Daemon
  • func NewDaemon(ctx context.Context, maddr ma.Multiaddr, dhtMode string, opts ...libp2p.Option) (*Daemon, error)
  • func (d *Daemon) Addrs() []ma.Multiaddr
  • func (d *Daemon) Bootstrap() error
  • func (d *Daemon) Close() error
  • func (d *Daemon) DHTRoutingFactory(opts []dhtopts.Option) func(host.Host) (routing.PeerRouting, error)
  • func (d *Daemon) EnableEcho() error
  • func (d *Daemon) EnablePubsub(router string, sign, strict bool) error
  • func (d *Daemon) EnableRelayV2() error
  • func (d *Daemon) ID() peer.ID
  • func (d *Daemon) Listener() manet.Listener

Constants

const BootstrapConnections = 4

const DefaultTimeout = 60 * time.Second

Variables

var BootstrapPeers = dht.DefaultBootstrapPeers

Functions

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, 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) EnableEcho

func (d *Daemon) EnableEcho() error

func (*Daemon) EnablePubsub

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

func (*Daemon) EnableRelayV2

func (d *Daemon) EnableRelayV2() error

func (*Daemon) ID

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

func (*Daemon) Listener

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