libp2p

func ConnectToPeer ¶ added in v0.3.26

func ConnectToPeer(ctx context.Context, h host.Host, peer host.Host) error

func ConnectToPeersContinuously ¶

func ConnectToPeersContinuously(ctx context.Context, cm *system.CleanupManager, h host.Host, peers []multiaddr.Multiaddr) error

func ConnectToPeersContinuouslyWithRetryDuration ¶ added in v0.3.24

func ConnectToPeersContinuouslyWithRetryDuration(
	ctx context.Context,
	cm *system.CleanupManager,
	h host.Host,
	peers []multiaddr.Multiaddr,
	tickDuration time.Duration,
) error

func GeneratePrivateKey ¶ added in v1.0.4

func GeneratePrivateKey(numBits int) (crypto.PrivKey, error)

func NewHost ¶

func NewHost(port int, privKey crypto.PrivKey, opts ...libp2p.Option) (host.Host, error)

NewHost creates a new libp2p host with some default configuration. It will continuously connect to bootstrap peers if they are defined.

func NewHostForTest ¶

func NewHostForTest(ctx context.Context, peers ...host.Host) (host.Host, error)