common

package

Go to main page

Versions in this module

v1

v1.7.17

Aug 10, 2022

v1.7.16

Jul 28, 2022

Changes in this version

+ const MaxOutstandingBroadcastRequests

+ const MaxOutstandingGetAncestorsRequests

+ const StatusUpdateFrequency

+ 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

+ func NewNoOpAcceptedHandler(log logging.Logger) AcceptedHandler

type AcceptedSender

+ 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

+ Clear func() error

+ type BootstrapableEngine interface

type BootstrapableTest

+ CantClear bool

+ ClearF func() error

+ func (b *BootstrapableTest) Clear() error

type Bootstrapper

+ func NewCommonBootstrapper(config Config) Bootstrapper

+ Restart func(reset bool) error

+ 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

+ AncestorsMaxContainersReceived int

+ AncestorsMaxContainersSent int

+ Ctx *snow.ConsensusContext

+ MaxTimeGetAncestors time.Duration

+ RetryBootstrap bool

+ RetryBootstrapWarnFrequency int

+ SampleK int

+ SharedCfg *SharedConfig

+ StartupTracker tracker.Startup

+ Subnet Subnet

+ Timer Timer

+ func (c *Config) IsBootstrapped() bool

type Engine

+ GetVM func() VM

+ Start func(startReqID uint32) error

type EngineTest

+ 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

+ CantAcceptedStateSummary bool

+ CantAncestors bool

+ CantAppGossip bool

+ CantAppRequest bool

+ CantAppRequestFailed bool

+ CantAppResponse bool

+ CantChitsV2 bool

+ CantConnected bool

+ CantDisconnected bool

+ CantGetAcceptedStateSummary bool

+ CantGetAcceptedStateSummaryFailed bool

+ CantGetAncestors bool

+ CantGetAncestorsFailed bool

+ CantGetStateSummaryFrontier bool

+ CantGetStateSummaryFrontierFailed bool

+ CantGetVM bool

+ CantGossip bool

+ CantHalt bool

+ CantHealth bool

+ CantIsBootstrapped bool

+ CantStart bool

+ CantStateSummaryFrontier bool

+ CantTimeout bool

+ ChitsV2F func(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID, containerID ids.ID) error

+ ConnectedF func(nodeID ids.NodeID, nodeVersion *version.Application) error

+ DisconnectedF func(nodeID ids.NodeID) 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

+ 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

+ StartF func(startReqID uint32) error

+ StateSummaryFrontierF func(nodeID ids.NodeID, requestID uint32, summary []byte) error

+ TimeoutF func() 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) 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) Disconnected(nodeID ids.NodeID) 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) 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) Start(startReqID uint32) error

+ func (e *EngineTest) StateSummaryFrontier(validatorID ids.NodeID, requestID uint32, summary []byte) error

+ func (e *EngineTest) Timeout() error

type FetchSender

+ 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

+ SendAcceptedFrontier func(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID)

+ SendGetAcceptedFrontier func(nodeIDs ids.NodeIDSet, requestID uint32)

+ 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 Haltable interface

+ Halt func()

+ Halted func() bool

+ type Halter struct

+ func (h *Halter) Halt()

+ func (h *Halter) Halted() bool

type InternalHandler

+ Gossip func() error

+ Halt func()

+ Timeout func() error

type Message

+ const StateSyncDone

+ const StopVertex

+ 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

+ func NewNoOpQueryHandler(log logging.Logger) QueryHandler

type QuerySender

+ 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 SenderTest

+ 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)

+ func (s *SenderTest) Accept(ctx *snow.ConsensusContext, containerID ids.ID, container []byte) error

+ 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

+ CreateStaticHandlers func() (map[string]*HTTPHandler, error)

+ SetState func(state snow.State) error

+ Version func() (string, error)

v1.7.16-rc.1

Aug 1, 2022

v1.7.14-rc.9

Jul 15, 2022

v1.7.14-rc.8

Jul 7, 2022

v1.7.13-rc.8

Aug 2, 2022

v1.7.13-rc.7

Aug 2, 2022

v1.7.13-rc.6

Aug 2, 2022

v1.7.13-rc.5

Aug 1, 2022

v1.7.10-rc.7

Aug 18, 2022

v1.7.10-rc.6

Aug 4, 2022

v1.7.10-rc.5

Aug 2, 2022

v1.7.10-rc.4

Aug 2, 2022

v0

v0.1.0

Apr 19, 2020

Changes in this version

+ const NoLock

+ const ReadLock

+ const WriteLock

+ type AcceptedHandler interface

+ Accepted func(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ GetAccepted func(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ GetAcceptedFailed func(validatorID ids.ShortID, requestID uint32)

+ type AcceptedSender interface

+ Accepted func(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ GetAccepted func(validatorIDs ids.ShortSet, requestID uint32, containerIDs ids.Set)

+ type Bootstrapable interface

+ CurrentAcceptedFrontier func() ids.Set

+ FilterAccepted func(containerIDs ids.Set) (acceptedContainerIDs ids.Set)

+ ForceAccepted func(acceptedContainerIDs ids.Set)

+ type BootstrapableTest struct

+ CantCurrentAcceptedFrontier bool

+ CantFilterAccepted bool

+ CantForceAccepted bool

+ CurrentAcceptedFrontierF func() (acceptedContainerIDs ids.Set)

+ FilterAcceptedF func(containerIDs ids.Set) (acceptedContainerIDs ids.Set)

+ ForceAcceptedF func(acceptedContainerIDs ids.Set)

+ T *testing.T

+ func (b *BootstrapableTest) CurrentAcceptedFrontier() ids.Set

+ func (b *BootstrapableTest) Default(cant bool)

+ func (b *BootstrapableTest) FilterAccepted(containerIDs ids.Set) ids.Set

+ func (b *BootstrapableTest) ForceAccepted(containerIDs ids.Set)

+ type Bootstrapper struct

+ RequestID uint32

+ func (b *Bootstrapper) Accepted(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ func (b *Bootstrapper) AcceptedFrontier(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ func (b *Bootstrapper) GetAccepted(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ func (b *Bootstrapper) GetAcceptedFailed(validatorID ids.ShortID, requestID uint32)

+ func (b *Bootstrapper) GetAcceptedFrontier(validatorID ids.ShortID, requestID uint32)

+ func (b *Bootstrapper) GetAcceptedFrontierFailed(validatorID ids.ShortID, requestID uint32)

+ func (b *Bootstrapper) Initialize(config Config)

+ func (b *Bootstrapper) Startup()

+ type Config struct

+ Alpha uint64

+ Beacons validators.Set

+ Bootstrapable Bootstrapable

+ Context *snow.Context

+ Sender Sender

+ Validators validators.Set

+ func DefaultConfigTest() Config

+ type Engine interface

+ Context func() *snow.Context

+ type EngineTest struct

+ AcceptedF func(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ AcceptedFrontierF func(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ CantAccepted bool

+ CantAcceptedFrontier bool

+ CantChits bool

+ CantContext bool

+ CantGet bool

+ CantGetAccepted bool

+ CantGetAcceptedFailed bool

+ CantGetAcceptedFrontier bool

+ CantGetAcceptedFrontierFailed bool

+ CantGetFailed bool

+ CantNotify bool

+ CantPullQuery bool

+ CantPushQuery bool

+ CantPut bool

+ CantQueryFailed bool

+ CantShutdown bool

+ CantStartup bool

+ ChitsF func(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ ContextF func() *snow.Context

+ GetAcceptedF func(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ GetAcceptedFailedF func(validatorID ids.ShortID, requestID uint32)

+ GetAcceptedFrontierF func(validatorID ids.ShortID, requestID uint32)

+ GetAcceptedFrontierFailedF func(validatorID ids.ShortID, requestID uint32)

+ GetF func(validatorID ids.ShortID, requestID uint32, containerID ids.ID)

+ GetFailedF func(validatorID ids.ShortID, requestID uint32, containerID ids.ID)

+ NotifyF func(Message)

+ PullQueryF func(validatorID ids.ShortID, requestID uint32, containerID ids.ID)

+ PushQueryF func(validatorID ids.ShortID, requestID uint32, containerID ids.ID, ...)

+ PutF func(validatorID ids.ShortID, requestID uint32, containerID ids.ID, ...)

+ QueryFailedF func(validatorID ids.ShortID, requestID uint32)

+ ShutdownF func()

+ StartupF func()

+ T *testing.T

+ func (e *EngineTest) Accepted(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ func (e *EngineTest) AcceptedFrontier(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ func (e *EngineTest) Chits(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ func (e *EngineTest) Context() *snow.Context

+ func (e *EngineTest) Default(cant bool)

+ func (e *EngineTest) Get(validatorID ids.ShortID, requestID uint32, containerID ids.ID)

+ func (e *EngineTest) GetAccepted(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ func (e *EngineTest) GetAcceptedFailed(validatorID ids.ShortID, requestID uint32)

+ func (e *EngineTest) GetAcceptedFrontier(validatorID ids.ShortID, requestID uint32)

+ func (e *EngineTest) GetAcceptedFrontierFailed(validatorID ids.ShortID, requestID uint32)

+ func (e *EngineTest) GetFailed(validatorID ids.ShortID, requestID uint32, containerID ids.ID)

+ func (e *EngineTest) Notify(msg Message)

+ func (e *EngineTest) PullQuery(validatorID ids.ShortID, requestID uint32, containerID ids.ID)

+ func (e *EngineTest) PushQuery(validatorID ids.ShortID, requestID uint32, containerID ids.ID, ...)

+ func (e *EngineTest) Put(validatorID ids.ShortID, requestID uint32, containerID ids.ID, ...)

+ func (e *EngineTest) QueryFailed(validatorID ids.ShortID, requestID uint32)

+ func (e *EngineTest) Shutdown()

+ func (e *EngineTest) Startup()

+ type ExternalHandler interface

+ type FetchHandler interface

+ Get func(validatorID ids.ShortID, requestID uint32, containerID ids.ID)

+ GetFailed func(validatorID ids.ShortID, requestID uint32, containerID ids.ID)

+ Put func(validatorID ids.ShortID, requestID uint32, containerID ids.ID, ...)

+ type FetchSender interface

+ Get func(validatorID ids.ShortID, requestID uint32, containerID ids.ID)

+ Put func(validatorID ids.ShortID, requestID uint32, containerID ids.ID, ...)

+ type FrontierHandler interface

+ AcceptedFrontier func(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ GetAcceptedFrontier func(validatorID ids.ShortID, requestID uint32)

+ GetAcceptedFrontierFailed func(validatorID ids.ShortID, requestID uint32)

+ type FrontierSender interface

+ AcceptedFrontier func(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ GetAcceptedFrontier func(validatorIDs ids.ShortSet, requestID uint32)

+ type Fx struct

+ Fx interface{}

+ ID ids.ID

+ type HTTPHandler struct

+ Handler http.Handler

+ LockOptions LockOption

+ type Handler interface

+ type InternalHandler interface

+ Notify func(Message)

+ Shutdown func()

+ Startup func()

+ type LockOption uint32

+ type Message uint32

+ const PendingTxs

+ func (msg Message) String() string

+ type QueryHandler interface

+ Chits func(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ PullQuery func(validatorID ids.ShortID, requestID uint32, containerID ids.ID)

+ PushQuery func(validatorID ids.ShortID, requestID uint32, containerID ids.ID, ...)

+ QueryFailed func(validatorID ids.ShortID, requestID uint32)

+ type QuerySender interface

+ Chits func(validatorID ids.ShortID, requestID uint32, votes ids.Set)

+ PullQuery func(validatorIDs ids.ShortSet, requestID uint32, containerID ids.ID)

+ PushQuery func(validatorIDs ids.ShortSet, requestID uint32, containerID ids.ID, ...)

+ type Sender interface

+ type SenderTest struct

+ AcceptedF func(ids.ShortID, uint32, ids.Set)

+ AcceptedFrontierF func(ids.ShortID, uint32, ids.Set)

+ CantAccepted bool

+ CantAcceptedFrontier bool

+ CantChits bool

+ CantGet bool

+ CantGetAccepted bool

+ CantGetAcceptedFrontier bool

+ CantPullQuery bool

+ CantPushQuery bool

+ CantPut bool

+ ChitsF func(ids.ShortID, uint32, ids.Set)

+ GetAcceptedF func(ids.ShortSet, uint32, ids.Set)

+ GetAcceptedFrontierF func(ids.ShortSet, uint32)

+ GetF func(ids.ShortID, uint32, ids.ID)

+ PullQueryF func(ids.ShortSet, uint32, ids.ID)

+ PushQueryF func(ids.ShortSet, uint32, ids.ID, []byte)

+ PutF func(ids.ShortID, uint32, ids.ID, []byte)

+ T *testing.T

+ func (s *SenderTest) Accepted(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ func (s *SenderTest) AcceptedFrontier(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

+ func (s *SenderTest) Chits(vdr ids.ShortID, requestID uint32, votes ids.Set)

+ func (s *SenderTest) Default(cant bool)

+ func (s *SenderTest) Get(vdr ids.ShortID, requestID uint32, vtxID ids.ID)

+ func (s *SenderTest) GetAccepted(validatorIDs ids.ShortSet, requestID uint32, containerIDs ids.Set)

+ func (s *SenderTest) GetAcceptedFrontier(validatorIDs ids.ShortSet, requestID uint32)

+ func (s *SenderTest) PullQuery(vdrs ids.ShortSet, requestID uint32, vtxID ids.ID)

+ func (s *SenderTest) PushQuery(vdrs ids.ShortSet, requestID uint32, vtxID ids.ID, vtx []byte)

+ func (s *SenderTest) Put(vdr ids.ShortID, requestID uint32, vtxID ids.ID, vtx []byte)

+ type StaticVM interface

+ CreateStaticHandlers func() map[string]*HTTPHandler

+ type VM interface

+ CreateHandlers func() map[string]*HTTPHandler

+ Initialize func(ctx *snow.Context, db database.Database, genesisBytes []byte, ...) error

+ Shutdown func()

+ type VMTest struct

+ CantCreateHandlers bool

+ CantCreateStaticHandlers bool

+ CantInitialize bool

+ CantShutdown bool

+ CreateHandlersF func() map[string]*HTTPHandler

+ CreateStaticHandlersF func() map[string]*HTTPHandler

+ InitializeF func(*snow.Context, database.Database, []byte, chan<- Message, []*Fx) error

+ ShutdownF func()

+ T *testing.T

+ func (vm *VMTest) CreateHandlers() map[string]*HTTPHandler

+ func (vm *VMTest) CreateStaticHandlers() map[string]*HTTPHandler

+ func (vm *VMTest) Default(cant bool)

+ func (vm *VMTest) Initialize(ctx *snow.Context, db database.Database, initState []byte, ...) error

+ func (vm *VMTest) Shutdown()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL