Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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

enginetest

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.5

Jul 18, 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.3

Jul 18, 2025

Changes in this version

+ type BootstrapTracker struct

+ BootstrappedF func(ids.ID)

+ CantBootstrapped bool

+ CantIsBootstrapped bool

+ CantOnBootstrapCompleted bool

+ IsBootstrappedF func() bool

+ OnBootstrapCompletedF func() chan struct{}

+ T *testing.T

+ func (s *BootstrapTracker) AllBootstrapped() <-chan struct{}

+ func (s *BootstrapTracker) Bootstrapped(chainID ids.ID)

+ func (s *BootstrapTracker) Default(cant bool)

+ func (s *BootstrapTracker) IsBootstrapped() bool

+ type Bootstrapper struct

+ CantClear bool

+ ClearF func(ctx context.Context) error

+ func (b *Bootstrapper) Clear(ctx context.Context) error

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

type Engine

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

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

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

+ 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, preferredID ids.ID, ...) error

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

+ ContextF func() *snow.ConsensusContext

+ 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 set.Set[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() common.VM

+ GossipF func(context.Context) error

+ HaltF func(context.Context)

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

+ IsBootstrappedF func() bool

+ NotifyF func(context.Context, common.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

+ TimeoutF func(context.Context) error

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

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

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

+ func (e *Engine) Ancestors(ctx context.Context, nodeID ids.NodeID, requestID uint32, containers [][]byte) error

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (e *Engine) Gossip(ctx context.Context) error

+ func (e *Engine) HealthCheck(ctx context.Context) (interface{}, error)

+ func (e *Engine) Notify(ctx context.Context, msg common.Message) error

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

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

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

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

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

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

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

+ type Sender struct

+ CantSendAccepted bool

+ CantSendAcceptedFrontier bool

+ CantSendAcceptedStateSummary bool

+ CantSendAncestors bool

+ CantSendAppError bool

+ CantSendAppGossip bool

+ CantSendAppRequest bool

+ CantSendAppResponse bool

+ CantSendChits bool

+ CantSendGet bool

+ CantSendGetAccepted bool

+ CantSendGetAcceptedFrontier bool

+ CantSendGetAcceptedStateSummary bool

+ CantSendGetAncestors bool

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

+ SendAppErrorF func(context.Context, ids.NodeID, uint32, int32, string) error

+ SendAppGossipF func(context.Context, common.SendConfig, []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, ids.ID, ids.ID, uint64)

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

+ SendPullQueryF func(context.Context, set.Set[ids.NodeID], uint32, ids.ID, uint64)

+ SendPushQueryF func(context.Context, set.Set[ids.NodeID], uint32, []byte, uint64)

+ SendPutF func(context.Context, ids.NodeID, uint32, []byte)

+ SendStateSummaryFrontierF func(context.Context, ids.NodeID, uint32, []byte)

+ T *testing.T

+ func (s *Sender) Default(cant bool)

+ func (s *Sender) SendAccepted(ctx context.Context, validatorID ids.NodeID, requestID uint32, ...)

+ func (s *Sender) SendAcceptedFrontier(ctx context.Context, validatorID ids.NodeID, requestID uint32, ...)

+ func (s *Sender) SendAcceptedStateSummary(ctx context.Context, validatorID ids.NodeID, requestID uint32, ...)

+ func (s *Sender) SendAncestors(ctx context.Context, vdr ids.NodeID, requestID uint32, containers [][]byte)

+ func (s *Sender) SendAppError(ctx context.Context, nodeID ids.NodeID, requestID uint32, code int32, ...) error

+ func (s *Sender) SendAppGossip(ctx context.Context, config common.SendConfig, appGossipBytes []byte) error

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

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

+ func (s *Sender) SendChits(ctx context.Context, vdr ids.NodeID, requestID uint32, preferredID ids.ID, ...)

+ func (s *Sender) SendGet(ctx context.Context, vdr ids.NodeID, requestID uint32, containerID ids.ID)

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

+ func (s *Sender) SendGetAcceptedFrontier(ctx context.Context, validatorIDs set.Set[ids.NodeID], requestID uint32)

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

+ func (s *Sender) SendGetAncestors(ctx context.Context, validatorID ids.NodeID, requestID uint32, ...)

+ func (s *Sender) SendGetStateSummaryFrontier(ctx context.Context, validatorIDs set.Set[ids.NodeID], requestID uint32)

+ func (s *Sender) SendPullQuery(ctx context.Context, vdrs set.Set[ids.NodeID], requestID uint32, ...)

+ func (s *Sender) SendPushQuery(ctx context.Context, vdrs set.Set[ids.NodeID], requestID uint32, ...)

+ func (s *Sender) SendPut(ctx context.Context, vdr ids.NodeID, requestID uint32, container []byte)

+ func (s *Sender) SendStateSummaryFrontier(ctx context.Context, validatorID ids.NodeID, requestID uint32, summary []byte)

+ type SenderStub struct

+ SentAppError chan *common.AppError

+ SentAppGossip chan []byte

+ SentAppRequest chan []byte

+ SentAppResponse chan []byte

+ func (f SenderStub) SendAppError(_ context.Context, _ ids.NodeID, _ uint32, errorCode int32, ...) error

+ func (f SenderStub) SendAppGossip(_ context.Context, _ common.SendConfig, bytes []byte) error

+ func (f SenderStub) SendAppRequest(_ context.Context, _ set.Set[ids.NodeID], _ uint32, bytes []byte) error

+ func (f SenderStub) SendAppResponse(_ context.Context, _ ids.NodeID, _ uint32, bytes []byte) error

+ type Timer struct

+ CantRegisterTimout bool

+ RegisterTimeoutF func(time.Duration)

+ T *testing.T

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

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

+ CantDisconnected bool

+ CantHealthCheck bool

+ CantInitialize bool

+ CantNewHTTPHandler 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]http.Handler, 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 database.Database, ...) error

+ NewHTTPHandlerF func(context.Context) (http.Handler, error)

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

+ ShutdownF func(context.Context) error

+ T *testing.T

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

+ WaitForEventF common.Subscription

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

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

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

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

+ func (vm *VM) Connected(ctx context.Context, id ids.NodeID, nodeVersion *version.Application) error

+ func (vm *VM) CreateHandlers(ctx context.Context) (map[string]http.Handler, error)

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

+ func (vm *VM) Disconnected(ctx context.Context, id ids.NodeID) error

+ func (vm *VM) HealthCheck(ctx context.Context) (interface{}, error)

+ func (vm *VM) Initialize(ctx context.Context, chainCtx *snow.Context, db database.Database, ...) error

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

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

+ func (vm *VM) Shutdown(ctx context.Context) error

+ func (vm *VM) Version(ctx context.Context) (string, error)

+ func (vm *VM) WaitForEvent(ctx context.Context) (common.Message, error)

v1.11.14

Aug 18, 2025

Changes in this version

+ type Engine struct

+ T *testing.T

+ func NewEngine(t *testing.T) *Engine

v1.0.0-genesis

Aug 2, 2025

v0

v0.7.8-lux.11

Aug 18, 2025

v0.1.0-lux.17

Aug 17, 2025