Versions in this module Expand all Collapse all v1 v1.2.0 Jun 19, 2022 v1.1.0 Jun 19, 2022 Changes in this version + const EthMsgSoftCapSize + const Version + func BuildCodec() (codec.Manager, error) + func BuildMessage(codec codec.Manager, msg Message) ([]byte, error) + func RequestToBytes(codec codec.Manager, request Request) ([]byte, error) + type AtomicTx struct + Tx []byte + func (m *AtomicTx) Bytes() []byte + func (msg *AtomicTx) Handle(handler GossipHandler, nodeID ids.ShortID) error + func (msg *AtomicTx) Type() string + type EthTxs struct + Txs []byte + func (m *EthTxs) Bytes() []byte + func (msg *EthTxs) Handle(handler GossipHandler, nodeID ids.ShortID) error + func (msg *EthTxs) Type() string + type GossipHandler interface + HandleAtomicTx func(nodeID ids.ShortID, msg *AtomicTx) error + HandleEthTxs func(nodeID ids.ShortID, msg *EthTxs) error + type Message interface + Bytes func() []byte + Handle func(handler GossipHandler, nodeID ids.ShortID) error + Type func() string + func ParseMessage(codec codec.Manager, bytes []byte) (Message, error) + type NoopMempoolGossipHandler struct + func (NoopMempoolGossipHandler) HandleAtomicTx(nodeID ids.ShortID, _ *AtomicTx) error + func (NoopMempoolGossipHandler) HandleEthTxs(nodeID ids.ShortID, _ *EthTxs) error + type Request interface + Handle func(ctx context.Context, nodeID ids.ShortID, requestID uint32, ...) ([]byte, error) + Type func() string + func BytesToRequest(codec codec.Manager, requestBytes []byte) (Request, error) + type RequestHandler interface + type ResponseHandler interface + OnFailure func(nodeID ids.ShortID, requestID uint32) error + OnResponse func(nodeID ids.ShortID, requestID uint32, response []byte) error
Go to main page