libp2p

Documentation

Index

• func ConnectToPeersContinuously(ctx context.Context, cm *system.CleanupManager, h host.Host, ...) error
• func ConnectToPeersContinuouslyWithRetryDuration(ctx context.Context, cm *system.CleanupManager, h host.Host, ...) error
• func NewHost(port int, opts ...libp2p.Option) (host.Host, error)
• func NewHostForTest(ctx context.Context, peers ...host.Host) (host.Host, error)

Functions

func ConnectToPeersContinuously

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

func ConnectToPeersContinuouslyWithRetryDuration

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

func NewHost

func NewHost(port int, 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)