ping

package

v0.0.1 Latest Latest Go to latest Published: Jan 9, 2025 License: MIT Imports: 13 Imported by: 1

Details

View Source

const (
	// ping 消息的大小(字节)
	PingSize = 32

	// ping 协议标识符
	ID = "/ipfs/ping/1.0.0"

	// ping 服务名称
	ServiceName = "libp2p.ping"
)

This section is empty.

func Ping(ctx context.Context, h host.Host, p peer.ID) <-chan Result

Ping 持续向远程节点发送 ping 请求直到上下文被取消参数:

返回值:

type PingService struct {
	// libp2p 主机实例
	Host host.Host
}

PingService ping 服务结构体

func NewPingService(h host.Host) *PingService

NewPingService 创建一个新的 ping 服务参数:

返回值:

func (ps *PingService) Ping(ctx context.Context, p peer.ID) <-chan Result

Ping 向指定节点发送 ping 请求参数:

返回值:

func (p *PingService) PingHandler(s network.Stream)

PingHandler 处理接收到的 ping 请求参数:

type Result struct {
	// RTT 往返时间
	RTT time.Duration
	// Error 错误信息
	Error error
}

Result ping 操作的结果