Versions in this module Expand all Collapse all v1 v1.12.1 Jan 10, 2025 Changes in this version + var ErrTimeout = &AppError + var ErrUndefined = &AppError + type AcceptedFrontierHandler interface + AcceptedFrontier func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) error + GetAcceptedFrontierFailed func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + func NewNoOpAcceptedFrontierHandler(log logging.Logger) AcceptedFrontierHandler + type AcceptedHandler interface + Accepted func(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) error + GetAcceptedFailed func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + func NewNoOpAcceptedHandler(log logging.Logger) AcceptedHandler + type AcceptedSender interface + SendAccepted func(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) + SendGetAccepted func(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...) + type AcceptedStateSummaryHandler interface + AcceptedStateSummary func(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) error + GetAcceptedStateSummaryFailed func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + func NewNoOpAcceptedStateSummaryHandler(log logging.Logger) AcceptedStateSummaryHandler + type AcceptedStateSummarySender interface + SendAcceptedStateSummary func(ctx context.Context, nodeID ids.NodeID, requestID uint32, summaryIDs []ids.ID) + SendGetAcceptedStateSummary func(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...) + type AllGetsServer interface + type AncestorsHandler interface + Ancestors func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containers [][]byte) error + GetAncestorsFailed func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + func NewNoOpAncestorsHandler(log logging.Logger) AncestorsHandler + type AppError struct + Code int32 + Message string + func (a *AppError) Error() string + func (a *AppError) Is(target error) bool + type AppGossipHandler interface + AppGossip func(ctx context.Context, nodeID ids.NodeID, msg []byte) error + type AppHandler interface + func NewNoOpAppHandler(log logging.Logger) AppHandler + type AppRequestHandler interface + AppRequest func(ctx context.Context, nodeID ids.NodeID, requestID uint32, deadline time.Time, ...) error + type AppResponseHandler interface + AppRequestFailed func(ctx context.Context, nodeID ids.NodeID, requestID uint32, appErr *AppError) error + AppResponse func(ctx context.Context, nodeID ids.NodeID, requestID uint32, response []byte) error + type AppSender interface + type BootstrapTracker interface + Bootstrapped func(chainID ids.ID) + IsBootstrapped func() bool + OnBootstrapCompleted func() chan struct{} + type BootstrapTrackerTest struct + BootstrappedF func(ids.ID) + CantBootstrapped bool + CantIsBootstrapped bool + CantOnBootstrapCompleted bool + IsBootstrappedF func() bool + OnBootstrapCompletedF func() chan struct{} + T *testing.T + func (s *BootstrapTrackerTest) Bootstrapped(chainID ids.ID) + func (s *BootstrapTrackerTest) Default(cant bool) + func (s *BootstrapTrackerTest) IsBootstrapped() bool + func (s *BootstrapTrackerTest) OnBootstrapCompleted() chan struct{} + type BootstrapableEngine interface + Clear func(ctx context.Context) error + func TraceBootstrapableEngine(bootstrapableEngine BootstrapableEngine, tracer trace.Tracer) BootstrapableEngine + type BootstrapperTest struct + CantClear bool + ClearF func(ctx context.Context) error + func (b *BootstrapperTest) Clear(ctx context.Context) error + func (b *BootstrapperTest) Default(cant bool) + type ChitsHandler interface + Chits func(ctx context.Context, nodeID ids.NodeID, requestID uint32, preferredID ids.ID, ...) error + QueryFailed func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + func NewNoOpChitsHandler(log logging.Logger) ChitsHandler + type CrossChainAppHandler interface + type CrossChainAppRequestHandler interface + CrossChainAppRequest func(ctx context.Context, chainID ids.ID, requestID uint32, deadline time.Time, ...) error + type CrossChainAppResponseHandler interface + CrossChainAppRequestFailed func(ctx context.Context, chainID ids.ID, requestID uint32, appErr *AppError) error + CrossChainAppResponse func(ctx context.Context, chainID ids.ID, requestID uint32, response []byte) error + type CrossChainAppSender interface + SendCrossChainAppError func(ctx context.Context, chainID ids.ID, requestID uint32, errorCode int32, ...) error + SendCrossChainAppRequest func(ctx context.Context, chainID ids.ID, requestID uint32, appRequestBytes []byte) error + SendCrossChainAppResponse func(ctx context.Context, chainID ids.ID, requestID uint32, appResponseBytes []byte) error + type Engine interface + Context func() *snow.ConsensusContext + Start func(ctx context.Context, startReqID uint32) error + func TraceEngine(engine Engine, tracer trace.Tracer) Engine + type EngineTest struct + AcceptedF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) error + AcceptedFrontierF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) error + AcceptedStateSummaryF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) error + AncestorsF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containers [][]byte) error + AppGossipF func(ctx context.Context, nodeID ids.NodeID, msg []byte) error + AppRequestF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, deadline time.Time, ...) error + AppRequestFailedF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, appErr *AppError) error + AppResponseF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, msg []byte) error + CantAccepted bool + CantAcceptedFrontier bool + CantAcceptedStateSummary bool + CantAncestors bool + CantAppGossip bool + CantAppRequest bool + CantAppRequestFailed bool + CantAppResponse bool + CantChits bool + CantConnected bool + CantContext bool + CantCrossChainAppRequest bool + CantCrossChainAppRequestFailed bool + CantCrossChainAppResponse bool + CantDisconnected bool + CantGet bool + CantGetAccepted bool + CantGetAcceptedFailed bool + CantGetAcceptedFrontier bool + CantGetAcceptedFrontierFailed bool + CantGetAcceptedStateSummary bool + CantGetAcceptedStateSummaryFailed bool + CantGetAncestors bool + CantGetAncestorsFailed bool + CantGetFailed bool + CantGetStateSummaryFrontier bool + CantGetStateSummaryFrontierFailed bool + CantGetVM bool + CantGossip bool + CantHalt bool + CantHealth bool + CantIsBootstrapped bool + CantNotify bool + CantPullQuery bool + CantPushQuery bool + CantPut bool + CantQueryFailed bool + CantShutdown bool + CantStart bool + CantStateSummaryFrontier bool + CantTimeout bool + ChitsF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, preferredID ids.ID, ...) error + ConnectedF func(ctx context.Context, nodeID ids.NodeID, nodeVersion *version.Application) error + ContextF func() *snow.ConsensusContext + CrossChainAppRequestF func(ctx context.Context, chainID ids.ID, requestID uint32, deadline time.Time, ...) error + CrossChainAppRequestFailedF func(ctx context.Context, chainID ids.ID, requestID uint32, appErr *AppError) error + CrossChainAppResponseF func(ctx context.Context, chainID ids.ID, requestID uint32, msg []byte) error + DisconnectedF func(ctx context.Context, nodeID ids.NodeID) error + GetAcceptedF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) error + GetAcceptedFailedF func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + GetAcceptedFrontierF func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + GetAcceptedFrontierFailedF func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + GetAcceptedStateSummaryF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, keys set.Set[uint64]) error + GetAcceptedStateSummaryFailedF func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + GetAncestorsF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) error + GetAncestorsFailedF func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + GetF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) error + GetFailedF func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + GetStateSummaryFrontierF func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + GetStateSummaryFrontierFailedF func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + GetVMF func() VM + GossipF func(context.Context) error + HaltF func(context.Context) + HealthF func(context.Context) (interface{}, error) + IsBootstrappedF func() bool + NotifyF func(context.Context, Message) error + PullQueryF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID, ...) error + PushQueryF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, container []byte, ...) error + PutF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, container []byte) error + QueryFailedF func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + ShutdownF func(context.Context) error + StartF func(ctx context.Context, startReqID uint32) error + StateSummaryFrontierF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, summary []byte) error + T *testing.T + TimeoutF func(context.Context) error + func (e *EngineTest) Accepted(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) error + func (e *EngineTest) AcceptedFrontier(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) error + func (e *EngineTest) AcceptedStateSummary(ctx context.Context, validatorID ids.NodeID, requestID uint32, ...) error + func (e *EngineTest) Ancestors(ctx context.Context, nodeID ids.NodeID, requestID uint32, containers [][]byte) error + func (e *EngineTest) AppGossip(ctx context.Context, nodeID ids.NodeID, msg []byte) error + func (e *EngineTest) AppRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, deadline time.Time, ...) error + func (e *EngineTest) AppRequestFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32, appErr *AppError) error + func (e *EngineTest) AppResponse(ctx context.Context, nodeID ids.NodeID, requestID uint32, response []byte) error + func (e *EngineTest) Chits(ctx context.Context, nodeID ids.NodeID, requestID uint32, preferredID ids.ID, ...) error + func (e *EngineTest) Connected(ctx context.Context, nodeID ids.NodeID, nodeVersion *version.Application) error + func (e *EngineTest) Context() *snow.ConsensusContext + func (e *EngineTest) CrossChainAppRequest(ctx context.Context, chainID ids.ID, requestID uint32, deadline time.Time, ...) error + func (e *EngineTest) CrossChainAppRequestFailed(ctx context.Context, chainID ids.ID, requestID uint32, appErr *AppError) error + func (e *EngineTest) CrossChainAppResponse(ctx context.Context, chainID ids.ID, requestID uint32, response []byte) error + func (e *EngineTest) Default(cant bool) + func (e *EngineTest) Disconnected(ctx context.Context, nodeID ids.NodeID) error + func (e *EngineTest) Get(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) error + func (e *EngineTest) GetAccepted(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) error + func (e *EngineTest) GetAcceptedFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + func (e *EngineTest) GetAcceptedFrontier(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + func (e *EngineTest) GetAcceptedFrontierFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + func (e *EngineTest) GetAcceptedStateSummary(ctx context.Context, validatorID ids.NodeID, requestID uint32, ...) error + func (e *EngineTest) GetAcceptedStateSummaryFailed(ctx context.Context, validatorID ids.NodeID, requestID uint32) error + func (e *EngineTest) GetAncestors(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) error + func (e *EngineTest) GetAncestorsFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + func (e *EngineTest) GetFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + func (e *EngineTest) GetStateSummaryFrontier(ctx context.Context, validatorID ids.NodeID, requestID uint32) error + func (e *EngineTest) GetStateSummaryFrontierFailed(ctx context.Context, validatorID ids.NodeID, requestID uint32) error + func (e *EngineTest) Gossip(ctx context.Context) error + func (e *EngineTest) Halt(ctx context.Context) + func (e *EngineTest) HealthCheck(ctx context.Context) (interface{}, error) + func (e *EngineTest) Notify(ctx context.Context, msg Message) error + func (e *EngineTest) PullQuery(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID, ...) error + func (e *EngineTest) PushQuery(ctx context.Context, nodeID ids.NodeID, requestID uint32, container []byte, ...) error + func (e *EngineTest) Put(ctx context.Context, nodeID ids.NodeID, requestID uint32, container []byte) error + func (e *EngineTest) QueryFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + func (e *EngineTest) Shutdown(ctx context.Context) error + func (e *EngineTest) Start(ctx context.Context, startReqID uint32) error + func (e *EngineTest) StateSummaryFrontier(ctx context.Context, validatorID ids.NodeID, requestID uint32, summary []byte) error + func (e *EngineTest) Timeout(ctx context.Context) error + type FakeSender struct + SentAppError chan *AppError + SentAppGossip chan []byte + SentAppRequest chan []byte + SentAppResponse chan []byte + SentCrossChainAppError chan *AppError + SentCrossChainAppRequest chan []byte + SentCrossChainAppResponse chan []byte + func (f FakeSender) SendAppError(_ context.Context, _ ids.NodeID, _ uint32, errorCode int32, ...) error + func (f FakeSender) SendAppGossip(_ context.Context, _ SendConfig, bytes []byte) error + func (f FakeSender) SendAppRequest(_ context.Context, _ set.Set[ids.NodeID], _ uint32, bytes []byte) error + func (f FakeSender) SendAppResponse(_ context.Context, _ ids.NodeID, _ uint32, bytes []byte) error + func (f FakeSender) SendCrossChainAppError(_ context.Context, _ ids.ID, _ uint32, errorCode int32, errorMessage string) error + func (f FakeSender) SendCrossChainAppRequest(_ context.Context, _ ids.ID, _ uint32, bytes []byte) error + func (f FakeSender) SendCrossChainAppResponse(_ context.Context, _ ids.ID, _ uint32, bytes []byte) error + type FetchSender interface + SendAncestors func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containers [][]byte) + SendGet func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) + SendGetAncestors func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) + SendPut func(ctx context.Context, nodeID ids.NodeID, requestID uint32, container []byte) + type FrontierSender interface + SendAcceptedFrontier func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) + SendGetAcceptedFrontier func(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32) + type Fx struct + Fx interface{} + ID ids.ID + type GetAcceptedFrontierHandler interface + GetAcceptedFrontier func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + type GetAcceptedHandler interface + GetAccepted func(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) error + type GetAcceptedStateSummaryHandler interface + GetAcceptedStateSummary func(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) error + type GetAncestorsHandler interface + GetAncestors func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) error + type GetHandler interface + Get func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) error + type GetStateSummaryFrontierHandler interface + GetStateSummaryFrontier func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + type Haltable interface + Halt func(context.Context) + Halted func() bool + type Halter struct + func (h *Halter) Halt(context.Context) + func (h *Halter) Halted() bool + type Handler interface + type InternalHandler interface + Gossip func(context.Context) error + Halt func(context.Context) + Notify func(context.Context, Message) error + Shutdown func(context.Context) error + Timeout func(context.Context) error + func NewNoOpInternalHandler(log logging.Logger) InternalHandler + type Message uint32 + const PendingTxs + const StateSyncDone + func (msg Message) String() string + type MockSender struct + func NewMockSender(ctrl *gomock.Controller) *MockSender + func (m *MockSender) EXPECT() *MockSenderMockRecorder + func (m *MockSender) SendAccepted(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) + func (m *MockSender) SendAcceptedFrontier(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) + func (m *MockSender) SendAcceptedStateSummary(ctx context.Context, nodeID ids.NodeID, requestID uint32, summaryIDs []ids.ID) + func (m *MockSender) SendAncestors(ctx context.Context, nodeID ids.NodeID, requestID uint32, containers [][]byte) + func (m *MockSender) SendAppError(ctx context.Context, nodeID ids.NodeID, requestID uint32, errorCode int32, ...) error + func (m *MockSender) SendAppGossip(ctx context.Context, config SendConfig, appGossipBytes []byte) error + func (m *MockSender) SendAppRequest(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...) error + func (m *MockSender) SendAppResponse(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) error + func (m *MockSender) SendChits(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) + func (m *MockSender) SendCrossChainAppError(ctx context.Context, chainID ids.ID, requestID uint32, errorCode int32, ...) error + func (m *MockSender) SendCrossChainAppRequest(ctx context.Context, chainID ids.ID, requestID uint32, appRequestBytes []byte) error + func (m *MockSender) SendCrossChainAppResponse(ctx context.Context, chainID ids.ID, requestID uint32, appResponseBytes []byte) error + func (m *MockSender) SendGet(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) + func (m *MockSender) SendGetAccepted(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...) + func (m *MockSender) SendGetAcceptedFrontier(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32) + func (m *MockSender) SendGetAcceptedStateSummary(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...) + func (m *MockSender) SendGetAncestors(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) + func (m *MockSender) SendGetStateSummaryFrontier(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32) + func (m *MockSender) SendPullQuery(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...) + func (m *MockSender) SendPushQuery(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...) + func (m *MockSender) SendPut(ctx context.Context, nodeID ids.NodeID, requestID uint32, container []byte) + func (m *MockSender) SendStateSummaryFrontier(ctx context.Context, nodeID ids.NodeID, requestID uint32, summary []byte) + type MockSenderMockRecorder struct + func (mr *MockSenderMockRecorder) SendAccepted(ctx, nodeID, requestID, containerIDs any) *gomock.Call + func (mr *MockSenderMockRecorder) SendAcceptedFrontier(ctx, nodeID, requestID, containerID any) *gomock.Call + func (mr *MockSenderMockRecorder) SendAcceptedStateSummary(ctx, nodeID, requestID, summaryIDs any) *gomock.Call + func (mr *MockSenderMockRecorder) SendAncestors(ctx, nodeID, requestID, containers any) *gomock.Call + func (mr *MockSenderMockRecorder) SendAppError(ctx, nodeID, requestID, errorCode, errorMessage any) *gomock.Call + func (mr *MockSenderMockRecorder) SendAppGossip(ctx, config, appGossipBytes any) *gomock.Call + func (mr *MockSenderMockRecorder) SendAppRequest(ctx, nodeIDs, requestID, appRequestBytes any) *gomock.Call + func (mr *MockSenderMockRecorder) SendAppResponse(ctx, nodeID, requestID, appResponseBytes any) *gomock.Call + func (mr *MockSenderMockRecorder) SendChits(ctx, nodeID, requestID, preferredID, preferredIDAtHeight, acceptedID any) *gomock.Call + func (mr *MockSenderMockRecorder) SendCrossChainAppError(ctx, chainID, requestID, errorCode, errorMessage any) *gomock.Call + func (mr *MockSenderMockRecorder) SendCrossChainAppRequest(ctx, chainID, requestID, appRequestBytes any) *gomock.Call + func (mr *MockSenderMockRecorder) SendCrossChainAppResponse(ctx, chainID, requestID, appResponseBytes any) *gomock.Call + func (mr *MockSenderMockRecorder) SendGet(ctx, nodeID, requestID, containerID any) *gomock.Call + func (mr *MockSenderMockRecorder) SendGetAccepted(ctx, nodeIDs, requestID, containerIDs any) *gomock.Call + func (mr *MockSenderMockRecorder) SendGetAcceptedFrontier(ctx, nodeIDs, requestID any) *gomock.Call + func (mr *MockSenderMockRecorder) SendGetAcceptedStateSummary(ctx, nodeIDs, requestID, heights any) *gomock.Call + func (mr *MockSenderMockRecorder) SendGetAncestors(ctx, nodeID, requestID, containerID any) *gomock.Call + func (mr *MockSenderMockRecorder) SendGetStateSummaryFrontier(ctx, nodeIDs, requestID any) *gomock.Call + func (mr *MockSenderMockRecorder) SendPullQuery(ctx, nodeIDs, requestID, containerID, requestedHeight any) *gomock.Call + func (mr *MockSenderMockRecorder) SendPushQuery(ctx, nodeIDs, requestID, container, requestedHeight any) *gomock.Call + func (mr *MockSenderMockRecorder) SendPut(ctx, nodeID, requestID, container any) *gomock.Call + func (mr *MockSenderMockRecorder) SendStateSummaryFrontier(ctx, nodeID, requestID, summary any) *gomock.Call + type NetworkAppHandler interface + type NetworkAppSender interface + SendAppError func(ctx context.Context, nodeID ids.NodeID, requestID uint32, errorCode int32, ...) error + SendAppGossip func(ctx context.Context, config SendConfig, appGossipBytes []byte) error + SendAppRequest func(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...) error + SendAppResponse func(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) error + type PutHandler interface + GetFailed func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + Put func(ctx context.Context, nodeID ids.NodeID, requestID uint32, container []byte) error + func NewNoOpPutHandler(log logging.Logger) PutHandler + type QueryHandler interface + PullQuery func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID, ...) error + PushQuery func(ctx context.Context, nodeID ids.NodeID, requestID uint32, container []byte, ...) error + func NewNoOpQueryHandler(log logging.Logger) QueryHandler + type QuerySender interface + SendChits func(ctx context.Context, nodeID ids.NodeID, requestID uint32, preferredID ids.ID, ...) + SendPullQuery func(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...) + SendPushQuery func(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...) + type Request struct + NodeID ids.NodeID + RequestID uint32 + func (r Request) MarshalText() ([]byte, error) + type SendConfig struct + NodeIDs set.Set[ids.NodeID] + NonValidators int + Peers int + Validators int + type Sender interface + type SenderTest struct + CantSendAccepted bool + CantSendAcceptedFrontier bool + CantSendAcceptedStateSummary bool + CantSendAncestors bool + CantSendAppError bool + CantSendAppGossip bool + CantSendAppRequest bool + CantSendAppResponse bool + CantSendChits bool + CantSendCrossChainAppError bool + CantSendCrossChainAppRequest bool + CantSendCrossChainAppResponse bool + CantSendGet bool + CantSendGetAccepted bool + CantSendGetAcceptedFrontier bool + CantSendGetAcceptedStateSummary bool + CantSendGetAncestors bool + CantSendGetStateSummaryFrontier bool + CantSendPullQuery bool + CantSendPushQuery bool + CantSendPut bool + CantSendStateSummaryFrontier bool + SendAcceptedF func(context.Context, ids.NodeID, uint32, []ids.ID) + SendAcceptedFrontierF func(context.Context, ids.NodeID, uint32, ids.ID) + SendAcceptedStateSummaryF func(context.Context, ids.NodeID, uint32, []ids.ID) + SendAncestorsF func(context.Context, ids.NodeID, uint32, [][]byte) + SendAppErrorF func(context.Context, ids.NodeID, uint32, int32, string) error + SendAppGossipF func(context.Context, SendConfig, []byte) error + SendAppRequestF func(context.Context, set.Set[ids.NodeID], uint32, []byte) error + SendAppResponseF func(context.Context, ids.NodeID, uint32, []byte) error + SendChitsF func(context.Context, ids.NodeID, uint32, ids.ID, ids.ID, ids.ID) + SendCrossChainAppErrorF func(context.Context, ids.ID, uint32, int32, string) + SendCrossChainAppRequestF func(context.Context, ids.ID, uint32, []byte) + SendCrossChainAppResponseF func(context.Context, ids.ID, uint32, []byte) + SendGetAcceptedF func(context.Context, set.Set[ids.NodeID], uint32, []ids.ID) + SendGetAcceptedFrontierF func(context.Context, set.Set[ids.NodeID], uint32) + SendGetAcceptedStateSummaryF func(context.Context, set.Set[ids.NodeID], uint32, []uint64) + SendGetAncestorsF func(context.Context, ids.NodeID, uint32, ids.ID) + SendGetF func(context.Context, ids.NodeID, uint32, ids.ID) + SendGetStateSummaryFrontierF func(context.Context, set.Set[ids.NodeID], uint32) + SendPullQueryF func(context.Context, set.Set[ids.NodeID], uint32, ids.ID, uint64) + SendPushQueryF func(context.Context, set.Set[ids.NodeID], uint32, []byte, uint64) + SendPutF func(context.Context, ids.NodeID, uint32, []byte) + SendStateSummaryFrontierF func(context.Context, ids.NodeID, uint32, []byte) + T require.TestingT + func (s *SenderTest) Default(cant bool) + func (s *SenderTest) SendAccepted(ctx context.Context, validatorID ids.NodeID, requestID uint32, ...) + func (s *SenderTest) SendAcceptedFrontier(ctx context.Context, validatorID ids.NodeID, requestID uint32, ...) + func (s *SenderTest) SendAcceptedStateSummary(ctx context.Context, validatorID ids.NodeID, requestID uint32, ...) + func (s *SenderTest) SendAncestors(ctx context.Context, vdr ids.NodeID, requestID uint32, containers [][]byte) + func (s *SenderTest) SendAppError(ctx context.Context, nodeID ids.NodeID, requestID uint32, code int32, ...) error + func (s *SenderTest) SendAppGossip(ctx context.Context, config SendConfig, appGossipBytes []byte) error + func (s *SenderTest) SendAppRequest(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...) error + func (s *SenderTest) SendAppResponse(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) error + func (s *SenderTest) SendChits(ctx context.Context, vdr ids.NodeID, requestID uint32, preferredID ids.ID, ...) + func (s *SenderTest) SendCrossChainAppError(ctx context.Context, chainID ids.ID, requestID uint32, errorCode int32, ...) error + func (s *SenderTest) SendCrossChainAppRequest(ctx context.Context, chainID ids.ID, requestID uint32, appRequestBytes []byte) error + func (s *SenderTest) SendCrossChainAppResponse(ctx context.Context, chainID ids.ID, requestID uint32, appResponseBytes []byte) error + func (s *SenderTest) SendGet(ctx context.Context, vdr ids.NodeID, requestID uint32, containerID ids.ID) + func (s *SenderTest) SendGetAccepted(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...) + func (s *SenderTest) SendGetAcceptedFrontier(ctx context.Context, validatorIDs set.Set[ids.NodeID], requestID uint32) + func (s *SenderTest) SendGetAcceptedStateSummary(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...) + func (s *SenderTest) SendGetAncestors(ctx context.Context, validatorID ids.NodeID, requestID uint32, ...) + func (s *SenderTest) SendGetStateSummaryFrontier(ctx context.Context, validatorIDs set.Set[ids.NodeID], requestID uint32) + func (s *SenderTest) SendPullQuery(ctx context.Context, vdrs set.Set[ids.NodeID], requestID uint32, ...) + func (s *SenderTest) SendPushQuery(ctx context.Context, vdrs set.Set[ids.NodeID], requestID uint32, ...) + func (s *SenderTest) SendPut(ctx context.Context, vdr ids.NodeID, requestID uint32, container []byte) + func (s *SenderTest) SendStateSummaryFrontier(ctx context.Context, validatorID ids.NodeID, requestID uint32, summary []byte) + type StateSummaryFrontierHandler interface + GetStateSummaryFrontierFailed func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error + StateSummaryFrontier func(ctx context.Context, nodeID ids.NodeID, requestID uint32, summary []byte) error + func NewNoOpStateSummaryFrontierHandler(log logging.Logger) StateSummaryFrontierHandler + type StateSummarySender interface + SendGetStateSummaryFrontier func(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32) + SendStateSummaryFrontier func(ctx context.Context, nodeID ids.NodeID, requestID uint32, summary []byte) + type StateSyncer interface + IsEnabled func(context.Context) (bool, error) + func TraceStateSyncer(stateSyncer StateSyncer, tracer trace.Tracer) StateSyncer + type TestVM struct + AppGossipF func(ctx context.Context, nodeID ids.NodeID, msg []byte) error + AppRequestF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, deadline time.Time, ...) error + AppRequestFailedF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, appErr *AppError) error + AppResponseF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, msg []byte) error + CantAppGossip bool + CantAppRequest bool + CantAppRequestFailed bool + CantAppResponse bool + CantConnected bool + CantCreateHandlers bool + CantCrossChainAppRequest bool + CantCrossChainAppRequestFailed bool + CantCrossChainAppResponse bool + CantDisconnected bool + CantHealthCheck bool + CantInitialize bool + CantSetState bool + CantShutdown bool + CantVersion bool + ConnectedF func(ctx context.Context, nodeID ids.NodeID, nodeVersion *version.Application) error + CreateHandlersF func(context.Context) (map[string]http.Handler, error) + CrossChainAppRequestF func(ctx context.Context, chainID ids.ID, requestID uint32, deadline time.Time, ...) error + CrossChainAppRequestFailedF func(ctx context.Context, chainID ids.ID, requestID uint32, appErr *AppError) error + CrossChainAppResponseF func(ctx context.Context, chainID ids.ID, requestID uint32, msg []byte) error + DisconnectedF func(ctx context.Context, nodeID ids.NodeID) error + HealthCheckF func(context.Context) (interface{}, error) + InitializeF func(ctx context.Context, chainCtx *snow.Context, db database.Database, ...) error + SetStateF func(ctx context.Context, state snow.State) error + ShutdownF func(context.Context) error + T *testing.T + VersionF func(context.Context) (string, error) + func (vm *TestVM) AppGossip(ctx context.Context, nodeID ids.NodeID, msg []byte) error + func (vm *TestVM) AppRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, deadline time.Time, ...) error + func (vm *TestVM) AppRequestFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32, appErr *AppError) error + func (vm *TestVM) AppResponse(ctx context.Context, nodeID ids.NodeID, requestID uint32, response []byte) error + func (vm *TestVM) Connected(ctx context.Context, id ids.NodeID, nodeVersion *version.Application) error + func (vm *TestVM) CreateHandlers(ctx context.Context) (map[string]http.Handler, error) + func (vm *TestVM) CrossChainAppRequest(ctx context.Context, chainID ids.ID, requestID uint32, deadline time.Time, ...) error + func (vm *TestVM) CrossChainAppRequestFailed(ctx context.Context, chainID ids.ID, requestID uint32, appErr *AppError) error + func (vm *TestVM) CrossChainAppResponse(ctx context.Context, chainID ids.ID, requestID uint32, response []byte) error + func (vm *TestVM) Default(cant bool) + func (vm *TestVM) Disconnected(ctx context.Context, id ids.NodeID) error + func (vm *TestVM) HealthCheck(ctx context.Context) (interface{}, error) + func (vm *TestVM) Initialize(ctx context.Context, chainCtx *snow.Context, db database.Database, ...) error + func (vm *TestVM) SetState(ctx context.Context, state snow.State) error + func (vm *TestVM) Shutdown(ctx context.Context) error + func (vm *TestVM) Version(ctx context.Context) (string, error) + type Timer interface + RegisterTimeout func(time.Duration) + type TimerTest struct + CantRegisterTimout bool + RegisterTimeoutF func(time.Duration) + T *testing.T + func (t *TimerTest) Default(cant bool) + func (t *TimerTest) RegisterTimeout(delay time.Duration) + type VM interface + CreateHandlers func(context.Context) (map[string]http.Handler, error) + Initialize func(ctx context.Context, chainCtx *snow.Context, db database.Database, ...) error + SetState func(ctx context.Context, state snow.State) error + Shutdown func(context.Context) error + Version func(context.Context) (string, error) v1.11.13-rc.2 Dec 3, 2024
Go to main page