rtrefresh

func NewRtRefreshManager ¶

func NewRtRefreshManager(h host.Host, rt *kbucket.RoutingTable, autoRefresh bool,
	refreshKeyGenFnc func(cpl uint) (string, error),
	refreshQueryFnc func(ctx context.Context, key string) error,
	refreshPingFnc func(ctx context.Context, p peer.ID) error,
	refreshQueryTimeout time.Duration,
	refreshInterval time.Duration,
	successfulOutboundQueryGracePeriod time.Duration,
	refreshDoneCh chan struct{}) (*RtRefreshManager, error)

NewRtRefreshManager 创建新的路由表刷新管理器 参数:

• h: host.Host 主机
• rt: *kbucket.RoutingTable 路由表
• autoRefresh: bool 是否自动刷新
• refreshKeyGenFnc: func(cpl uint) (string, error) 生成刷新键的函数
• refreshQueryFnc: func(ctx context.Context, key string) error 执行刷新查询的函数
• refreshPingFnc: func(ctx context.Context, p peer.ID) error 执行ping的函数
• refreshQueryTimeout: time.Duration 刷新查询超时时间
• refreshInterval: time.Duration 刷新间隔
• successfulOutboundQueryGracePeriod: time.Duration 成功外发查询的宽限期
• refreshDoneCh: chan struct{} 刷新完成通道

返回值:

• *RtRefreshManager 刷新管理器实例
• error 错误信息