Versions in this module Expand all Collapse all v6 v6.4.0 May 18, 2020 Changes in this version + func AuthenticateMessage(message types.Message, data *types.MessageComm) bool + func ClearEventHandler() + func CloseStream(stream core.Stream) + func NewStream(host core.Host, pid core.PeerID, msgID string) (core.Stream, error) + func ReadStream(data types.Message, stream core.Stream) error + func RegisterEventHandler(eventID int64, handler EventHandler) + func RegisterProtocol(typeName string, proto IProtocol) + func RegisterStreamHandler(typeName, msgID string, handler StreamHandler) + func SignProtoMessage(message types.Message, host core.Host) ([]byte, error) + func WriteStream(data types.Message, stream core.Stream) error + type BaseProtocol struct + func (base *BaseProtocol) GetChainCfg() *types.Chain33Config + func (base *BaseProtocol) GetConnsManager() *manage.ConnManager + func (base *BaseProtocol) GetHost() core.Host + func (base *BaseProtocol) GetP2PEnv() *P2PEnv + func (base *BaseProtocol) GetPeerInfoManager() *manage.PeerInfoManager + func (base *BaseProtocol) GetQueueClient() queue.Client + func (base *BaseProtocol) InitProtocol(data *P2PEnv) + func (base *BaseProtocol) NewMessageCommon(msgID, pid string, nodePubkey []byte, gossip bool) *types.MessageComm + func (base *BaseProtocol) SendPeer(req *StreamRequest) error + func (base *BaseProtocol) SendRecvPeer(req *StreamRequest, resp types.Message) error + func (base *BaseProtocol) SendToBlockChain(ty int64, data interface{}) (interface{}, error) + func (base *BaseProtocol) SendToMemPool(ty int64, data interface{}) (interface{}, error) + type BaseStreamHandler struct + Protocol IProtocol + func (s *BaseStreamHandler) GetProtocol() IProtocol + func (s *BaseStreamHandler) Handle(core.Stream) + func (s *BaseStreamHandler) HandleStream(stream core.Stream) + func (s *BaseStreamHandler) SetProtocol(protocol IProtocol) + func (s *BaseStreamHandler) SignProtoMessage(message types.Message, host core.Host) ([]byte, error) + func (s *BaseStreamHandler) VerifyRequest(message types.Message, messageComm *types.MessageComm) bool + type EventHandler func(*queue.Message) + func GetEventHandler(eventID int64) (EventHandler, bool) + type IProtocol interface + GetP2PEnv func() *P2PEnv + InitProtocol func(*P2PEnv) + type P2PEnv struct + ChainCfg *types.Chain33Config + ConnManager *manage.ConnManager + Discovery *net.Discovery + Host core.Host + P2PManager *p2p.Manager + PeerInfoManager *manage.PeerInfoManager + QueueClient queue.Client + SubConfig *p2pty.P2PSubConfig + type ProtocolManager struct + func (p *ProtocolManager) Init(env *P2PEnv) + type StreamHandler interface + GetProtocol func() IProtocol + Handle func(stream core.Stream) + SetProtocol func(protocol IProtocol) + SignProtoMessage func(message types.Message, host core.Host) ([]byte, error) + VerifyRequest func(message types.Message, messageComm *types.MessageComm) bool + type StreamRequest struct + Data types.Message + MsgID string + PeerID core.PeerID Other modules containing this package github.com/33cn/chain33