Versions in this module Expand all Collapse all v0 v0.0.15 Sep 23, 2022 v0.0.14 Sep 23, 2022 Changes in this version + const MaxOutstandingBroadcastRequests + const MaxOutstandingGetAncestorsRequests + const NoLock + const ReadLock + const StatusUpdateFrequency + const WriteLock + func SendMixedQuery(sender Sender, vdrs []ids.NodeID, numPushTo int, reqID uint32, ...) + type AcceptedFrontierHandler interface + AcceptedFrontier func(validatorID ids.NodeID, requestID uint32, containerIDs []ids.ID) error + GetAcceptedFrontierFailed func(validatorID ids.NodeID, requestID uint32) error + func NewNoOpAcceptedFrontierHandler(log logging.Logger) AcceptedFrontierHandler + type AcceptedHandler interface + Accepted func(validatorID ids.NodeID, requestID uint32, containerIDs []ids.ID) error + GetAcceptedFailed func(validatorID ids.NodeID, requestID uint32) error + func NewNoOpAcceptedHandler(log logging.Logger) AcceptedHandler + type AcceptedSender interface + SendAccepted func(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID) + SendGetAccepted func(nodeIDs ids.NodeIDSet, requestID uint32, containerIDs []ids.ID) + type AcceptedStateSummaryHandler interface + AcceptedStateSummary func(validatorID ids.NodeID, requestID uint32, summaryIDs []ids.ID) error + GetAcceptedStateSummaryFailed func(validatorID ids.NodeID, requestID uint32) error + func NewNoOpAcceptedStateSummaryHandler(log logging.Logger) AcceptedStateSummaryHandler + type AcceptedStateSummarySender interface + SendAcceptedStateSummary func(nodeID ids.NodeID, requestID uint32, summaryIDs []ids.ID) + SendGetAcceptedStateSummary func(nodeIDs ids.NodeIDSet, requestID uint32, heights []uint64) + type AllGetsServer interface + type AncestorsHandler interface + Ancestors func(validatorID ids.NodeID, requestID uint32, containers [][]byte) error + GetAncestorsFailed func(validatorID ids.NodeID, requestID uint32) error + func NewNoOpAncestorsHandler(log logging.Logger) AncestorsHandler + type AppHandler interface + AppGossip func(nodeID ids.NodeID, msg []byte) error + AppRequest func(nodeID ids.NodeID, requestID uint32, deadline time.Time, request []byte) error + AppRequestFailed func(nodeID ids.NodeID, requestID uint32) error + AppResponse func(nodeID ids.NodeID, requestID uint32, response []byte) error + func NewNoOpAppHandler(log logging.Logger) AppHandler + type AppSender interface + SendAppGossip func(appGossipBytes []byte) error + SendAppGossipSpecific func(nodeIDs ids.NodeIDSet, appGossipBytes []byte) error + SendAppRequest func(nodeIDs ids.NodeIDSet, requestID uint32, appRequestBytes []byte) error + SendAppResponse func(nodeID ids.NodeID, requestID uint32, appResponseBytes []byte) error + type Bootstrapable interface + Clear func() error + ForceAccepted func(acceptedContainerIDs []ids.ID) error + type BootstrapableEngine interface + type BootstrapableTest struct + CantClear bool + CantForceAccepted bool + ClearF func() error + ForceAcceptedF func(acceptedContainerIDs []ids.ID) error + T *testing.T + func (b *BootstrapableTest) Clear() error + func (b *BootstrapableTest) Default(cant bool) + func (b *BootstrapableTest) ForceAccepted(containerIDs []ids.ID) error + type Bootstrapper interface + Restart func(reset bool) error + Startup func() error + func NewCommonBootstrapper(config Config) Bootstrapper + type BootstrapperTest struct + func (b *BootstrapperTest) Default(cant bool) + type ChitsHandler interface + Chits func(validatorID ids.NodeID, requestID uint32, containerIDs []ids.ID) error + ChitsV2 func(validatorID ids.NodeID, requestID uint32, containerIDs []ids.ID, ...) error + QueryFailed func(validatorID ids.NodeID, requestID uint32) error + func NewNoOpChitsHandler(log logging.Logger) ChitsHandler + type Config struct + Alpha uint64 + AncestorsMaxContainersReceived int + AncestorsMaxContainersSent int + Beacons validators.Set + Bootstrapable Bootstrapable + Ctx *snow.ConsensusContext + MaxTimeGetAncestors time.Duration + RetryBootstrap bool + RetryBootstrapWarnFrequency int + SampleK int + Sender Sender + SharedCfg *SharedConfig + StartupTracker tracker.Startup + Subnet Subnet + Timer Timer + Validators validators.Set + func DefaultConfigTest() Config + func (c *Config) Context() *snow.ConsensusContext + func (c *Config) IsBootstrapped() bool + type Engine interface + Context func() *snow.ConsensusContext + GetVM func() VM + Start func(startReqID uint32) error + type EngineTest struct + AcceptedF func(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID) error + AcceptedFrontierF func(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID) error + AcceptedStateSummaryF func(nodeID ids.NodeID, requestID uint32, summaryIDs []ids.ID) error + AncestorsF func(nodeID ids.NodeID, requestID uint32, containers [][]byte) error + AppGossipF func(nodeID ids.NodeID, msg []byte) error + AppRequestF func(nodeID ids.NodeID, requestID uint32, msg []byte) error + AppRequestFailedF func(nodeID ids.NodeID, requestID uint32) error + AppResponseF func(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 + CantChitsV2 bool + CantConnected bool + CantContext 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(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID) error + ChitsV2F func(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID, containerID ids.ID) error + ConnectedF func(nodeID ids.NodeID, nodeVersion *version.Application) error + ContextF func() *snow.ConsensusContext + DisconnectedF func(nodeID ids.NodeID) error + GetAcceptedF func(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID) error + GetAcceptedFailedF func(nodeID ids.NodeID, requestID uint32) error + GetAcceptedFrontierF func(nodeID ids.NodeID, requestID uint32) error + GetAcceptedFrontierFailedF func(nodeID ids.NodeID, requestID uint32) error + GetAcceptedStateSummaryF func(nodeID ids.NodeID, requestID uint32, keys []uint64) error + GetAcceptedStateSummaryFailedF func(nodeID ids.NodeID, requestID uint32) error + GetAncestorsF func(nodeID ids.NodeID, requestID uint32, containerID ids.ID) error + GetAncestorsFailedF func(nodeID ids.NodeID, requestID uint32) error + GetF func(nodeID ids.NodeID, requestID uint32, containerID ids.ID) error + GetFailedF func(nodeID ids.NodeID, requestID uint32) error + GetStateSummaryFrontierF func(nodeID ids.NodeID, requestID uint32) error + GetStateSummaryFrontierFailedF func(nodeID ids.NodeID, requestID uint32) error + GetVMF func() VM + GossipF func() error + HaltF func() + HealthF func() (interface{}, error) + IsBootstrappedF func() bool + NotifyF func(Message) error + PullQueryF func(nodeID ids.NodeID, requestID uint32, containerID ids.ID) error + PushQueryF func(nodeID ids.NodeID, requestID uint32, container []byte) error + PutF func(nodeID ids.NodeID, requestID uint32, container []byte) error + QueryFailedF func(nodeID ids.NodeID, requestID uint32) error + ShutdownF func() error + StartF func(startReqID uint32) error + StateSummaryFrontierF func(nodeID ids.NodeID, requestID uint32, summary []byte) error + T *testing.T + TimeoutF func() error + func (e *EngineTest) Accepted(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID) error + func (e *EngineTest) AcceptedFrontier(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID) error + func (e *EngineTest) AcceptedStateSummary(validatorID ids.NodeID, requestID uint32, summaryIDs []ids.ID) error + func (e *EngineTest) Ancestors(nodeID ids.NodeID, requestID uint32, containers [][]byte) error + func (e *EngineTest) AppGossip(nodeID ids.NodeID, msg []byte) error + func (e *EngineTest) AppRequest(nodeID ids.NodeID, requestID uint32, deadline time.Time, request []byte) error + func (e *EngineTest) AppRequestFailed(nodeID ids.NodeID, requestID uint32) error + func (e *EngineTest) AppResponse(nodeID ids.NodeID, requestID uint32, response []byte) error + func (e *EngineTest) Chits(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID) error + func (e *EngineTest) ChitsV2(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID, containerID ids.ID) error + func (e *EngineTest) Connected(nodeID ids.NodeID, nodeVersion *version.Application) error + func (e *EngineTest) Context() *snow.ConsensusContext + func (e *EngineTest) Default(cant bool) + func (e *EngineTest) Disconnected(nodeID ids.NodeID) error + func (e *EngineTest) Get(nodeID ids.NodeID, requestID uint32, containerID ids.ID) error + func (e *EngineTest) GetAccepted(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID) error + func (e *EngineTest) GetAcceptedFailed(nodeID ids.NodeID, requestID uint32) error + func (e *EngineTest) GetAcceptedFrontier(nodeID ids.NodeID, requestID uint32) error + func (e *EngineTest) GetAcceptedFrontierFailed(nodeID ids.NodeID, requestID uint32) error + func (e *EngineTest) GetAcceptedStateSummary(validatorID ids.NodeID, requestID uint32, keys []uint64) error + func (e *EngineTest) GetAcceptedStateSummaryFailed(validatorID ids.NodeID, requestID uint32) error + func (e *EngineTest) GetAncestors(nodeID ids.NodeID, requestID uint32, containerID ids.ID) error + func (e *EngineTest) GetAncestorsFailed(nodeID ids.NodeID, requestID uint32) error + func (e *EngineTest) GetFailed(nodeID ids.NodeID, requestID uint32) error + func (e *EngineTest) GetStateSummaryFrontier(validatorID ids.NodeID, requestID uint32) error + func (e *EngineTest) GetStateSummaryFrontierFailed(validatorID ids.NodeID, requestID uint32) error + func (e *EngineTest) GetVM() VM + func (e *EngineTest) Gossip() error + func (e *EngineTest) Halt() + func (e *EngineTest) HealthCheck() (interface{}, error) + func (e *EngineTest) Notify(msg Message) error + func (e *EngineTest) PullQuery(nodeID ids.NodeID, requestID uint32, containerID ids.ID) error + func (e *EngineTest) PushQuery(nodeID ids.NodeID, requestID uint32, container []byte) error + func (e *EngineTest) Put(nodeID ids.NodeID, requestID uint32, container []byte) error + func (e *EngineTest) QueryFailed(nodeID ids.NodeID, requestID uint32) error + func (e *EngineTest) Shutdown() error + func (e *EngineTest) Start(startReqID uint32) error + func (e *EngineTest) StateSummaryFrontier(validatorID ids.NodeID, requestID uint32, summary []byte) error + func (e *EngineTest) Timeout() error + type FetchSender interface + SendAncestors func(nodeID ids.NodeID, requestID uint32, containers [][]byte) + SendGet func(nodeID ids.NodeID, requestID uint32, containerID ids.ID) + SendGetAncestors func(nodeID ids.NodeID, requestID uint32, containerID ids.ID) + SendPut func(nodeID ids.NodeID, requestID uint32, containerID ids.ID, container []byte) + type Fetcher struct + OnFinished func(lastReqID uint32) error + OutstandingRequests Requests + type FrontierSender interface + SendAcceptedFrontier func(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID) + SendGetAcceptedFrontier func(nodeIDs ids.NodeIDSet, requestID uint32) + type Fx struct + Fx interface{} + ID ids.ID + type GetAcceptedFrontierHandler interface + GetAcceptedFrontier func(validatorID ids.NodeID, requestID uint32) error + type GetAcceptedHandler interface + GetAccepted func(validatorID ids.NodeID, requestID uint32, containerIDs []ids.ID) error + type GetAcceptedStateSummaryHandler interface + GetAcceptedStateSummary func(validatorID ids.NodeID, requestID uint32, keys []uint64) error + type GetAncestorsHandler interface + GetAncestors func(validatorID ids.NodeID, requestID uint32, containerID ids.ID) error + type GetHandler interface + Get func(validatorID ids.NodeID, requestID uint32, containerID ids.ID) error + type GetStateSummaryFrontierHandler interface + GetStateSummaryFrontier func(validatorID ids.NodeID, requestID uint32) error + type Gossiper interface + SendGossip func(containerID ids.ID, container []byte) + type HTTPHandler struct + Handler http.Handler + LockOptions LockOption + type Haltable interface + Halt func() + Halted func() bool + type Halter struct + func (h *Halter) Halt() + func (h *Halter) Halted() bool + type Handler interface + type InternalHandler interface + Gossip func() error + Halt func() + Notify func(Message) error + Shutdown func() error + Timeout func() error + type LockOption uint32 + type Message uint32 + const PendingTxs + const StateSyncDone + const StopVertex + func (msg Message) String() string + type MockAcceptedSender struct + func NewMockAcceptedSender(ctrl *gomock.Controller) *MockAcceptedSender + func (m *MockAcceptedSender) EXPECT() *MockAcceptedSenderMockRecorder + func (m *MockAcceptedSender) SendAccepted(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID) + func (m *MockAcceptedSender) SendGetAccepted(nodeIDs ids.NodeIDSet, requestID uint32, containerIDs []ids.ID) + type MockAcceptedSenderMockRecorder struct + func (mr *MockAcceptedSenderMockRecorder) SendAccepted(nodeID, requestID, containerIDs interface{}) *gomock.Call + func (mr *MockAcceptedSenderMockRecorder) SendGetAccepted(nodeIDs, requestID, containerIDs interface{}) *gomock.Call + type MockAcceptedStateSummarySender struct + func NewMockAcceptedStateSummarySender(ctrl *gomock.Controller) *MockAcceptedStateSummarySender + func (m *MockAcceptedStateSummarySender) EXPECT() *MockAcceptedStateSummarySenderMockRecorder + func (m *MockAcceptedStateSummarySender) SendAcceptedStateSummary(nodeID ids.NodeID, requestID uint32, summaryIDs []ids.ID) + func (m *MockAcceptedStateSummarySender) SendGetAcceptedStateSummary(nodeIDs ids.NodeIDSet, requestID uint32, heights []uint64) + type MockAcceptedStateSummarySenderMockRecorder struct + func (mr *MockAcceptedStateSummarySenderMockRecorder) SendAcceptedStateSummary(nodeID, requestID, summaryIDs interface{}) *gomock.Call + func (mr *MockAcceptedStateSummarySenderMockRecorder) SendGetAcceptedStateSummary(nodeIDs, requestID, heights interface{}) *gomock.Call + type MockAppSender struct + func NewMockAppSender(ctrl *gomock.Controller) *MockAppSender + func (m *MockAppSender) EXPECT() *MockAppSenderMockRecorder + func (m *MockAppSender) SendAppGossip(appGossipBytes []byte) error + func (m *MockAppSender) SendAppGossipSpecific(nodeIDs ids.NodeIDSet, appGossipBytes []byte) error + func (m *MockAppSender) SendAppRequest(nodeIDs ids.NodeIDSet, requestID uint32, appRequestBytes []byte) error + func (m *MockAppSender) SendAppResponse(nodeID ids.NodeID, requestID uint32, appResponseBytes []byte) error + type MockAppSenderMockRecorder struct + func (mr *MockAppSenderMockRecorder) SendAppGossip(appGossipBytes interface{}) *gomock.Call + func (mr *MockAppSenderMockRecorder) SendAppGossipSpecific(nodeIDs, appGossipBytes interface{}) *gomock.Call + func (mr *MockAppSenderMockRecorder) SendAppRequest(nodeIDs, requestID, appRequestBytes interface{}) *gomock.Call + func (mr *MockAppSenderMockRecorder) SendAppResponse(nodeID, requestID, appResponseBytes interface{}) *gomock.Call + type MockFetchSender struct + func NewMockFetchSender(ctrl *gomock.Controller) *MockFetchSender + func (m *MockFetchSender) EXPECT() *MockFetchSenderMockRecorder + func (m *MockFetchSender) SendAncestors(nodeID ids.NodeID, requestID uint32, containers [][]byte) + func (m *MockFetchSender) SendGet(nodeID ids.NodeID, requestID uint32, containerID ids.ID) + func (m *MockFetchSender) SendGetAncestors(nodeID ids.NodeID, requestID uint32, containerID ids.ID) + func (m *MockFetchSender) SendPut(nodeID ids.NodeID, requestID uint32, containerID ids.ID, container []byte) + type MockFetchSenderMockRecorder struct + func (mr *MockFetchSenderMockRecorder) SendAncestors(nodeID, requestID, containers interface{}) *gomock.Call + func (mr *MockFetchSenderMockRecorder) SendGet(nodeID, requestID, containerID interface{}) *gomock.Call + func (mr *MockFetchSenderMockRecorder) SendGetAncestors(nodeID, requestID, containerID interface{}) *gomock.Call + func (mr *MockFetchSenderMockRecorder) SendPut(nodeID, requestID, containerID, container interface{}) *gomock.Call + type MockFrontierSender struct + func NewMockFrontierSender(ctrl *gomock.Controller) *MockFrontierSender + func (m *MockFrontierSender) EXPECT() *MockFrontierSenderMockRecorder + func (m *MockFrontierSender) SendAcceptedFrontier(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID) + func (m *MockFrontierSender) SendGetAcceptedFrontier(nodeIDs ids.NodeIDSet, requestID uint32) + type MockFrontierSenderMockRecorder struct + func (mr *MockFrontierSenderMockRecorder) SendAcceptedFrontier(nodeID, requestID, containerIDs interface{}) *gomock.Call + func (mr *MockFrontierSenderMockRecorder) SendGetAcceptedFrontier(nodeIDs, requestID interface{}) *gomock.Call + type MockGossiper struct + func NewMockGossiper(ctrl *gomock.Controller) *MockGossiper + func (m *MockGossiper) EXPECT() *MockGossiperMockRecorder + func (m *MockGossiper) SendGossip(containerID ids.ID, container []byte) + type MockGossiperMockRecorder struct + func (mr *MockGossiperMockRecorder) SendGossip(containerID, container interface{}) *gomock.Call + type MockQuerySender struct + func NewMockQuerySender(ctrl *gomock.Controller) *MockQuerySender + func (m *MockQuerySender) EXPECT() *MockQuerySenderMockRecorder + func (m *MockQuerySender) SendChits(nodeID ids.NodeID, requestID uint32, votes []ids.ID) + func (m *MockQuerySender) SendChitsV2(nodeID ids.NodeID, requestID uint32, votes []ids.ID, vote ids.ID) + func (m *MockQuerySender) SendPullQuery(nodeIDs ids.NodeIDSet, requestID uint32, containerID ids.ID) + func (m *MockQuerySender) SendPushQuery(nodeIDs ids.NodeIDSet, requestID uint32, containerID ids.ID, container []byte) + type MockQuerySenderMockRecorder struct + func (mr *MockQuerySenderMockRecorder) SendChits(nodeID, requestID, votes interface{}) *gomock.Call + func (mr *MockQuerySenderMockRecorder) SendChitsV2(nodeID, requestID, votes, vote interface{}) *gomock.Call + func (mr *MockQuerySenderMockRecorder) SendPullQuery(nodeIDs, requestID, containerID interface{}) *gomock.Call + func (mr *MockQuerySenderMockRecorder) SendPushQuery(nodeIDs, requestID, containerID, container interface{}) *gomock.Call + type MockSender struct + func NewMockSender(ctrl *gomock.Controller) *MockSender + func (m *MockSender) Accept(ctx *snow.ConsensusContext, containerID ids.ID, container []byte) error + func (m *MockSender) EXPECT() *MockSenderMockRecorder + func (m *MockSender) SendAccepted(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID) + func (m *MockSender) SendAcceptedFrontier(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID) + func (m *MockSender) SendAcceptedStateSummary(nodeID ids.NodeID, requestID uint32, summaryIDs []ids.ID) + func (m *MockSender) SendAncestors(nodeID ids.NodeID, requestID uint32, containers [][]byte) + func (m *MockSender) SendAppGossip(appGossipBytes []byte) error + func (m *MockSender) SendAppGossipSpecific(nodeIDs ids.NodeIDSet, appGossipBytes []byte) error + func (m *MockSender) SendAppRequest(nodeIDs ids.NodeIDSet, requestID uint32, appRequestBytes []byte) error + func (m *MockSender) SendAppResponse(nodeID ids.NodeID, requestID uint32, appResponseBytes []byte) error + func (m *MockSender) SendChits(nodeID ids.NodeID, requestID uint32, votes []ids.ID) + func (m *MockSender) SendChitsV2(nodeID ids.NodeID, requestID uint32, votes []ids.ID, vote ids.ID) + func (m *MockSender) SendGet(nodeID ids.NodeID, requestID uint32, containerID ids.ID) + func (m *MockSender) SendGetAccepted(nodeIDs ids.NodeIDSet, requestID uint32, containerIDs []ids.ID) + func (m *MockSender) SendGetAcceptedFrontier(nodeIDs ids.NodeIDSet, requestID uint32) + func (m *MockSender) SendGetAcceptedStateSummary(nodeIDs ids.NodeIDSet, requestID uint32, heights []uint64) + func (m *MockSender) SendGetAncestors(nodeID ids.NodeID, requestID uint32, containerID ids.ID) + func (m *MockSender) SendGetStateSummaryFrontier(nodeIDs ids.NodeIDSet, requestID uint32) + func (m *MockSender) SendGossip(containerID ids.ID, container []byte) + func (m *MockSender) SendPullQuery(nodeIDs ids.NodeIDSet, requestID uint32, containerID ids.ID) + func (m *MockSender) SendPushQuery(nodeIDs ids.NodeIDSet, requestID uint32, containerID ids.ID, container []byte) + func (m *MockSender) SendPut(nodeID ids.NodeID, requestID uint32, containerID ids.ID, container []byte) + func (m *MockSender) SendStateSummaryFrontier(nodeID ids.NodeID, requestID uint32, summary []byte) + type MockSenderMockRecorder struct + func (mr *MockSenderMockRecorder) Accept(ctx, containerID, container interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendAccepted(nodeID, requestID, containerIDs interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendAcceptedFrontier(nodeID, requestID, containerIDs interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendAcceptedStateSummary(nodeID, requestID, summaryIDs interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendAncestors(nodeID, requestID, containers interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendAppGossip(appGossipBytes interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendAppGossipSpecific(nodeIDs, appGossipBytes interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendAppRequest(nodeIDs, requestID, appRequestBytes interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendAppResponse(nodeID, requestID, appResponseBytes interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendChits(nodeID, requestID, votes interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendChitsV2(nodeID, requestID, votes, vote interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendGet(nodeID, requestID, containerID interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendGetAccepted(nodeIDs, requestID, containerIDs interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendGetAcceptedFrontier(nodeIDs, requestID interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendGetAcceptedStateSummary(nodeIDs, requestID, heights interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendGetAncestors(nodeID, requestID, containerID interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendGetStateSummaryFrontier(nodeIDs, requestID interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendGossip(containerID, container interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendPullQuery(nodeIDs, requestID, containerID interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendPushQuery(nodeIDs, requestID, containerID, container interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendPut(nodeID, requestID, containerID, container interface{}) *gomock.Call + func (mr *MockSenderMockRecorder) SendStateSummaryFrontier(nodeID, requestID, summary interface{}) *gomock.Call + type MockStateSummarySender struct + func NewMockStateSummarySender(ctrl *gomock.Controller) *MockStateSummarySender + func (m *MockStateSummarySender) EXPECT() *MockStateSummarySenderMockRecorder + func (m *MockStateSummarySender) SendGetStateSummaryFrontier(nodeIDs ids.NodeIDSet, requestID uint32) + func (m *MockStateSummarySender) SendStateSummaryFrontier(nodeID ids.NodeID, requestID uint32, summary []byte) + type MockStateSummarySenderMockRecorder struct + func (mr *MockStateSummarySenderMockRecorder) SendGetStateSummaryFrontier(nodeIDs, requestID interface{}) *gomock.Call + func (mr *MockStateSummarySenderMockRecorder) SendStateSummaryFrontier(nodeID, requestID, summary interface{}) *gomock.Call + type PutHandler interface + GetFailed func(validatorID ids.NodeID, requestID uint32) error + Put func(validatorID ids.NodeID, requestID uint32, container []byte) error + func NewNoOpPutHandler(log logging.Logger) PutHandler + type QueryHandler interface + PullQuery func(validatorID ids.NodeID, requestID uint32, containerID ids.ID) error + PushQuery func(validatorID ids.NodeID, requestID uint32, container []byte) error + func NewNoOpQueryHandler(log logging.Logger) QueryHandler + type QuerySender interface + SendChits func(nodeID ids.NodeID, requestID uint32, votes []ids.ID) + SendChitsV2 func(nodeID ids.NodeID, requestID uint32, votes []ids.ID, vote ids.ID) + SendPullQuery func(nodeIDs ids.NodeIDSet, requestID uint32, containerID ids.ID) + SendPushQuery func(nodeIDs ids.NodeIDSet, requestID uint32, containerID ids.ID, container []byte) + type Requests struct + func (r *Requests) Add(vdr ids.NodeID, requestID uint32, containerID ids.ID) + func (r *Requests) Contains(containerID ids.ID) bool + func (r *Requests) Len() int + func (r *Requests) Remove(vdr ids.NodeID, requestID uint32) (ids.ID, bool) + func (r *Requests) RemoveAny(containerID ids.ID) bool + func (r Requests) String() string + type Sender interface + type SenderTest struct + AcceptF func(*snow.ConsensusContext, ids.ID, []byte) error + CantAccept bool + CantSendAccepted bool + CantSendAcceptedFrontier bool + CantSendAcceptedStateSummary bool + CantSendAncestors bool + CantSendAppGossip bool + CantSendAppGossipSpecific bool + CantSendAppRequest bool + CantSendAppResponse bool + CantSendChits bool + CantSendChitsV2 bool + CantSendGet bool + CantSendGetAccepted bool + CantSendGetAcceptedFrontier bool + CantSendGetAcceptedStateSummary bool + CantSendGetAncestors bool + CantSendGetStateSummaryFrontier bool + CantSendGossip bool + CantSendPullQuery bool + CantSendPushQuery bool + CantSendPut bool + CantSendStateSummaryFrontier bool + SendAcceptedF func(ids.NodeID, uint32, []ids.ID) + SendAcceptedFrontierF func(ids.NodeID, uint32, []ids.ID) + SendAcceptedStateSummaryF func(ids.NodeID, uint32, []ids.ID) + SendAncestorsF func(ids.NodeID, uint32, [][]byte) + SendAppGossipF func([]byte) error + SendAppGossipSpecificF func(ids.NodeIDSet, []byte) error + SendAppRequestF func(ids.NodeIDSet, uint32, []byte) error + SendAppResponseF func(ids.NodeID, uint32, []byte) error + SendChitsF func(ids.NodeID, uint32, []ids.ID) + SendChitsV2F func(ids.NodeID, uint32, []ids.ID, ids.ID) + SendGetAcceptedF func(ids.NodeIDSet, uint32, []ids.ID) + SendGetAcceptedFrontierF func(ids.NodeIDSet, uint32) + SendGetAcceptedStateSummaryF func(ids.NodeIDSet, uint32, []uint64) + SendGetAncestorsF func(ids.NodeID, uint32, ids.ID) + SendGetF func(ids.NodeID, uint32, ids.ID) + SendGetStateSummaryFrontierF func(ids.NodeIDSet, uint32) + SendGossipF func(ids.ID, []byte) + SendPullQueryF func(ids.NodeIDSet, uint32, ids.ID) + SendPushQueryF func(ids.NodeIDSet, uint32, ids.ID, []byte) + SendPutF func(ids.NodeID, uint32, ids.ID, []byte) + SendStateSummaryFrontierF func(ids.NodeID, uint32, []byte) + T *testing.T + func (s *SenderTest) Accept(ctx *snow.ConsensusContext, containerID ids.ID, container []byte) error + func (s *SenderTest) Default(cant bool) + func (s *SenderTest) SendAccepted(validatorID ids.NodeID, requestID uint32, containerIDs []ids.ID) + func (s *SenderTest) SendAcceptedFrontier(validatorID ids.NodeID, requestID uint32, containerIDs []ids.ID) + func (s *SenderTest) SendAcceptedStateSummary(validatorID ids.NodeID, requestID uint32, summaryIDs []ids.ID) + func (s *SenderTest) SendAncestors(vdr ids.NodeID, requestID uint32, vtxs [][]byte) + func (s *SenderTest) SendAppGossip(appGossipBytes []byte) error + func (s *SenderTest) SendAppGossipSpecific(nodeIDs ids.NodeIDSet, appGossipBytes []byte) error + func (s *SenderTest) SendAppRequest(nodeIDs ids.NodeIDSet, requestID uint32, appRequestBytes []byte) error + func (s *SenderTest) SendAppResponse(nodeID ids.NodeID, requestID uint32, appResponseBytes []byte) error + func (s *SenderTest) SendChits(vdr ids.NodeID, requestID uint32, votes []ids.ID) + func (s *SenderTest) SendChitsV2(vdr ids.NodeID, requestID uint32, votes []ids.ID, vote ids.ID) + func (s *SenderTest) SendGet(vdr ids.NodeID, requestID uint32, vtxID ids.ID) + func (s *SenderTest) SendGetAccepted(nodeIDs ids.NodeIDSet, requestID uint32, containerIDs []ids.ID) + func (s *SenderTest) SendGetAcceptedFrontier(validatorIDs ids.NodeIDSet, requestID uint32) + func (s *SenderTest) SendGetAcceptedStateSummary(nodeIDs ids.NodeIDSet, requestID uint32, heights []uint64) + func (s *SenderTest) SendGetAncestors(validatorID ids.NodeID, requestID uint32, vtxID ids.ID) + func (s *SenderTest) SendGetStateSummaryFrontier(validatorIDs ids.NodeIDSet, requestID uint32) + func (s *SenderTest) SendGossip(containerID ids.ID, container []byte) + func (s *SenderTest) SendPullQuery(vdrs ids.NodeIDSet, requestID uint32, vtxID ids.ID) + func (s *SenderTest) SendPushQuery(vdrs ids.NodeIDSet, requestID uint32, vtxID ids.ID, vtx []byte) + func (s *SenderTest) SendPut(vdr ids.NodeID, requestID uint32, vtxID ids.ID, vtx []byte) + func (s *SenderTest) SendStateSummaryFrontier(validatorID ids.NodeID, requestID uint32, summary []byte) + type SharedConfig struct + RequestID uint32 + Restarted bool + type StateSummaryFrontierHandler interface + GetStateSummaryFrontierFailed func(validatorID ids.NodeID, requestID uint32) error + StateSummaryFrontier func(validatorID ids.NodeID, requestID uint32, summary []byte) error + func NewNoOpStateSummaryFrontierHandler(log logging.Logger) StateSummaryFrontierHandler + type StateSummarySender interface + SendGetStateSummaryFrontier func(nodeIDs ids.NodeIDSet, requestID uint32) + SendStateSummaryFrontier func(nodeID ids.NodeID, requestID uint32, summary []byte) + type StateSyncer interface + IsEnabled func() (bool, error) + type Subnet interface + Bootstrapped func(chainID ids.ID) + IsBootstrapped func() bool + type SubnetTest struct + BootstrappedF func(ids.ID) + CantBootstrapped bool + CantIsBootstrapped bool + IsBootstrappedF func() bool + T *testing.T + func (s *SubnetTest) Bootstrapped(chainID ids.ID) + func (s *SubnetTest) Default(cant bool) + func (s *SubnetTest) IsBootstrapped() bool + type SubnetTracker interface + TracksSubnet func(nodeID ids.NodeID, subnetID ids.ID) bool + type TestVM struct + AppGossipF func(nodeID ids.NodeID, msg []byte) error + AppRequestF func(nodeID ids.NodeID, requestID uint32, deadline time.Time, msg []byte) error + AppRequestFailedF func(nodeID ids.NodeID, requestID uint32) error + AppResponseF func(nodeID ids.NodeID, requestID uint32, msg []byte) error + CantAppGossip bool + CantAppRequest bool + CantAppRequestFailed bool + CantAppResponse bool + CantConnected bool + CantCreateHandlers bool + CantCreateStaticHandlers bool + CantDisconnected bool + CantHealthCheck bool + CantInitialize bool + CantSetState bool + CantShutdown bool + CantVersion bool + ConnectedF func(nodeID ids.NodeID, nodeVersion *version.Application) error + CreateHandlersF func() (map[string]*HTTPHandler, error) + CreateStaticHandlersF func() (map[string]*HTTPHandler, error) + DisconnectedF func(nodeID ids.NodeID) error + HealthCheckF func() (interface{}, error) + InitializeF func(*snow.Context, manager.Manager, []byte, []byte, []byte, chan<- Message, []*Fx, ...) error + SetStateF func(snow.State) error + ShutdownF func() error + T *testing.T + VersionF func() (string, error) + func (vm *TestVM) AppGossip(nodeID ids.NodeID, msg []byte) error + func (vm *TestVM) AppRequest(nodeID ids.NodeID, requestID uint32, deadline time.Time, request []byte) error + func (vm *TestVM) AppRequestFailed(nodeID ids.NodeID, requestID uint32) error + func (vm *TestVM) AppResponse(nodeID ids.NodeID, requestID uint32, response []byte) error + func (vm *TestVM) Connected(id ids.NodeID, nodeVersion *version.Application) error + func (vm *TestVM) CreateHandlers() (map[string]*HTTPHandler, error) + func (vm *TestVM) CreateStaticHandlers() (map[string]*HTTPHandler, error) + func (vm *TestVM) Default(cant bool) + func (vm *TestVM) Disconnected(id ids.NodeID) error + func (vm *TestVM) HealthCheck() (interface{}, error) + func (vm *TestVM) Initialize(ctx *snow.Context, db manager.Manager, ...) error + func (vm *TestVM) SetState(state snow.State) error + func (vm *TestVM) Shutdown() error + func (vm *TestVM) Version() (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() (map[string]*HTTPHandler, error) + CreateStaticHandlers func() (map[string]*HTTPHandler, error) + Initialize func(ctx *snow.Context, dbManager manager.Manager, genesisBytes []byte, ...) error + SetState func(state snow.State) error + Shutdown func() error + Version func() (string, error)
Go to main page