common

package

Go to main page

Versions in this module

v1

v1.20.1

Oct 29, 2025

v1.20.0

Oct 28, 2025

v1.18.6

Sep 26, 2025

v1.18.5

Sep 26, 2025

v1.18.4

Sep 26, 2025

v1.18.3

Sep 26, 2025

v1.18.2

Sep 26, 2025

v1.18.1-qos

Sep 26, 2025

v1.13.6

Jul 18, 2025

v1.13.6-lux

Jul 31, 2025

v1.13.5

Jul 18, 2025

v1.13.5-lux

Jul 31, 2025

v1.13.5-alpha

Aug 23, 2025

v1.13.4

Jul 18, 2025

v1.13.4-lux.25

Aug 19, 2025

v1.13.4-lux.20

Aug 18, 2025

v1.13.4-lux.17

Aug 13, 2025

v1.13.4-lux

Jul 31, 2025

v1.13.3

Jul 18, 2025

Changes in this version

+ func NewTimeoutScheduler(onTimeout func(), preemptionSignal <-chan struct{}) *timeoutScheduler

type AppSender

+ SendAppError func(ctx context.Context, nodeID ids.NodeID, requestID uint32, errorCode int32, ...) error

+ SendAppGossip func(ctx context.Context, config SendConfig, 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 BootstrapTracker

+ AllBootstrapped func() <-chan struct{}

+ type NotificationForwarder struct

+ Engine Notifier

+ Log logging.Logger

+ Subscribe Subscription

+ func NewNotificationForwarder(engine Notifier, subscribe Subscription, log logging.Logger) *NotificationForwarder

+ func (nf *NotificationForwarder) CheckForEvent()

+ func (nf *NotificationForwarder) Close()

+ type Notifier interface

+ Notify func(context.Context, Message) error

+ type PreemptionSignal struct

+ func (ps *PreemptionSignal) Listen() <-chan struct{}

+ func (ps *PreemptionSignal) Preempt()

+ type Subscription func(ctx context.Context) (Message, error)

+ type TimeoutRegistrar interface

+ RegisterTimeout func(time.Duration)

type VM

+ NewHTTPHandler func(ctx context.Context) (http.Handler, error)

+ WaitForEvent func(ctx context.Context) (Message, error)

v1.13.3-lux-latest

Jul 30, 2025

v1.11.14

Aug 18, 2025

Changes in this version

type Engine

+ Shutdown func(ctx context.Context) error

v1.11.10

Jul 13, 2024

Changes in this version

+ var ErrTimeout = &AppError

+ var ErrUndefined = &AppError

+ type AcceptedFrontierHandler interface

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

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

+ func NewNoOpAcceptedFrontierHandler(log logging.Logger) AcceptedFrontierHandler

type AcceptedHandler

+ func NewNoOpAcceptedHandler(log logging.Logger) AcceptedHandler

type AcceptedSender

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

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

+ type AcceptedStateSummaryHandler interface

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

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

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

+ func NewNoOpAncestorsHandler(log logging.Logger) AncestorsHandler

+ type AppError struct

+ Code int32

+ Message string

+ func (a *AppError) Error() string

+ func (a *AppError) Is(target error) bool

+ type AppGossipHandler interface

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

+ type AppHandler interface

+ func NewNoOpAppHandler(log logging.Logger) AppHandler

+ type AppRequestHandler interface

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

+ type AppResponseHandler interface

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

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

+ type AppSender interface

+ type BootstrapTracker interface

+ Bootstrapped func(chainID ids.ID)

+ IsBootstrapped func() bool

+ OnBootstrapCompleted func() chan struct{}

+ type BootstrapableEngine interface

+ Clear func(ctx context.Context) error

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

+ type ChitsHandler interface

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

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

+ func NewNoOpChitsHandler(log logging.Logger) ChitsHandler

+ type CrossChainAppHandler interface

+ type CrossChainAppRequestHandler interface

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

+ type CrossChainAppResponseHandler interface

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

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

+ type CrossChainAppSender interface

+ SendCrossChainAppError func(ctx context.Context, chainID ids.ID, requestID uint32, errorCode int32, ...) error

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

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

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

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

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

type FrontierSender

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

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

+ type GetAcceptedFrontierHandler interface

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

+ type GetAcceptedHandler interface

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

+ type GetAcceptedStateSummaryHandler interface

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

+ type GetAncestorsHandler interface

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

+ type GetHandler interface

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

+ type GetStateSummaryFrontierHandler interface

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

+ type Haltable interface

+ Halt func(context.Context)

+ Halted func() bool

+ type Halter struct

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

+ func (h *Halter) Halted() bool

type InternalHandler

+ func NewNoOpInternalHandler(log logging.Logger) InternalHandler

+ Gossip func(context.Context) error

+ Halt func(context.Context)

+ Timeout func(context.Context) error

type Message

+ const StateSyncDone

+ type MockSender struct

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

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

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

+ func (m *MockSender) SendAcceptedFrontier(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID)

+ func (m *MockSender) SendAcceptedStateSummary(ctx context.Context, nodeID ids.NodeID, requestID uint32, summaryIDs []ids.ID)

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

+ func (m *MockSender) SendAppError(ctx context.Context, nodeID ids.NodeID, requestID uint32, errorCode int32, ...) error

+ func (m *MockSender) SendAppGossip(ctx context.Context, config SendConfig, appGossipBytes []byte) error

+ func (m *MockSender) SendAppRequest(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...) error

+ func (m *MockSender) SendAppResponse(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) error

+ func (m *MockSender) SendChits(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...)

+ func (m *MockSender) SendCrossChainAppError(ctx context.Context, chainID ids.ID, requestID uint32, errorCode int32, ...) error

+ func (m *MockSender) SendCrossChainAppRequest(ctx context.Context, chainID ids.ID, requestID uint32, appRequestBytes []byte) error

+ func (m *MockSender) SendCrossChainAppResponse(ctx context.Context, chainID ids.ID, requestID uint32, appResponseBytes []byte) error

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

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

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

+ func (m *MockSender) SendGetAcceptedStateSummary(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...)

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

+ func (m *MockSender) SendGetStateSummaryFrontier(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32)

+ func (m *MockSender) SendPullQuery(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...)

+ func (m *MockSender) SendPushQuery(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...)

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

+ func (m *MockSender) SendStateSummaryFrontier(ctx context.Context, nodeID ids.NodeID, requestID uint32, summary []byte)

+ type MockSenderMockRecorder struct

+ func (mr *MockSenderMockRecorder) SendAccepted(ctx, nodeID, requestID, containerIDs any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendAcceptedFrontier(ctx, nodeID, requestID, containerID any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendAcceptedStateSummary(ctx, nodeID, requestID, summaryIDs any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendAncestors(ctx, nodeID, requestID, containers any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendAppError(ctx, nodeID, requestID, errorCode, errorMessage any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendAppGossip(ctx, config, appGossipBytes any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendAppRequest(ctx, nodeIDs, requestID, appRequestBytes any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendAppResponse(ctx, nodeID, requestID, appResponseBytes any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendChits(ctx, nodeID, requestID, preferredID, preferredIDAtHeight, acceptedID any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendCrossChainAppError(ctx, chainID, requestID, errorCode, errorMessage any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendCrossChainAppRequest(ctx, chainID, requestID, appRequestBytes any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendCrossChainAppResponse(ctx, chainID, requestID, appResponseBytes any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendGet(ctx, nodeID, requestID, containerID any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendGetAccepted(ctx, nodeIDs, requestID, containerIDs any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendGetAcceptedFrontier(ctx, nodeIDs, requestID any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendGetAcceptedStateSummary(ctx, nodeIDs, requestID, heights any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendGetAncestors(ctx, nodeID, requestID, containerID any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendGetStateSummaryFrontier(ctx, nodeIDs, requestID any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendPullQuery(ctx, nodeIDs, requestID, containerID, requestedHeight any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendPushQuery(ctx, nodeIDs, requestID, container, requestedHeight any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendPut(ctx, nodeID, requestID, container any) *gomock.Call

+ func (mr *MockSenderMockRecorder) SendStateSummaryFrontier(ctx, nodeID, requestID, summary any) *gomock.Call

+ type NetworkAppHandler interface

+ type NetworkAppSender interface

+ SendAppError func(ctx context.Context, nodeID ids.NodeID, requestID uint32, errorCode int32, ...) error

+ SendAppGossip func(ctx context.Context, config SendConfig, 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, nodeID ids.NodeID, requestID uint32) error

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

+ func NewNoOpPutHandler(log logging.Logger) PutHandler

type QueryHandler

+ func NewNoOpQueryHandler(log logging.Logger) QueryHandler

type QuerySender

+ SendChits func(ctx context.Context, nodeID ids.NodeID, requestID uint32, preferredID 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 Request struct

+ NodeID ids.NodeID

+ RequestID uint32

+ func (r Request) MarshalText() ([]byte, error)

+ type SendConfig struct

+ NodeIDs set.Set[ids.NodeID]

+ NonValidators int

+ Peers int

+ Validators int

+ type StateSummaryFrontierHandler interface

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

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

+ RegisterTimeout func(time.Duration)

type VM

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

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

v1.0.0-genesis

Aug 2, 2025

v0

v0.7.8-lux.11

Aug 18, 2025

v0.1.1

Jul 30, 2025

Changes in this version

+ type Block interface

+ Bytes func() []byte

+ Height func() uint64

+ Parent func() ids.ID

+ Timestamp func() uint64

+ Verify func() error

+ type Decidable interface

+ Accept func() error

+ ID func() ids.ID

+ Reject func() error

+ Status func() choices.Status

type Engine

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

+ Start func(uint64) error

+ Stop func() error

+ type EngineState uint32

+ const Bootstrapping

+ const Initializing

+ const NormalOp

+ const Stopped

+ func (s EngineState) String() string

type Handler

+ GetState func() EngineState

+ SetState func(EngineState) error

type Sender

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

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

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

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

+ SendGetAccepted func(nodeID ids.NodeID, requestID uint32, containerIDs []ids.ID)

+ SendGetAcceptedFrontier func(nodeID ids.NodeID, requestID uint32)

+ SendPullQuery func(nodeIDs []ids.NodeID, requestID uint32, containerID ids.ID)

+ SendPushQuery func(nodeIDs []ids.NodeID, requestID uint32, container []byte)

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

+ type Vertex interface

+ Bytes func() []byte

+ Epoch func() uint32

+ Height func() uint64

+ Parents func() []ids.ID

+ Verify func() error

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

v0.1.0-lux.17

Aug 17, 2025

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