common

package

Go to main page

Versions in this module

v1

v1.10.1

Apr 13, 2022

v1.7.11

Apr 13, 2022

v1.6.11

Apr 13, 2022

Changes in this version

+ const MaxOutstandingBootstrapRequests

+ const MaxOutstandingGetAncestorsRequests

+ const MaxTimeFetchingAncestors

+ const StatusUpdateFrequency

+ type AcceptedFrontierHandler interface

+ AcceptedFrontier func(validatorID ids.ShortID, requestID uint32, containerIDs []ids.ID) error

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

+ func NewNoOpAcceptedFrontierHandler(log logging.Logger) AcceptedFrontierHandler

type AcceptedHandler

+ func NewNoOpAcceptedHandler(log logging.Logger) AcceptedHandler

type AcceptedSender

+ SendAccepted func(nodeID ids.ShortID, requestID uint32, containerIDs []ids.ID)

+ SendGetAccepted func(nodeIDs ids.ShortSet, requestID uint32, containerIDs []ids.ID)

+ type AllGetsServer interface

+ type AncestorsHandler interface

+ Ancestors func(validatorID ids.ShortID, requestID uint32, containers [][]byte) error

+ GetAncestorsFailed func(validatorID ids.ShortID, requestID uint32) error

+ func NewNoOpAncestorsHandler(log logging.Logger) AncestorsHandler

+ type AppHandler interface

+ AppGossip func(nodeID ids.ShortID, msg []byte) error

+ AppRequest func(nodeID ids.ShortID, requestID uint32, deadline time.Time, request []byte) error

+ AppRequestFailed func(nodeID ids.ShortID, requestID uint32) error

+ AppResponse func(nodeID ids.ShortID, requestID uint32, response []byte) error

+ func NewNoOpAppHandler(log logging.Logger) AppHandler

+ type AppSender interface

+ SendAppGossip func(appGossipBytes []byte) error

+ SendAppGossipSpecific func(nodeIDs ids.ShortSet, appGossipBytes []byte) error

+ SendAppRequest func(nodeIDs ids.ShortSet, requestID uint32, appRequestBytes []byte) error

+ SendAppResponse func(nodeID ids.ShortID, requestID uint32, appResponseBytes []byte) error

type Bootstrapable

+ Clear func() error

+ type BootstrapableEngine interface

type BootstrapableTest

+ CantClear bool

+ ClearF func() error

+ func (b *BootstrapableTest) Clear() error

type Bootstrapper

+ func NewCommonBootstrapper(config Config) Bootstrapper

+ Restart func(reset bool) error

+ type BootstrapperTest struct

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

+ type ChitsHandler interface

+ Chits func(validatorID ids.ShortID, requestID uint32, containerIDs []ids.ID) error

+ QueryFailed func(validatorID ids.ShortID, 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

+ StartupAlpha uint64

+ Subnet Subnet

+ Timer Timer

+ func (c *Config) IsBootstrapped() bool

type Engine

+ GetVM func() VM

+ Start func(startReqID uint32) error

type EngineTest

+ AncestorsF func(nodeID ids.ShortID, requestID uint32, containers [][]byte) error

+ AppGossipF func(nodeID ids.ShortID, msg []byte) error

+ AppRequestF func(nodeID ids.ShortID, requestID uint32, msg []byte) error

+ AppRequestFailedF func(nodeID ids.ShortID, requestID uint32) error

+ AppResponseF func(nodeID ids.ShortID, requestID uint32, msg []byte) error

+ CantAncestors bool

+ CantAppGossip bool

+ CantAppRequest bool

+ CantAppRequestFailed bool

+ CantAppResponse bool

+ CantConnected bool

+ CantDisconnected bool

+ CantGetAncestors bool

+ CantGetAncestorsFailed bool

+ CantGetVM bool

+ CantGossip bool

+ CantHalt bool

+ CantHealth bool

+ CantIsBootstrapped bool

+ CantStart bool

+ CantTimeout bool

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

+ DisconnectedF func(nodeID ids.ShortID) error

+ GetAncestorsF func(nodeID ids.ShortID, requestID uint32, containerID ids.ID) error

+ GetAncestorsFailedF func(nodeID ids.ShortID, requestID uint32) error

+ GetVMF func() VM

+ GossipF func() error

+ HaltF func()

+ HealthF func() (interface{}, error)

+ IsBootstrappedF func() bool

+ StartF func(startReqID uint32) error

+ TimeoutF func() error

+ func (e *EngineTest) Ancestors(nodeID ids.ShortID, requestID uint32, containers [][]byte) error

+ func (e *EngineTest) AppGossip(nodeID ids.ShortID, msg []byte) error

+ func (e *EngineTest) AppRequest(nodeID ids.ShortID, requestID uint32, deadline time.Time, request []byte) error

+ func (e *EngineTest) AppRequestFailed(nodeID ids.ShortID, requestID uint32) error

+ func (e *EngineTest) AppResponse(nodeID ids.ShortID, requestID uint32, response []byte) error

+ func (e *EngineTest) Connected(nodeID ids.ShortID, nodeVersion version.Application) error

+ func (e *EngineTest) Disconnected(nodeID ids.ShortID) error

+ func (e *EngineTest) GetAncestors(nodeID ids.ShortID, requestID uint32, containerID ids.ID) error

+ func (e *EngineTest) GetAncestorsFailed(nodeID ids.ShortID, requestID uint32) error

+ func (e *EngineTest) GetVM() VM

+ func (e *EngineTest) Gossip() error

+ func (e *EngineTest) Halt()

+ func (e *EngineTest) HealthCheck() (interface{}, error)

+ func (e *EngineTest) Start(startReqID uint32) error

+ func (e *EngineTest) Timeout() error

type FetchSender

+ SendAncestors func(nodeID ids.ShortID, requestID uint32, containers [][]byte)

+ SendGet func(nodeID ids.ShortID, requestID uint32, containerID ids.ID)

+ SendGetAncestors func(nodeID ids.ShortID, requestID uint32, containerID ids.ID)

+ SendPut func(nodeID ids.ShortID, requestID uint32, containerID ids.ID, container []byte)

+ type Fetcher struct

+ OnFinished func(lastReqID uint32) error

+ OutstandingRequests Requests

type FrontierSender

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

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

+ type GetAcceptedFrontierHandler interface

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

+ type GetAcceptedHandler interface

+ GetAccepted func(validatorID ids.ShortID, requestID uint32, containerIDs []ids.ID) error

+ type GetAncestorsHandler interface

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

+ type GetHandler interface

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

+ type Gossiper interface

+ SendGossip func(containerID ids.ID, container []byte)

+ type Haltable interface

+ Halt func()

+ Halted func() bool

+ type Halter struct

+ func (h *Halter) Halt()

+ func (h *Halter) Halted() bool

type InternalHandler

+ Gossip func() error

+ Halt func()

+ Timeout func() error

type Message

+ const StopVertex

+ type PutHandler interface

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

+ Put func(validatorID ids.ShortID, requestID uint32, container []byte) error

+ func NewNoOpPutHandler(log logging.Logger) PutHandler

type QueryHandler

+ func NewNoOpQueryHandler(log logging.Logger) QueryHandler

type QuerySender

+ SendChits func(nodeID ids.ShortID, requestID uint32, votes []ids.ID)

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

+ SendPushQuery func(nodeIDs ids.ShortSet, requestID uint32, containerID ids.ID, container []byte)

+ type Requests struct

+ func (r *Requests) Add(vdr ids.ShortID, requestID uint32, containerID ids.ID)

+ func (r *Requests) Contains(containerID ids.ID) bool

+ func (r *Requests) Len() int

+ func (r *Requests) Remove(vdr ids.ShortID, requestID uint32) (ids.ID, bool)

+ func (r *Requests) RemoveAny(containerID ids.ID) bool

+ func (r Requests) String() string

type SenderTest

+ CantSendAccepted bool

+ CantSendAcceptedFrontier bool

+ CantSendAncestors bool

+ CantSendAppGossip bool

+ CantSendAppGossipSpecific bool

+ CantSendAppRequest bool

+ CantSendAppResponse bool

+ CantSendChits bool

+ CantSendGet bool

+ CantSendGetAccepted bool

+ CantSendGetAcceptedFrontier bool

+ CantSendGetAncestors bool

+ CantSendGossip bool

+ CantSendPullQuery bool

+ CantSendPushQuery bool

+ CantSendPut bool

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

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

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

+ SendAppGossipF func([]byte) error

+ SendAppGossipSpecificF func(ids.ShortSet, []byte) error

+ SendAppRequestF func(ids.ShortSet, uint32, []byte) error

+ SendAppResponseF func(ids.ShortID, uint32, []byte) error

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

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

+ SendGetAcceptedFrontierF func(ids.ShortSet, uint32)

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

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

+ SendGossipF func(ids.ID, []byte)

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

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

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

+ func (s *SenderTest) SendAccepted(validatorID ids.ShortID, requestID uint32, containerIDs []ids.ID)

+ func (s *SenderTest) SendAcceptedFrontier(validatorID ids.ShortID, requestID uint32, containerIDs []ids.ID)

+ func (s *SenderTest) SendAncestors(vdr ids.ShortID, requestID uint32, vtxs [][]byte)

+ func (s *SenderTest) SendAppGossip(appGossipBytes []byte) error

+ func (s *SenderTest) SendAppGossipSpecific(nodeIDs ids.ShortSet, appGossipBytes []byte) error

+ func (s *SenderTest) SendAppRequest(nodeIDs ids.ShortSet, requestID uint32, appRequestBytes []byte) error

+ func (s *SenderTest) SendAppResponse(nodeID ids.ShortID, requestID uint32, appResponseBytes []byte) error

+ func (s *SenderTest) SendChits(vdr ids.ShortID, requestID uint32, votes []ids.ID)

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

+ func (s *SenderTest) SendGetAccepted(nodeIDs ids.ShortSet, requestID uint32, containerIDs []ids.ID)

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

+ func (s *SenderTest) SendGetAncestors(validatorID ids.ShortID, requestID uint32, vtxID ids.ID)

+ func (s *SenderTest) SendGossip(containerID ids.ID, container []byte)

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

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

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

+ type SharedConfig struct

+ RequestID uint32

+ Restarted bool

+ 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(nodeID ids.ShortID, msg []byte) error

+ AppRequestF func(nodeID ids.ShortID, requestID uint32, deadline time.Time, msg []byte) error

+ AppRequestFailedF func(nodeID ids.ShortID, requestID uint32) error

+ AppResponseF func(nodeID ids.ShortID, 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.ShortID, nodeVersion version.Application) error

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

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

+ DisconnectedF func(nodeID ids.ShortID) 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.ShortID, msg []byte) error

+ func (vm *TestVM) AppRequest(nodeID ids.ShortID, requestID uint32, deadline time.Time, request []byte) error

+ func (vm *TestVM) AppRequestFailed(nodeID ids.ShortID, requestID uint32) error

+ func (vm *TestVM) AppResponse(nodeID ids.ShortID, requestID uint32, response []byte) error

+ func (vm *TestVM) Connected(id ids.ShortID, 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.ShortID) error

+ func (vm *TestVM) HealthCheck() (interface{}, error)

+ func (vm *TestVM) Initialize(ctx *snow.Context, db manager.Manager, ...) error

+ func (vm *TestVM) SetState(state snow.State) error

+ func (vm *TestVM) Shutdown() error

+ func (vm *TestVM) Version() (string, error)

+ type Timer interface

+ RegisterTimeout func(time.Duration)

+ type TimerTest struct

+ CantRegisterTimout bool

+ RegisterTimeoutF func(time.Duration)

+ T *testing.T

+ func (t *TimerTest) Default(cant bool)

+ func (t *TimerTest) RegisterTimeout(delay time.Duration)

type VM

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

+ SetState func(state snow.State) error

+ Version func() (string, error)

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