common

package

Go to main page

Versions in this module

v0

v0.7.0

Aug 30, 2020

v0.6.4

Aug 24, 2020

v0.6.2

Aug 21, 2020

v0.6.1

Aug 20, 2020

Changes in this version

type Config

+ Ctx *snow.Context

+ func (c *Config) IsBootstrapped() bool

type Engine

+ IsBootstrapped func() bool

type EngineTest

+ CantIsBootstrapped bool

+ IsBootstrappedF func() bool

+ func (e *EngineTest) IsBootstrapped() bool

+ type Fetcher struct

+ NumFetched uint32

+ OnFinished func() error

+ OutstandingRequests Requests

+ type TestVM struct

+ BootstrappedF func() error

+ BootstrappingF func() error

+ CantBootstrapped bool

+ CantBootstrapping bool

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

+ T *testing.T

+ func (vm *TestVM) Bootstrapped() error

+ func (vm *TestVM) Bootstrapping() error

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

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

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

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

+ func (vm *TestVM) Shutdown() error

v0.6.1-rc.2

Aug 20, 2020

v0.6.1-rc.1

Aug 20, 2020

v0.5.7

Jun 24, 2020

Changes in this version

+ const MaxOutstandingRequests

v0.5.5

Jun 10, 2020

v0.5.4

Jun 9, 2020

v0.5.3

Jun 8, 2020

Changes in this version

+ const MaxContainersPerMultiPut

+ const StatusUpdateFrequency

+ var MaxTimeFetchingAncestors = 100 * time.Millisecond

type EngineTest

+ CantGetAncestors bool

+ CantGetAncestorsFailed bool

+ CantMultiPut bool

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

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

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

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

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

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

type FetchHandler

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

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

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

type FetchSender

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

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

type SenderTest

+ CantGetAncestors bool

+ CantMultiPut bool

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

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

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

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

type VM

+ Bootstrapped func() error

+ Bootstrapping func() error

type VMTest

+ BootstrappedF func() error

+ BootstrappingF func() error

+ CantBootstrapped bool

+ CantBootstrapping bool

+ func (vm *VMTest) Bootstrapped() error

+ func (vm *VMTest) Bootstrapping() error

v0.5.0

May 31, 2020

Changes in this version

type EngineTest

+ CantGossip bool

+ GossipF func() error

+ func (e *EngineTest) Gossip() error

+ type Gossiper interface

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

type InternalHandler

+ Gossip func() error

+ 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

type SenderTest

+ CantGossip bool

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

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

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