common

package

Go to main page

Versions in this module

v1

v1.9.8

Jun 28, 2023

Changes in this version

+ const MaxOutstandingBroadcastRequests

+ const MaxOutstandingGetAncestorsRequests

+ const StatusUpdateFrequency

+ func SendMixedQuery(ctx context.Context, sender Sender, vdrs []ids.NodeID, numPushTo int, ...)

+ type AcceptedFrontierHandler interface

+ AcceptedFrontier func(ctx context.Context, validatorID ids.NodeID, requestID uint32, ...) error

+ GetAcceptedFrontierFailed func(ctx context.Context, validatorID ids.NodeID, requestID uint32) error

+ func NewNoOpAcceptedFrontierHandler(log logging.Logger) AcceptedFrontierHandler

type AcceptedHandler

+ func NewNoOpAcceptedHandler(log logging.Logger) AcceptedHandler

type AcceptedSender

+ 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, validatorID ids.NodeID, requestID uint32, ...) error

+ GetAcceptedStateSummaryFailed func(ctx context.Context, validatorID 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, validatorID ids.NodeID, requestID uint32, ...) error

+ GetAncestorsFailed func(ctx context.Context, validatorID ids.NodeID, requestID uint32) error

+ func NewNoOpAncestorsHandler(log logging.Logger) AncestorsHandler

+ type AppHandler interface

+ func NewNoOpAppHandler(log logging.Logger) AppHandler

+ type AppSender interface

type Bootstrapable

+ Clear func() error

+ type BootstrapableEngine interface

+ func TraceBootstrapableEngine(bootstrapableEngine BootstrapableEngine, tracer trace.Tracer) BootstrapableEngine

type BootstrapableTest

+ CantClear bool

+ ClearF func() error

+ func (b *BootstrapableTest) Clear() error

type Bootstrapper

+ func NewCommonBootstrapper(config Config) Bootstrapper

+ Restart func(ctx context.Context, reset bool) error

+ type BootstrapperTest struct

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

+ type ChitsHandler interface

+ Chits func(ctx context.Context, validatorID ids.NodeID, requestID uint32, ...) error

+ QueryFailed func(ctx context.Context, 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 CrossChainAppHandler interface

+ CrossChainAppRequest func(ctx context.Context, chainID ids.ID, requestID uint32, deadline time.Time, ...) error

+ CrossChainAppRequestFailed func(ctx context.Context, chainID ids.ID, requestID uint32) error

+ CrossChainAppResponse func(ctx context.Context, chainID ids.ID, requestID uint32, response []byte) error

+ type CrossChainAppSender interface

+ 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

+ func TraceEngine(engine Engine, tracer trace.Tracer) Engine

+ GetVM func() VM

+ Start func(ctx context.Context, startReqID uint32) error

type EngineTest

+ AcceptedStateSummaryF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, summaryIDs []ids.ID) 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) error

+ AppResponseF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, msg []byte) error

+ CantAcceptedStateSummary bool

+ CantAncestors bool

+ CantAppGossip bool

+ CantAppRequest bool

+ CantAppRequestFailed bool

+ CantAppResponse bool

+ CantConnected bool

+ CantCrossChainAppRequest bool

+ CantCrossChainAppRequestFailed bool

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

+ ConnectedF func(ctx context.Context, nodeID ids.NodeID, nodeVersion *version.Application) 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) error

+ CrossChainAppResponseF func(ctx context.Context, chainID ids.ID, requestID uint32, msg []byte) error

+ DisconnectedF func(ctx context.Context, nodeID ids.NodeID) error

+ GetAcceptedStateSummaryF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, keys []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

+ 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

+ StartF func(ctx context.Context, startReqID uint32) error

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

+ TimeoutF func(context.Context) 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) error

+ func (e *EngineTest) AppResponse(ctx context.Context, nodeID ids.NodeID, requestID uint32, response []byte) error

+ func (e *EngineTest) Connected(ctx context.Context, nodeID ids.NodeID, nodeVersion *version.Application) error

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

+ func (e *EngineTest) CrossChainAppResponse(ctx context.Context, chainID ids.ID, requestID uint32, response []byte) error

+ func (e *EngineTest) Disconnected(ctx context.Context, nodeID ids.NodeID) error

+ func (e *EngineTest) GetAcceptedStateSummary(ctx context.Context, validatorID ids.NodeID, requestID uint32, keys []uint64) 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) 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) GetVM() VM

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

+ 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 Fetcher struct

+ OnFinished func(ctx context.Context, lastReqID uint32) error

+ OutstandingRequests Requests

type FrontierSender

+ SendAcceptedFrontier func(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...)

+ SendGetAcceptedFrontier func(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32)

+ type GetAcceptedFrontierHandler interface

+ GetAcceptedFrontier func(ctx context.Context, validatorID ids.NodeID, requestID uint32) error

+ type GetAcceptedHandler interface

+ GetAccepted func(ctx context.Context, validatorID ids.NodeID, requestID uint32, ...) error

+ type GetAcceptedStateSummaryHandler interface

+ GetAcceptedStateSummary func(ctx context.Context, validatorID ids.NodeID, requestID uint32, keys []uint64) error

+ type GetAncestorsHandler interface

+ GetAncestors func(ctx context.Context, validatorID ids.NodeID, requestID uint32, ...) error

+ type GetHandler interface

+ Get func(ctx context.Context, validatorID ids.NodeID, requestID uint32, ...) error

+ type GetStateSummaryFrontierHandler interface

+ GetStateSummaryFrontier func(ctx context.Context, validatorID ids.NodeID, requestID uint32) error

+ type Gossiper interface

+ SendGossip func(ctx context.Context, container []byte)

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

+ Gossip func(context.Context) error

+ Halt func(context.Context)

+ Timeout func(context.Context) error

type Message

+ const StateSyncDone

+ const StopVertex

+ type MockSender struct

+ func NewMockSender(ctrl *gomock.Controller) *MockSender

+ func (m *MockSender) Accept(arg0 *snow.ConsensusContext, arg1 ids.ID, arg2 []byte) error

+ func (m *MockSender) EXPECT() *MockSenderMockRecorder

+ func (m *MockSender) SendAccepted(arg0 context.Context, arg1 ids.NodeID, arg2 uint32, arg3 []ids.ID)

+ func (m *MockSender) SendAcceptedFrontier(arg0 context.Context, arg1 ids.NodeID, arg2 uint32, arg3 []ids.ID)

+ func (m *MockSender) SendAcceptedStateSummary(arg0 context.Context, arg1 ids.NodeID, arg2 uint32, arg3 []ids.ID)

+ func (m *MockSender) SendAncestors(arg0 context.Context, arg1 ids.NodeID, arg2 uint32, arg3 [][]byte)

+ func (m *MockSender) SendAppGossip(arg0 context.Context, arg1 []byte) error

+ func (m *MockSender) SendAppGossipSpecific(arg0 context.Context, arg1 set.Set[ids.NodeID], arg2 []byte) error

+ func (m *MockSender) SendAppRequest(arg0 context.Context, arg1 set.Set[ids.NodeID], arg2 uint32, arg3 []byte) error

+ func (m *MockSender) SendAppResponse(arg0 context.Context, arg1 ids.NodeID, arg2 uint32, arg3 []byte) error

+ func (m *MockSender) SendChits(arg0 context.Context, arg1 ids.NodeID, arg2 uint32, arg3, arg4 []ids.ID)

+ func (m *MockSender) SendCrossChainAppRequest(arg0 context.Context, arg1 ids.ID, arg2 uint32, arg3 []byte) error

+ func (m *MockSender) SendCrossChainAppResponse(arg0 context.Context, arg1 ids.ID, arg2 uint32, arg3 []byte) error

+ func (m *MockSender) SendGet(arg0 context.Context, arg1 ids.NodeID, arg2 uint32, arg3 ids.ID)

+ func (m *MockSender) SendGetAccepted(arg0 context.Context, arg1 set.Set[ids.NodeID], arg2 uint32, arg3 []ids.ID)

+ func (m *MockSender) SendGetAcceptedFrontier(arg0 context.Context, arg1 set.Set[ids.NodeID], arg2 uint32)

+ func (m *MockSender) SendGetAcceptedStateSummary(arg0 context.Context, arg1 set.Set[ids.NodeID], arg2 uint32, arg3 []uint64)

+ func (m *MockSender) SendGetAncestors(arg0 context.Context, arg1 ids.NodeID, arg2 uint32, arg3 ids.ID)

+ func (m *MockSender) SendGetStateSummaryFrontier(arg0 context.Context, arg1 set.Set[ids.NodeID], arg2 uint32)

+ func (m *MockSender) SendGossip(arg0 context.Context, arg1 []byte)

+ func (m *MockSender) SendPullQuery(arg0 context.Context, arg1 set.Set[ids.NodeID], arg2 uint32, arg3 ids.ID)

+ func (m *MockSender) SendPushQuery(arg0 context.Context, arg1 set.Set[ids.NodeID], arg2 uint32, arg3 []byte)

+ func (m *MockSender) SendPut(arg0 context.Context, arg1 ids.NodeID, arg2 uint32, arg3 []byte)

+ func (m *MockSender) SendStateSummaryFrontier(arg0 context.Context, arg1 ids.NodeID, arg2 uint32, arg3 []byte)

+ type MockSenderMockRecorder struct

+ func (mr *MockSenderMockRecorder) Accept(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendAccepted(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendAcceptedFrontier(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendAcceptedStateSummary(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendAncestors(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendAppGossip(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendAppGossipSpecific(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendAppRequest(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendAppResponse(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendChits(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendCrossChainAppRequest(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendCrossChainAppResponse(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendGet(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendGetAccepted(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendGetAcceptedFrontier(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendGetAcceptedStateSummary(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendGetAncestors(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendGetStateSummaryFrontier(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendGossip(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendPullQuery(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendPushQuery(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendPut(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendStateSummaryFrontier(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ type NetworkAppHandler interface

+ AppGossip func(ctx context.Context, nodeID ids.NodeID, msg []byte) error

+ AppRequest func(ctx context.Context, nodeID ids.NodeID, requestID uint32, deadline time.Time, ...) error

+ AppRequestFailed func(ctx context.Context, nodeID ids.NodeID, requestID uint32) error

+ AppResponse func(ctx context.Context, nodeID ids.NodeID, requestID uint32, response []byte) error

+ type NetworkAppSender interface

+ SendAppGossip func(ctx context.Context, appGossipBytes []byte) error

+ SendAppGossipSpecific func(ctx context.Context, nodeIDs set.Set[ids.NodeID], 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, validatorID ids.NodeID, requestID uint32) error

+ Put func(ctx context.Context, validatorID ids.NodeID, requestID uint32, ...) error

+ func NewNoOpPutHandler(log logging.Logger) PutHandler

type QueryHandler

+ func NewNoOpQueryHandler(log logging.Logger) QueryHandler

type QuerySender

+ SendChits func(ctx context.Context, nodeID ids.NodeID, requestID uint32, votes []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 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) Get(vdr ids.NodeID, requestID uint32) (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

+ CantSendCrossChainAppRequest bool

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

+ SendAppGossipF func(context.Context, []byte) error

+ SendAppGossipSpecificF func(context.Context, set.Set[ids.NodeID], []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)

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

+ SendGossipF func(context.Context, []byte)

+ SendPullQueryF func(context.Context, set.Set[ids.NodeID], uint32, ids.ID)

+ SendPushQueryF func(context.Context, set.Set[ids.NodeID], uint32, []byte)

+ SendPutF func(context.Context, ids.NodeID, uint32, []byte)

+ SendStateSummaryFrontierF func(context.Context, ids.NodeID, uint32, []byte)

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

+ 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, vtxs [][]byte)

+ func (s *SenderTest) SendAppGossip(ctx context.Context, appGossipBytes []byte) error

+ func (s *SenderTest) SendAppGossipSpecific(ctx context.Context, nodeIDs set.Set[ids.NodeID], 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, votes []ids.ID, ...)

+ 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, vtxID 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, vtxID ids.ID)

+ func (s *SenderTest) SendGetStateSummaryFrontier(ctx context.Context, validatorIDs set.Set[ids.NodeID], requestID uint32)

+ func (s *SenderTest) SendGossip(ctx context.Context, container []byte)

+ func (s *SenderTest) SendPullQuery(ctx context.Context, vdrs set.Set[ids.NodeID], requestID uint32, vtxID ids.ID)

+ func (s *SenderTest) SendPushQuery(ctx context.Context, vdrs set.Set[ids.NodeID], requestID uint32, vtx []byte)

+ func (s *SenderTest) SendPut(ctx context.Context, vdr ids.NodeID, requestID uint32, vtx []byte)

+ func (s *SenderTest) SendStateSummaryFrontier(ctx context.Context, validatorID ids.NodeID, requestID uint32, summary []byte)

+ type SharedConfig struct

+ RequestID uint32

+ Restarted bool

+ type StateSummaryFrontierHandler interface

+ GetStateSummaryFrontierFailed func(ctx context.Context, validatorID ids.NodeID, requestID uint32) error

+ StateSummaryFrontier func(ctx context.Context, validatorID 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 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 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) 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

+ CantCreateStaticHandlers 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]*HTTPHandler, error)

+ CreateStaticHandlersF func(context.Context) (map[string]*HTTPHandler, 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) 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 manager.Manager, ...) 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) 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]*HTTPHandler, error)

+ func (vm *TestVM) CreateStaticHandlers(ctx context.Context) (map[string]*HTTPHandler, 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) 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 manager.Manager, ...) 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

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

+ SetState func(ctx context.Context, state snow.State) error

+ Version func(context.Context) (string, error)

v1.9.8-rc.9

Jun 28, 2023

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