Versions in this module Expand all Collapse all v1 v1.11.10 Jul 13, 2024 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.Of(GetAcceptedFrontierOp, GetAcceptedOp, GetAncestorsOp, GetOp, PushQueryOp, ...) + 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) (fmt.Stringer, error) + type Connected struct + NodeVersion *version.Application + func (m *Connected) String() string + type ConnectedSubnet struct + SubnetID ids.ID + func (m *ConnectedSubnet) String() string + type Creator interface + func NewCreator(log logging.Logger, metrics prometheus.Registerer, ...) (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 + func (m *CrossChainAppRequest) String() string + type CrossChainAppRequestFailed struct + DestinationChainID ids.ID + ErrorCode int32 + ErrorMessage string + RequestID uint32 + SourceChainID ids.ID + func (m *CrossChainAppRequestFailed) GetChainId() []byte + func (m *CrossChainAppRequestFailed) GetRequestId() uint32 + func (m *CrossChainAppRequestFailed) GetSourceChainID() ids.ID + func (m *CrossChainAppRequestFailed) String() string + 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 + func (m *CrossChainAppResponse) String() string + type Disconnected struct + func (Disconnected) String() string + type GetAcceptedFailed struct + ChainID ids.ID + RequestID uint32 + func (m *GetAcceptedFailed) GetChainId() []byte + func (m *GetAcceptedFailed) GetRequestId() uint32 + func (m *GetAcceptedFailed) String() string + type GetAcceptedFrontierFailed struct + ChainID ids.ID + RequestID uint32 + func (m *GetAcceptedFrontierFailed) GetChainId() []byte + func (m *GetAcceptedFrontierFailed) GetRequestId() uint32 + func (m *GetAcceptedFrontierFailed) String() string + type GetAcceptedStateSummaryFailed struct + ChainID ids.ID + RequestID uint32 + func (m *GetAcceptedStateSummaryFailed) GetChainId() []byte + func (m *GetAcceptedStateSummaryFailed) GetRequestId() uint32 + func (m *GetAcceptedStateSummaryFailed) String() string + 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 + func (m *GetAncestorsFailed) String() string + type GetFailed struct + ChainID ids.ID + RequestID uint32 + func (m *GetFailed) GetChainId() []byte + func (m *GetFailed) GetRequestId() uint32 + func (m *GetFailed) String() string + type GetStateSummaryFrontierFailed struct + ChainID ids.ID + RequestID uint32 + func (m *GetStateSummaryFrontierFailed) GetChainId() []byte + func (m *GetStateSummaryFrontierFailed) GetRequestId() uint32 + func (m *GetStateSummaryFrontierFailed) String() string + type GossipRequest struct + func (GossipRequest) String() string + type InboundMessage interface + BytesSavedCompression func() int + Expiration func() time.Time + Message func() fmt.Stringer + 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, containerID ids.ID, nodeID ids.NodeID) InboundMessage + func InboundAcceptedStateSummary(chainID ids.ID, requestID uint32, summaryIDs []ids.ID, nodeID ids.NodeID) InboundMessage + func InboundAppError(nodeID ids.NodeID, chainID ids.ID, requestID uint32, errorCode int32, ...) 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, preferredID 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 InternalConnected(nodeID ids.NodeID, nodeVersion *version.Application) InboundMessage + func InternalConnectedSubnet(nodeID ids.NodeID, subnetID ids.ID) InboundMessage + func InternalCrossChainAppError(nodeID ids.NodeID, sourceChainID ids.ID, destinationChainID ids.ID, ...) InboundMessage + func InternalCrossChainAppRequest(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) InboundMessage + func InternalGetAcceptedFrontierFailed(nodeID ids.NodeID, chainID ids.ID, requestID uint32) 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) 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) 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) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) AcceptedFrontier(arg0 ids.ID, arg1 uint32, arg2 ids.ID) (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) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) AppError(arg0 ids.ID, arg1 uint32, arg2 int32, arg3 string) (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, arg4 ids.ID) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) EXPECT() *MockOutboundMsgBuilderMockRecorder + func (m *MockOutboundMsgBuilder) Get(arg0 ids.ID, arg1 uint32, arg2 time.Duration, arg3 ids.ID) (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) (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) GetPeerList(arg0, arg1 []byte) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) GetStateSummaryFrontier(arg0 ids.ID, arg1 uint32, arg2 time.Duration) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) Handshake(arg0 uint32, arg1 uint64, arg2 netip.AddrPort, arg3 string, ...) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) PeerList(arg0 []*ips.ClaimedIPPort, arg1 bool) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) Ping(arg0 uint32, arg1 []*p2p.SubnetUptime) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) Pong() (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) PullQuery(arg0 ids.ID, arg1 uint32, arg2 time.Duration, arg3 ids.ID, arg4 uint64) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) PushQuery(arg0 ids.ID, arg1 uint32, arg2 time.Duration, arg3 []byte, arg4 uint64) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) Put(arg0 ids.ID, arg1 uint32, arg2 []byte) (OutboundMessage, error) + func (m *MockOutboundMsgBuilder) StateSummaryFrontier(arg0 ids.ID, arg1 uint32, arg2 []byte) (OutboundMessage, error) + type MockOutboundMsgBuilderMockRecorder struct + func (mr *MockOutboundMsgBuilderMockRecorder) Accepted(arg0, arg1, arg2 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) AcceptedFrontier(arg0, arg1, arg2 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) AcceptedStateSummary(arg0, arg1, arg2 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) Ancestors(arg0, arg1, arg2 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) AppError(arg0, arg1, arg2, arg3 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) AppGossip(arg0, arg1 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) AppRequest(arg0, arg1, arg2, arg3 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) AppResponse(arg0, arg1, arg2 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) Chits(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) Get(arg0, arg1, arg2, arg3 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) GetAccepted(arg0, arg1, arg2, arg3 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) GetAcceptedFrontier(arg0, arg1, arg2 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) GetAcceptedStateSummary(arg0, arg1, arg2, arg3 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) GetAncestors(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) GetPeerList(arg0, arg1 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) GetStateSummaryFrontier(arg0, arg1, arg2 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) Handshake(...) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) PeerList(arg0, arg1 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) Ping(arg0, arg1 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) Pong() *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) PullQuery(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) PushQuery(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) Put(arg0, arg1, arg2 any) *gomock.Call + func (mr *MockOutboundMsgBuilderMockRecorder) StateSummaryFrontier(arg0, arg1, arg2 any) *gomock.Call + type Op byte + const AcceptedFrontierOp + const AcceptedOp + const AcceptedStateSummaryOp + const AncestorsOp + const AppErrorOp + const AppGossipOp + const AppRequestOp + const AppResponseOp + const ChitsOp + const ConnectedOp + const ConnectedSubnetOp + const CrossChainAppErrorOp + 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 GetPeerListOp + const GetStateSummaryFrontierFailedOp + const GetStateSummaryFrontierOp + const GossipRequestOp + const HandshakeOp + const NotifyOp + const PeerListOp + const PingOp + const PongOp + const PullQueryOp + const PushQueryOp + const PutOp + const QueryFailedOp + const StateSummaryFrontierOp + const TimeoutOp + 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, containerID 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) + AppError func(chainID ids.ID, requestID uint32, errorCode int32, errorMessage string) (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, preferredID 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) + GetPeerList func(knownPeersFilter []byte, knownPeersSalt []byte) (OutboundMessage, error) + GetStateSummaryFrontier func(chainID ids.ID, requestID uint32, deadline time.Duration) (OutboundMessage, error) + Handshake func(networkID uint32, myTime uint64, ip netip.AddrPort, client string, ...) (OutboundMessage, error) + PeerList func(peers []*ips.ClaimedIPPort, bypassThrottling bool) (OutboundMessage, error) + Ping func(primaryUptime uint32, subnetUptimes []*p2p.SubnetUptime) (OutboundMessage, error) + Pong func() (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) (OutboundMessage, error) + StateSummaryFrontier func(chainID ids.ID, requestID uint32, summary []byte) (OutboundMessage, error) + type QueryFailed struct + ChainID ids.ID + RequestID uint32 + func (m *QueryFailed) GetChainId() []byte + func (m *QueryFailed) GetRequestId() uint32 + func (m *QueryFailed) String() string + type Timeout struct + func (Timeout) String() string + type VMMessage struct + Notification uint32 + func (m *VMMessage) String() string
Go to main page