Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

subproto

package

Go to main page

Versions in this module

v1

v1.11.1

Jun 4, 2019

v1.11.0

Jun 4, 2019

v1.3.1

Nov 6, 2019

v1.3.0

Oct 7, 2019

v1.2.3

Sep 6, 2019

v1.2.2

Aug 27, 2019

v1.2.1

Aug 22, 2019

v1.2.0

Aug 7, 2019

Changes in this version

+ func DebugLogRaftWrapMsg(logger *log.Logger, peer p2pcommon.RemotePeer, msgID p2pcommon.MsgID, ...)

+ func NewBPNoticeDiscardHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) p2pcommon.MessageHandler

+ func NewBlkNoticeDiscardHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) p2pcommon.MessageHandler

+ func NewGetBlockHeaderRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *getBlockHeadersResponseHandler

+ func NewGetBlockHeadersReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *getBlockHeadersRequestHandler

+ func NewRaftWrapperHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *raftWrapperHandler

+ func WithTimeLog(handler p2pcommon.MessageHandler, logger *log.Logger, level zerolog.Level) p2pcommon.MessageHandler

type BaseMsgHandler

+ func (bh *BaseMsgHandler) AddAdvice(advice p2pcommon.HandlerAdvice)

+ type LogHandleTimeAdvice struct

+ func (a *LogHandleTimeAdvice) PostHandle(msg p2pcommon.Message, msgBody p2pcommon.MessageBody)

+ func (a *LogHandleTimeAdvice) PreHandle()

v1.1.2

Jun 28, 2019

v1.1.1

Jun 17, 2019

v1.1.0

Jun 4, 2019

v1.0.5

May 22, 2019

v1.0.4

May 2, 2019

v1.0.3

Apr 22, 2019

v1.0.2

Apr 16, 2019

v1.0.1

Apr 15, 2019

v1.0.0

Apr 12, 2019

v1.0.0-rc1

Mar 28, 2019

v0

v0.9.0

Jun 3, 2019

Changes in this version

+ const AddressesRequest

+ const AddressesResponse

+ const BlockProducedNotice

+ const EmptyGetBlockResponseSize

+ const GetAncestorRequest

+ const GetAncestorResponse

+ const GetBlockHeadersRequest

+ const GetBlockHeadersResponse

+ const GetBlocksRequest

+ const GetBlocksResponse

+ const GetClusterRequest

+ const GetClusterResponse

+ const GetHashByNoRequest

+ const GetHashByNoResponse

+ const GetHashesRequest

+ const GetHashesResponse

+ const GetMissingRequest

+ const GetMissingResponse

+ const GetTXsRequest

+ const GetTXsResponse

+ const GoAway

+ const NewBlockNotice

+ const NewTxNotice

+ const PingRequest

+ const PingResponse

+ const StatusRequest

+ var ErrConsensusAccessorNotReady = errors.New("consensus acessor is not ready")

+ 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 struct

+ func (bh *BaseMsgHandler) CheckAuth(msg p2pcommon.Message, msgBody p2pcommon.MessageBody) error

+ func (bh *BaseMsgHandler) PostHandle(msg p2pcommon.Message, msgBody p2pcommon.MessageBody)

+ func (bh *BaseMsgHandler) PreHandle()

Other modules containing this package

github.com/aergoio/aergo/v2