p2p

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

type Message struct {
	From     PeerID // 发送方 peer ID
	Data     []byte // 载荷
	Reliable bool   // true=通过可靠通道到达; false=通过不可靠通道到达
}

type Network interface {
	// LocalID 返回本节点的 peer ID。
	LocalID() PeerID

	// Peers 返回当前已连接的所有 peer。
	Peers() []PeerConn

	// Peer 按 ID 获取已连接的 peer;不存在返回 nil。
	Peer(id PeerID) PeerConn

	// Events 返回 peer 生命周期事件通道。
	Events() <-chan PeerEvent

	// Broadcast 向所有已连接的 peer 广播。reliable 决定走哪条通道。
	// 返回第一个遇到的错误(或 nil);部分 peer 发送失败不影响其余。
	Broadcast(data []byte, reliable bool) error

	// Close 关闭网络(断开所有 peer 连接)。
	Close() error
}

type PeerConn interface {
	// ID 返回远端 peer 的标识。
	ID() PeerID

	// SendReliable 通过可靠有序通道发送数据(类似 TCP 语义)。
	SendReliable(data []byte) error

	// SendUnreliable 通过不可靠无序通道发送数据(类似 UDP 语义)。
	// 超过底层 MTU 的负载可能被丢弃或返回错误——大负载走 SendReliable。
	SendUnreliable(data []byte) error

	// Recv 返回接收通道;关闭连接后通道会被关闭。
	Recv() <-chan Message

	// Context 返回连接生命周期 ctx(连接断开时取消)。
	Context() context.Context

	// Close 关闭连接。幂等。
	Close() error
}

type PeerEvent struct {
	PeerID PeerID
	State  PeerState
	Conn   PeerConn // PeerStateConnected 时有效
}

type PeerID = string

type PeerState int

type Transport interface {
	io.Closer

	// Connect 主动向目标 peer 发起连接。地址解析由具体实现负责(如通过构造时传入的地址簿)。
	Connect(ctx context.Context, peerID PeerID) (PeerConn, error)

	// Accept 阻塞等待一个入站的 peer 连接。Transport 关闭后返回错误。
	Accept(ctx context.Context) (PeerConn, error)

	// Addr 返回本 Transport 的监听地址(可用于告知其他 peer 如何连接本节点)。
	Addr() string
}