dennis-tra/pcp

View on GitHub
internal/wrap/dht.go

Summary

Maintainability
A
0 mins
Test Coverage
package wrap

import (
    "context"

    "github.com/ipfs/go-cid"
    stddht "github.com/libp2p/go-libp2p-kad-dht"

    "github.com/libp2p/go-libp2p-core/peer"
)

type DHTer interface {
    GetDefaultBootstrapPeerAddrInfos() []peer.AddrInfo
}

type DHT struct{}

func (d DHT) GetDefaultBootstrapPeerAddrInfos() []peer.AddrInfo {
    return stddht.GetDefaultBootstrapPeerAddrInfos()
}

type IpfsDHT interface {
    Provide(context.Context, cid.Cid, bool) error
    FindProvidersAsync(context.Context, cid.Cid, int) <-chan peer.AddrInfo
}