crawler

type Crawler interface {
	// Run 从startingPeers开始爬取DHT,根据是否成功联系到对等节点调用handleSuccess或handleFail
	// 参数:
	//   - ctx: context.Context 上下文
	//   - startingPeers: []*peer.AddrInfo 起始对等节点列表
	//   - handleSuccess: HandleQueryResult 查询成功的回调函数
	//   - handleFail: HandleQueryFail 查询失败的回调函数
	Run(ctx context.Context, startingPeers []*peer.AddrInfo, handleSuccess HandleQueryResult, handleFail HandleQueryFail)
}

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

type HandleQueryFail func(p peer.ID, err error)

type HandleQueryResult func(p peer.ID, rtPeers []*peer.AddrInfo)

type Option func(*options) error