Versions in this module Expand all Collapse all v1 v1.9.8 Jun 28, 2023 Changes in this version + var AsynchronousOps = []Op + var ConsensusExternalOps = append(ConsensusRequestOps, append(ConsensusResponseOps, AppGossipOp)) + var ConsensusInternalOps = []Op + var ConsensusOps = append(ConsensusExternalOps, ConsensusInternalOps) + var ConsensusRequestOps = []Op + var ConsensusResponseOps = []Op + var ExternalOps = append(ConsensusExternalOps, HandshakeOps) + var FailedToResponseOps = map[Op]Op + var HandshakeOps = []Op + var SynchronousOps = []Op + var UnrequestedOps = set.Set[Op] + func GetChainID(m any) (ids.ID, error) + func GetDeadline(m any) (time.Duration, bool) + func GetEngineType(m any) (p2p.EngineType, bool) + func GetRequestID(m any) (uint32, bool) + func GetSourceChainID(m any) (ids.ID, error) + func Unwrap(m *p2p.Message) (interface{}, error) + type AppRequestFailed struct + ChainID ids.ID + RequestID uint32 + func (m *AppRequestFailed) GetChainId() []byte + func (m *AppRequestFailed) GetRequestId() uint32 + type Connected struct + NodeVersion *version.Application + type ConnectedSubnet struct + SubnetID ids.ID + type Creator interface + func NewCreator(metrics prometheus.Registerer, parentNamespace string, compressionEnabled bool, ...) (Creator, error) + type CrossChainAppRequest struct + DestinationChainID ids.ID + Message []byte + RequestID uint32 + SourceChainID ids.ID + func (m *CrossChainAppRequest) GetChainId() []byte + func (m *CrossChainAppRequest) GetRequestId() uint32 + func (m *CrossChainAppRequest) GetSourceChainID() ids.ID + type CrossChainAppRequestFailed struct + DestinationChainID ids.ID + RequestID uint32 + SourceChainID ids.ID + func (m *CrossChainAppRequestFailed) GetChainId() []byte + func (m *CrossChainAppRequestFailed) GetRequestId() uint32 + func (m *CrossChainAppRequestFailed) GetSourceChainID() ids.ID + type CrossChainAppResponse struct + DestinationChainID ids.ID + Message []byte + RequestID uint32 + SourceChainID ids.ID + func (m *CrossChainAppResponse) GetChainId() []byte + func (m *CrossChainAppResponse) GetRequestId() uint32 + func (m *CrossChainAppResponse) GetSourceChainID() ids.ID + type Disconnected struct + type GetAcceptedFailed struct + ChainID ids.ID + EngineType p2p.EngineType + RequestID uint32 + func (m *GetAcceptedFailed) GetChainId() []byte + func (m *GetAcceptedFailed) GetEngineType() p2p.EngineType + func (m *GetAcceptedFailed) GetRequestId() uint32 + type GetAcceptedFrontierFailed struct + ChainID ids.ID + EngineType p2p.EngineType + RequestID uint32 + func (m *GetAcceptedFrontierFailed) GetChainId() []byte + func (m *GetAcceptedFrontierFailed) GetEngineType() p2p.EngineType + func (m *GetAcceptedFrontierFailed) GetRequestId() uint32 + type GetAcceptedStateSummaryFailed struct + ChainID ids.ID + RequestID uint32 + func (m *GetAcceptedStateSummaryFailed) GetChainId() []byte + func (m *GetAcceptedStateSummaryFailed) GetRequestId() uint32 + type GetAncestorsFailed struct + ChainID ids.ID + EngineType p2p.EngineType + RequestID uint32 + func (m *GetAncestorsFailed) GetChainId() []byte + func (m *GetAncestorsFailed) GetEngineType() p2p.EngineType + func (m *GetAncestorsFailed) GetRequestId() uint32 + type GetFailed struct + ChainID ids.ID + EngineType p2p.EngineType + RequestID uint32 + func (m *GetFailed) GetChainId() []byte + func (m *GetFailed) GetEngineType() p2p.EngineType + func (m *GetFailed) GetRequestId() uint32 + type GetStateSummaryFrontierFailed struct + ChainID ids.ID + RequestID uint32 + func (m *GetStateSummaryFrontierFailed) GetChainId() []byte + func (m *GetStateSummaryFrontierFailed) GetRequestId() uint32 + type GossipRequest struct + type InboundMessage interface + BytesSavedCompression func() int + Expiration func() time.Time + Message func() any + NodeID func() ids.NodeID + OnFinishedHandling func() + Op func() Op + func InboundAccepted(chainID ids.ID, requestID uint32, containerIDs []ids.ID, nodeID ids.NodeID, ...) InboundMessage + func InboundAcceptedFrontier(chainID ids.ID, requestID uint32, containerIDs []ids.ID, nodeID ids.NodeID, ...) InboundMessage + func InboundAcceptedStateSummary(chainID ids.ID, requestID uint32, summaryIDs []ids.ID, nodeID ids.NodeID) InboundMessage + func InboundAppRequest(chainID ids.ID, requestID uint32, deadline time.Duration, msg []byte, ...) InboundMessage + func InboundAppResponse(chainID ids.ID, requestID uint32, msg []byte, nodeID ids.NodeID) InboundMessage + func InboundChits(chainID ids.ID, requestID uint32, preferredContainerIDs []ids.ID, ...) InboundMessage + func InboundGetAccepted(chainID ids.ID, requestID uint32, deadline time.Duration, ...) InboundMessage + func InboundGetAcceptedFrontier(chainID ids.ID, requestID uint32, deadline time.Duration, nodeID ids.NodeID, ...) InboundMessage + func InboundGetAcceptedStateSummary(chainID ids.ID, requestID uint32, heights []uint64, deadline time.Duration, ...) InboundMessage + func InboundGetStateSummaryFrontier(chainID ids.ID, requestID uint32, deadline time.Duration, nodeID ids.NodeID) InboundMessage + func InboundPullQuery(chainID ids.ID, requestID uint32, deadline time.Duration, containerID ids.ID, ...) InboundMessage + func InboundPushQuery(chainID ids.ID, requestID uint32, deadline time.Duration, container []byte, ...) InboundMessage + func InboundStateSummaryFrontier(chainID ids.ID, requestID uint32, summary []byte, nodeID ids.NodeID) InboundMessage + func InternalAppRequestFailed(nodeID ids.NodeID, chainID ids.ID, requestID uint32) InboundMessage + func InternalConnected(nodeID ids.NodeID, nodeVersion *version.Application) InboundMessage + func InternalConnectedSubnet(nodeID ids.NodeID, subnetID ids.ID) InboundMessage + func InternalCrossChainAppRequest(nodeID ids.NodeID, sourceChainID ids.ID, destinationChainID ids.ID, ...) InboundMessage + func InternalCrossChainAppRequestFailed(nodeID ids.NodeID, sourceChainID ids.ID, destinationChainID ids.ID, ...) InboundMessage + func InternalCrossChainAppResponse(nodeID ids.NodeID, sourceChainID ids.ID, destinationChainID ids.ID, ...) InboundMessage + func InternalDisconnected(nodeID ids.NodeID) InboundMessage + func InternalGetAcceptedFailed(nodeID ids.NodeID, chainID ids.ID, requestID uint32, engineType p2p.EngineType) InboundMessage + func InternalGetAcceptedFrontierFailed(nodeID ids.NodeID, chainID ids.ID, requestID uint32, engineType p2p.EngineType) InboundMessage + func InternalGetAcceptedStateSummaryFailed(nodeID ids.NodeID, chainID ids.ID, requestID uint32) InboundMessage + func InternalGetAncestorsFailed(nodeID ids.NodeID, chainID ids.ID, requestID uint32, engineType p2p.EngineType) InboundMessage + func InternalGetFailed(nodeID ids.NodeID, chainID ids.ID, requestID uint32, engineType p2p.EngineType) InboundMessage + func InternalGetStateSummaryFrontierFailed(nodeID ids.NodeID, chainID ids.ID, requestID uint32) InboundMessage + func InternalGossipRequest(nodeID ids.NodeID) InboundMessage + func InternalQueryFailed(nodeID ids.NodeID, chainID ids.ID, requestID uint32, engineType p2p.EngineType) InboundMessage + func InternalTimeout(nodeID ids.NodeID) InboundMessage + func InternalVMMessage(nodeID ids.NodeID, notification uint32) InboundMessage + type InboundMsgBuilder interface + Parse func(bytes []byte, nodeID ids.NodeID, onFinishedHandling func()) (InboundMessage, error) + type MockOutboundMessage struct + func NewMockOutboundMessage(ctrl *gomock.Controller) *MockOutboundMessage + func (m *MockOutboundMessage) BypassThrottling() bool + func (m *MockOutboundMessage) Bytes() []byte + func (m *MockOutboundMessage) BytesSavedCompression() int + func (m *MockOutboundMessage) EXPECT() *MockOutboundMessageMockRecorder + func (m *MockOutboundMessage) Op() Op + type MockOutboundMessageMockRecorder struct + func (mr *MockOutboundMessageMockRecorder) BypassThrottling() *gomock.Call + func (mr *MockOutboundMessageMockRecorder) Bytes() *gomock.Call + func (mr *MockOutboundMessageMockRecorder) BytesSavedCompression() *gomock.Call + func (mr *MockOutboundMessageMockRecorder) Op() *gomock.Call + type MockOutboundMsgBuilder struct + func NewMockOutboundMsgBuilder(ctrl *gomock.Controller) *MockOutboundMsgBuilder + func (m *MockOutboundMsgBuilder) Accepted(arg0 ids.ID, arg1 uint32, arg2 []ids.ID, arg3 p2p.EngineType) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) AcceptedFrontier(arg0 ids.ID, arg1 uint32, arg2 []ids.ID, arg3 p2p.EngineType) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) AcceptedStateSummary(arg0 ids.ID, arg1 uint32, arg2 []ids.ID) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) Ancestors(arg0 ids.ID, arg1 uint32, arg2 [][]byte, arg3 p2p.EngineType) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) AppGossip(arg0 ids.ID, arg1 []byte) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) AppRequest(arg0 ids.ID, arg1 uint32, arg2 time.Duration, arg3 []byte) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) AppResponse(arg0 ids.ID, arg1 uint32, arg2 []byte) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) Chits(arg0 ids.ID, arg1 uint32, arg2, arg3 []ids.ID, arg4 p2p.EngineType) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) EXPECT() *MockOutboundMsgBuilderMockRecorder + func (m *MockOutboundMsgBuilder) Get(arg0 ids.ID, arg1 uint32, arg2 time.Duration, arg3 ids.ID, arg4 p2p.EngineType) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) GetAccepted(arg0 ids.ID, arg1 uint32, arg2 time.Duration, arg3 []ids.ID, ...) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) GetAcceptedFrontier(arg0 ids.ID, arg1 uint32, arg2 time.Duration, arg3 p2p.EngineType) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) GetAcceptedStateSummary(arg0 ids.ID, arg1 uint32, arg2 time.Duration, arg3 []uint64) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) GetAncestors(arg0 ids.ID, arg1 uint32, arg2 time.Duration, arg3 ids.ID, arg4 p2p.EngineType) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) GetStateSummaryFrontier(arg0 ids.ID, arg1 uint32, arg2 time.Duration) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) PeerList(arg0 []ips.ClaimedIPPort, arg1 bool) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) PeerListAck(arg0 []*p2p.PeerAck) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) Ping() (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) Pong(arg0 uint32, arg1 []*p2p.SubnetUptime) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) PullQuery(arg0 ids.ID, arg1 uint32, arg2 time.Duration, arg3 ids.ID, arg4 p2p.EngineType) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) PushQuery(arg0 ids.ID, arg1 uint32, arg2 time.Duration, arg3 []byte, arg4 p2p.EngineType) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) Put(arg0 ids.ID, arg1 uint32, arg2 []byte, arg3 p2p.EngineType) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) StateSummaryFrontier(arg0 ids.ID, arg1 uint32, arg2 []byte) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) Version(arg0 uint32, arg1 uint64, arg2 ips.IPPort, arg3 string, arg4 uint64, ...) (OutboundMessage, error) + type MockOutboundMsgBuilderMockRecorder struct + func (mr *MockOutboundMsgBuilderMockRecorder) Accepted(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) AcceptedFrontier(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) AcceptedStateSummary(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) Ancestors(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) AppGossip(arg0, arg1 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) AppRequest(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) AppResponse(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) Chits(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) Get(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) GetAccepted(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) GetAcceptedFrontier(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) GetAcceptedStateSummary(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) GetAncestors(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) GetStateSummaryFrontier(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) PeerList(arg0, arg1 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) PeerListAck(arg0 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) Ping() *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) Pong(arg0, arg1 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) PullQuery(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) PushQuery(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) Put(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) StateSummaryFrontier(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) Version(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call + type Op byte + const AcceptedFrontierOp + const AcceptedOp + const AcceptedStateSummaryOp + const AncestorsOp + const AppGossipOp + const AppRequestFailedOp + const AppRequestOp + const AppResponseOp + const ChitsOp + const ConnectedOp + const ConnectedSubnetOp + const CrossChainAppRequestFailedOp + const CrossChainAppRequestOp + const CrossChainAppResponseOp + const DisconnectedOp + const GetAcceptedFailedOp + const GetAcceptedFrontierFailedOp + const GetAcceptedFrontierOp + const GetAcceptedOp + const GetAcceptedStateSummaryFailedOp + const GetAcceptedStateSummaryOp + const GetAncestorsFailedOp + const GetAncestorsOp + const GetFailedOp + const GetOp + const GetStateSummaryFrontierFailedOp + const GetStateSummaryFrontierOp + const GossipRequestOp + const NotifyOp + const PeerListAckOp + const PeerListOp + const PingOp + const PongOp + const PullQueryOp + const PushQueryOp + const PutOp + const QueryFailedOp + const StateSummaryFrontierOp + const TimeoutOp + const VersionOp + func ToOp(m *p2p.Message) (Op, error) + func (op Op) String() string + type OutboundMessage interface + BypassThrottling func() bool + Bytes func() []byte + BytesSavedCompression func() int + Op func() Op + type OutboundMsgBuilder interface + Accepted func(chainID ids.ID, requestID uint32, containerIDs []ids.ID, ...) (OutboundMessage, error) + AcceptedFrontier func(chainID ids.ID, requestID uint32, containerIDs []ids.ID, ...) (OutboundMessage, error) + AcceptedStateSummary func(chainID ids.ID, requestID uint32, summaryIDs []ids.ID) (OutboundMessage, error) + Ancestors func(chainID ids.ID, requestID uint32, containers [][]byte, ...) (OutboundMessage, error) + AppGossip func(chainID ids.ID, msg []byte) (OutboundMessage, error) + AppRequest func(chainID ids.ID, requestID uint32, deadline time.Duration, msg []byte) (OutboundMessage, error) + AppResponse func(chainID ids.ID, requestID uint32, msg []byte) (OutboundMessage, error) + Chits func(chainID ids.ID, requestID uint32, preferredContainerIDs []ids.ID, ...) (OutboundMessage, error) + Get func(chainID ids.ID, requestID uint32, deadline time.Duration, containerID ids.ID, ...) (OutboundMessage, error) + GetAccepted func(chainID ids.ID, requestID uint32, deadline time.Duration, ...) (OutboundMessage, error) + GetAcceptedFrontier func(chainID ids.ID, requestID uint32, deadline time.Duration, ...) (OutboundMessage, error) + GetAcceptedStateSummary func(chainID ids.ID, requestID uint32, deadline time.Duration, heights []uint64) (OutboundMessage, error) + GetAncestors func(chainID ids.ID, requestID uint32, deadline time.Duration, containerID ids.ID, ...) (OutboundMessage, error) + GetStateSummaryFrontier func(chainID ids.ID, requestID uint32, deadline time.Duration) (OutboundMessage, error) + PeerList func(peers []ips.ClaimedIPPort, bypassThrottling bool) (OutboundMessage, error) + PeerListAck func(peerAcks []*p2p.PeerAck) (OutboundMessage, error) + Ping func() (OutboundMessage, error) + Pong func(primaryUptime uint32, subnetUptimes []*p2p.SubnetUptime) (OutboundMessage, error) + PullQuery func(chainID ids.ID, requestID uint32, deadline time.Duration, containerID ids.ID, ...) (OutboundMessage, error) + PushQuery func(chainID ids.ID, requestID uint32, deadline time.Duration, container []byte, ...) (OutboundMessage, error) + Put func(chainID ids.ID, requestID uint32, container []byte, engineType p2p.EngineType) (OutboundMessage, error) + StateSummaryFrontier func(chainID ids.ID, requestID uint32, summary []byte) (OutboundMessage, error) + Version func(networkID uint32, myTime uint64, ip ips.IPPort, myVersion string, ...) (OutboundMessage, error) + type QueryFailed struct + ChainID ids.ID + EngineType p2p.EngineType + RequestID uint32 + func (m *QueryFailed) GetChainId() []byte + func (m *QueryFailed) GetEngineType() p2p.EngineType + func (m *QueryFailed) GetRequestId() uint32 + type Timeout struct + type VMMessage struct + Notification uint32 v1.9.8-rc.9 Jun 28, 2023
Go to main page