common

package

Go to main page

Versions in this module

v1

v1.8.14

Dec 22, 2022

v1.8.13

Dec 22, 2022

v1.8.12

Dec 21, 2022

v1.8.11

Dec 21, 2022

v1.8.10

Dec 14, 2022

v1.8.9

Dec 13, 2022

v1.8.8

Dec 13, 2022

v1.8.7

Dec 13, 2022

Changes in this version

type BootstrapableEngine

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

+ 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

type EngineTest

+ CantCrossChainAppRequest bool

+ CantCrossChainAppRequestFailed bool

+ CantCrossChainAppResponse bool

+ 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

+ 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

type MockSender

+ 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

type MockSenderMockRecorder

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

+ func (mr *MockSenderMockRecorder) SendCrossChainAppResponse(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 SenderTest

+ CantSendCrossChainAppRequest bool

+ CantSendCrossChainAppResponse bool

+ SendCrossChainAppRequestF func(context.Context, ids.ID, uint32, []byte)

+ SendCrossChainAppResponseF func(context.Context, ids.ID, uint32, []byte)

+ 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

type StateSyncer

+ func TraceStateSyncer(stateSyncer StateSyncer, tracer trace.Tracer) StateSyncer

type TestVM

+ CantCrossChainAppRequest bool

+ CantCrossChainAppRequestFailed bool

+ CantCrossChainAppResponse bool

+ 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

+ 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

v1.8.6

Dec 6, 2022

v0

v0.1.0

Dec 4, 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

+ 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

+ 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

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

+ type MockGossiperMockRecorder struct

+ func (mr *MockGossiperMockRecorder) SendGossip(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) SendPullQuery(nodeIDs ids.NodeIDSet, requestID uint32, containerID ids.ID)

+ func (m *MockQuerySender) SendPushQuery(nodeIDs ids.NodeIDSet, requestID uint32, container []byte)

+ type MockQuerySenderMockRecorder struct

+ func (mr *MockQuerySenderMockRecorder) SendChits(nodeID, requestID, votes interface{}) *gomock.Call

+ func (mr *MockQuerySenderMockRecorder) SendPullQuery(nodeIDs, requestID, containerID interface{}) *gomock.Call

+ func (mr *MockQuerySenderMockRecorder) SendPushQuery(nodeIDs, requestID, 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) 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(container []byte)

+ func (m *MockSender) SendPullQuery(nodeIDs ids.NodeIDSet, requestID uint32, containerID ids.ID)

+ func (m *MockSender) SendPushQuery(nodeIDs ids.NodeIDSet, requestID uint32, container []byte)

+ func (m *MockSender) SendPut(nodeID ids.NodeID, requestID uint32, 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) 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(container interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendPullQuery(nodeIDs, requestID, containerID interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendPushQuery(nodeIDs, requestID, container interface{}) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendPut(nodeID, requestID, 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)

+ SendPullQuery func(nodeIDs ids.NodeIDSet, requestID uint32, containerID ids.ID)

+ SendPushQuery func(nodeIDs ids.NodeIDSet, requestID uint32, 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) 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 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

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

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

+ SendPullQueryF func(ids.NodeIDSet, uint32, ids.ID)

+ SendPushQueryF func(ids.NodeIDSet, uint32, []byte)

+ SendPutF func(ids.NodeID, uint32, []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) 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(container []byte)

+ func (s *SenderTest) SendPullQuery(vdrs ids.NodeIDSet, requestID uint32, vtxID ids.ID)

+ func (s *SenderTest) SendPushQuery(vdrs ids.NodeIDSet, requestID uint32, vtx []byte)

+ func (s *SenderTest) SendPut(vdr ids.NodeID, requestID uint32, 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)

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