Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

common

package

Go to main page

Versions in this module

v0

v0.1.4

Oct 31, 2024

v0.1.3

Aug 10, 2023

v0.1.2

Aug 10, 2023

v0.1.1

Aug 10, 2023

Changes in this version

+ const MaxOutstandingBroadcastRequests

+ const MaxOutstandingGetAncestorsRequests

+ const NoLock

+ const ReadLock

+ const StatusUpdateFrequency

+ const WriteLock

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

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

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

+ func NewNoOpAcceptedHandler(log logging.Logger) AcceptedHandler

+ type AcceptedSender interface

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

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

+ type AcceptedStateSummaryHandler interface

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

+ Clear func() error

+ ForceAccepted func(ctx context.Context, acceptedContainerIDs []ids.ID) error

+ type BootstrapableEngine interface

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

+ type BootstrapableTest struct

+ CantClear bool

+ CantForceAccepted bool

+ ClearF func() error

+ ForceAcceptedF func(ctx context.Context, acceptedContainerIDs []ids.ID) error

+ T *testing.T

+ func (b *BootstrapableTest) Clear() error

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

+ func (b *BootstrapableTest) ForceAccepted(ctx context.Context, containerIDs []ids.ID) error

+ type Bootstrapper interface

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

+ Startup func(context.Context) error

+ func NewCommonBootstrapper(config Config) Bootstrapper

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

+ Context func() *snow.ConsensusContext

+ GetVM func() VM

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

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

+ type EngineTest struct

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

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

+ 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

+ CantAccepted bool

+ CantAcceptedFrontier bool

+ CantAcceptedStateSummary bool

+ CantAncestors bool

+ CantAppGossip bool

+ CantAppRequest bool

+ CantAppRequestFailed bool

+ CantAppResponse bool

+ CantChits bool

+ CantConnected bool

+ CantContext bool

+ CantCrossChainAppRequest bool

+ CantCrossChainAppRequestFailed bool

+ CantCrossChainAppResponse bool

+ CantDisconnected bool

+ CantGet bool

+ CantGetAccepted bool

+ CantGetAcceptedFailed bool

+ CantGetAcceptedFrontier bool

+ CantGetAcceptedFrontierFailed bool

+ CantGetAcceptedStateSummary bool

+ CantGetAcceptedStateSummaryFailed bool

+ CantGetAncestors bool

+ CantGetAncestorsFailed bool

+ CantGetFailed bool

+ CantGetStateSummaryFrontier bool

+ CantGetStateSummaryFrontierFailed bool

+ CantGetVM bool

+ CantGossip bool

+ CantHalt bool

+ CantHealth bool

+ CantIsBootstrapped bool

+ CantNotify bool

+ CantPullQuery bool

+ CantPushQuery bool

+ CantPut bool

+ CantQueryFailed bool

+ CantShutdown bool

+ CantStart bool

+ CantStateSummaryFrontier bool

+ CantTimeout bool

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

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

+ ContextF func() *snow.ConsensusContext

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

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

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

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

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

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

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

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

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

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

+ GetAncestorsF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) error

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

+ GetF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) error

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

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

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

+ GetVMF func() VM

+ GossipF func(context.Context) error

+ HaltF func(context.Context)

+ HealthF func(context.Context) (interface{}, error)

+ IsBootstrappedF func() bool

+ NotifyF func(context.Context, Message) error

+ PullQueryF func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) error

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

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

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

+ ShutdownF func(context.Context) error

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

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

+ T *testing.T

+ TimeoutF func(context.Context) error

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

+ func (e *EngineTest) AcceptedFrontier(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) 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) Chits(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) error

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

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

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

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

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

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

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

+ func (e *EngineTest) Get(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) error

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

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

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

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

+ func (e *EngineTest) GetAcceptedStateSummary(ctx context.Context, validatorID ids.NodeID, requestID uint32, 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) GetFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32) error

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

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

+ func (e *EngineTest) 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) Notify(ctx context.Context, msg Message) error

+ func (e *EngineTest) PullQuery(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) error

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

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

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

+ func (e *EngineTest) Shutdown(ctx context.Context) error

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

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

+ func (e *EngineTest) Timeout(ctx context.Context) error

+ type FetchSender interface

+ SendAncestors func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containers [][]byte)

+ SendGet func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID)

+ SendGetAncestors func(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID)

+ SendPut func(ctx context.Context, nodeID ids.NodeID, requestID uint32, container []byte)

+ type Fetcher struct

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

+ OutstandingRequests Requests

+ type FrontierSender interface

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

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

+ type Fx struct

+ Fx interface{}

+ ID ids.ID

+ type GetAcceptedFrontierHandler interface

+ GetAcceptedFrontier func(ctx context.Context, 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 HTTPHandler struct

+ Handler http.Handler

+ LockOptions LockOption

+ type Haltable interface

+ Halt func(context.Context)

+ Halted func() bool

+ type Halter struct

+ func (h *Halter) Halt(context.Context)

+ func (h *Halter) Halted() bool

+ type Handler interface

+ type InternalHandler interface

+ Gossip func(context.Context) error

+ Halt func(context.Context)

+ Notify func(context.Context, Message) error

+ Shutdown func(context.Context) error

+ Timeout func(context.Context) error

+ type LockOption uint32

+ type Message uint32

+ const PendingTxs

+ const StateSyncDone

+ const StopVertex

+ func (msg Message) String() string

+ 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 []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 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 interface

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

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

+ func NewNoOpQueryHandler(log logging.Logger) QueryHandler

+ type QuerySender interface

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

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

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

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

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

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

+ Initialize func(ctx context.Context, chainCtx *snow.Context, dbManager manager.Manager, ...) error

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

+ Shutdown func(context.Context) error

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