libp2p

Documentation

Index

• Constants
• func ConnectToPeer(ctx context.Context, h host.Host, peer host.Host) error
• 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 GeneratePrivateKey(numBits int) (crypto.PrivKey, error)
• func NewHost(port int, privKey crypto.PrivKey, opts ...libp2p.Option) (host.Host, error)
• func NewHostForTest(ctx context.Context, peers ...host.Host) (host.Host, error)
• type PeerInfoDecorator
  • func NewPeerInfoDecorator(params PeerInfoDecoratorParams) *PeerInfoDecorator
  • func (l *PeerInfoDecorator) DecorateNodeInfo(ctx context.Context, nodeInfo models.NodeInfo) models.NodeInfo
• type PeerInfoDecoratorParams

Constants

const DefaultKeySize = 2048

Functions

func ConnectToPeer

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

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

func GeneratePrivateKey

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)

Types

type PeerInfoDecorator

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

func NewPeerInfoDecorator

func NewPeerInfoDecorator(params PeerInfoDecoratorParams) *PeerInfoDecorator

func (*PeerInfoDecorator) DecorateNodeInfo

func (l *PeerInfoDecorator) DecorateNodeInfo(ctx context.Context, nodeInfo models.NodeInfo) models.NodeInfo

type PeerInfoDecoratorParams

type PeerInfoDecoratorParams struct {
	Host            host.Host
	IdentityService identify.IDService
}