types

type BaseProtocol struct {
	*P2PEnv
}

type BaseStreamHandler struct {
	Protocol IProtocol
	// contains filtered or unexported fields
}

type EventHandler func(*queue.Message)

type IConnManager interface {
	FetchConnPeers() []peer.ID
	BoundSize() (in int, out int)
	IsNeighbors(id peer.ID) bool
	GetLatencyByPeer(pids []peer.ID) map[string]time.Duration
	GetNetRate() metrics.Stats
	BandTrackerByProtocol() *types.NetProtocolInfos
	RateCaculate(ratebytes float64) string
}

type IPeerInfoManager interface {
	Copy(dest *types.Peer, source *types.P2PPeerInfo)
	Add(pid string, info *types.Peer)
	FetchPeerInfosInMin() []*types.Peer
	GetPeerInfoInMin(key string) *types.Peer
}

type IProtocol interface {
	InitProtocol(*P2PEnv)
	GetP2PEnv() *P2PEnv
}

type P2PEnv struct {
	ChainCfg        *types.Chain33Config
	QueueClient     queue.Client
	Host            core.Host
	ConnManager     IConnManager
	PeerInfoManager IPeerInfoManager
	Discovery       *net.Discovery
	P2PManager      *p2p.Manager
	SubConfig       *p2pty.P2PSubConfig
	Pubsub          *net.PubSub
	Ctx             context.Context
	DB              ds.Datastore
	RoutingTable    *kbt.RoutingTable
	*discovery.RoutingDiscovery
}

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

type RoutingTabler interface {
	RoutingTable() *kbt.RoutingTable
}

type StreamHandler interface {
	// GetProtocol get protocol
	GetProtocol() IProtocol
	// SetProtocol 初始化公共结构, 内部通过protocol获取外部依赖公共类, 如queue.client等
	SetProtocol(protocol IProtocol)
	// VerifyRequest  验证请求数据
	VerifyRequest(message types.Message, messageComm *types.MessageComm) bool
	//SignMessage
	SignProtoMessage(message types.Message, host core.Host) ([]byte, error)
	// Handle 处理请求
	Handle(stream core.Stream)
	// ReuseStream 复用stream，处理后不进行关闭
	ReuseStream() bool
}

type StreamRequest struct {
	// PeerID peer id
	PeerID core.PeerID
	// MsgID stream msg id
	MsgID []core.ProtocolID
	// Data request data
	Data types.Message
}