The highest tagged major version is
Documentation
¶
Index ¶
- Constants
- Variables
- func NewAddressesReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *addressesRequestHandler
- func NewAddressesRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *addressesResponseHandler
- func NewBlockProducedNoticeHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *blockProducedNoticeHandler
- func NewBlockReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *blockRequestHandler
- func NewBlockRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *blockResponseHandler
- func NewGetAncestorReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *getAncestorRequestHandler
- func NewGetAncestorRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *getAncestorResponseHandler
- func NewGetClusterReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *getClusterRequestHandler
- func NewGetClusterRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *getClusterResponseHandler
- func NewGetHashByNoReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *getHashByNoRequestHandler
- func NewGetHashByNoRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *getHashByNoResponseHandler
- func NewGetHashesReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *getHashRequestHandler
- func NewGetHashesRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *getHashResponseHandler
- func NewGoAwayHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *goAwayHandler
- func NewListBlockHeadersReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *listBlockHeadersRequestHandler
- func NewListBlockRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *listBlockHeadersResponseHandler
- func NewNewBlockNoticeHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *newBlockNoticeHandler
- func NewNewTxNoticeHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *newTxNoticeHandler
- func NewPingReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *pingRequestHandler
- func NewPingRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *pingResponseHandler
- func NewTxReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *txRequestHandler
- func NewTxRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *txResponseHandler
- type BaseMsgHandler
Constants ¶
View Source
const ( StatusRequest p2pcommon.SubProtocol PingRequest PingResponse GoAway AddressesRequest AddressesResponse )
NOTE: change const of protocols_test.go
View Source
const ( GetBlocksRequest p2pcommon.SubProtocol = 0x010 + iota GetBlocksResponse GetBlockHeadersRequest GetBlockHeadersResponse GetMissingRequest // Deprecated GetMissingResponse // Deprecated NewBlockNotice GetAncestorRequest GetAncestorResponse GetHashesRequest GetHashesResponse GetHashByNoRequest GetHashByNoResponse )
View Source
const ( GetTXsRequest p2pcommon.SubProtocol = 0x020 + iota GetTXsResponse NewTxNotice )
View Source
const ( GetClusterRequest p2pcommon.SubProtocol GetClusterResponse )
View Source
const ( // BlockProducedNotice from block producer to trusted nodes and other bp nodes BlockProducedNotice p2pcommon.SubProtocol = 0x030 + iota )
subprotocols for block producers and their own trusted nodes
View Source
const (
EmptyGetBlockResponseSize = 12 // roughly estimated maximum size if element is full
)
Variables ¶
View Source
var (
ErrConsensusAccessorNotReady = errors.New("consensus acessor is not ready")
)
Functions ¶
func NewAddressesReqHandler ¶
func NewAddressesReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *addressesRequestHandler
newAddressesReqHandler creates handler for PingRequest
func NewAddressesRespHandler ¶
func NewAddressesRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *addressesResponseHandler
newAddressesRespHandler creates handler for PingRequest
func NewBlockProducedNoticeHandler ¶
func NewBlockProducedNoticeHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService, sm p2pcommon.SyncManager) *blockProducedNoticeHandler
newNewBlockNoticeHandler creates handler for NewBlockNotice
func NewBlockReqHandler ¶
func NewBlockReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *blockRequestHandler
newBlockReqHandler creates handler for GetBlockRequest
func NewBlockRespHandler ¶
func NewBlockRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService, sm p2pcommon.SyncManager) *blockResponseHandler
newBlockRespHandler creates handler for GetBlockResponse
func NewGetAncestorReqHandler ¶
func NewGetAncestorReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *getAncestorRequestHandler
newGetAncestorReqHandler creates handler for GetAncestorRequest
func NewGetAncestorRespHandler ¶
func NewGetAncestorRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *getAncestorResponseHandler
newBlockRespHandler creates handler for GetAncestorResponse
func NewGetClusterReqHandler ¶
func NewGetClusterReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService, consAcc consensus.ConsensusAccessor) *getClusterRequestHandler
NewGetClusterReqHandler creates handler for PingRequest
func NewGetClusterRespHandler ¶
func NewGetClusterRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *getClusterResponseHandler
NewGetClusterRespHandler creates handler for PingRequest
func NewGetHashByNoReqHandler ¶
func NewGetHashByNoReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *getHashByNoRequestHandler
newBlockReqHandler creates handler for GetBlockRequest
func NewGetHashByNoRespHandler ¶
func NewGetHashByNoRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *getHashByNoResponseHandler
newBlockReqHandler creates handler for GetBlockRequest
func NewGetHashesReqHandler ¶
func NewGetHashesReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *getHashRequestHandler
newBlockReqHandler creates handler for GetBlockRequest
func NewGetHashesRespHandler ¶
func NewGetHashesRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *getHashResponseHandler
newBlockReqHandler creates handler for GetBlockRequest
func NewGoAwayHandler ¶
func NewGoAwayHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *goAwayHandler
newGoAwayHandler creates handler for PingResponse
func NewListBlockHeadersReqHandler ¶
func NewListBlockHeadersReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *listBlockHeadersRequestHandler
newListBlockHeadersReqHandler creates handler for GetBlockHeadersRequest
func NewListBlockRespHandler ¶
func NewListBlockRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *listBlockHeadersResponseHandler
newListBlockRespHandler creates handler for GetBlockHeadersResponse
func NewNewBlockNoticeHandler ¶
func NewNewBlockNoticeHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService, sm p2pcommon.SyncManager) *newBlockNoticeHandler
newNewBlockNoticeHandler creates handler for NewBlockNotice
func NewNewTxNoticeHandler ¶
func NewNewTxNoticeHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService, sm p2pcommon.SyncManager) *newTxNoticeHandler
newNewTxNoticeHandler creates handler for GetTransactionsResponse
func NewPingReqHandler ¶
func NewPingReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *pingRequestHandler
newPingReqHandler creates handler for PingRequest
func NewPingRespHandler ¶
func NewPingRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *pingResponseHandler
newPingRespHandler creates handler for PingResponse
func NewTxReqHandler ¶
func NewTxReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *txRequestHandler
newTxReqHandler creates handler for GetTransactionsRequest
func NewTxRespHandler ¶
func NewTxRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *txResponseHandler
newTxRespHandler creates handler for GetTransactionsResponse
Types ¶
type BaseMsgHandler ¶
type BaseMsgHandler struct {
// contains filtered or unexported fields
}
func(msg *types.P2PMessage) BaseMsgHandler contains common attributes of MessageHandler
func (*BaseMsgHandler) CheckAuth ¶
func (bh *BaseMsgHandler) CheckAuth(msg p2pcommon.Message, msgBody p2pcommon.MessageBody) error
func (*BaseMsgHandler) PostHandle ¶
func (bh *BaseMsgHandler) PostHandle(msg p2pcommon.Message, msgBody p2pcommon.MessageBody)
func (*BaseMsgHandler) PreHandle ¶
func (bh *BaseMsgHandler) PreHandle()
Source Files
Click to show internal directories.
Click to hide internal directories.