The highest tagged major version is v2.

enginetest

package

v1.0.0-genesis Latest Latest Go to latest Published: Aug 2, 2025 License: BSD-3-Clause Imports: 5 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/luxfi/node

Links

Open Source Insights

Documentation ¶

Overview ¶

Package enginetest provides test utilities for consensus engines

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Engine ¶

type Engine struct {
	T common.Engine

	StartF               func(context.Context, uint32) error
	IsBootstrappedF      func() bool
	ContextF             func() interface{}
	StopF                func(context.Context) error
	NotifyF              func(context.Context, common.Message) error
	GetVMF               func() interface{}
	SetStateF            func(context.Context, interface{}) error
	HealthCheckF         func(context.Context) (interface{}, error)
	ConnectedF           func(context.Context, ids.NodeID, *version.Application) error
	DisconnectedF        func(context.Context, ids.NodeID) error
	GetAcceptedFrontierF func(context.Context, ids.NodeID, uint32) error
}

Engine is a test engine

func Default ¶

func Default() *Engine

Default returns a default test engine

func (*Engine) AppRequest ¶ added in v1.13.3

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

AppRequest implements common.AppHandler

func (*Engine) AppRequestFailed ¶ added in v1.13.3

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

AppRequestFailed implements common.AppHandler

func (*Engine) AppResponse ¶ added in v1.13.3

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

AppResponse implements common.AppHandler

func (*Engine) Connected ¶ added in v1.13.3

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

Connected implements common.Handler

func (*Engine) CrossChainAppRequest ¶

func (e *Engine) CrossChainAppRequest(ctx context.Context, chainID ids.ID, requestID uint32, deadline time.Time, msg []byte) error

CrossChainAppRequest implements common.AppHandler

func (*Engine) CrossChainAppRequestFailed ¶

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

CrossChainAppRequestFailed implements common.AppHandler

func (*Engine) CrossChainAppResponse ¶

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

CrossChainAppResponse implements common.AppHandler

func (*Engine) Disconnected ¶ added in v1.13.3

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

Disconnected implements common.Handler

func (*Engine) GetVM ¶

func (e *Engine) GetVM() interface{}

GetVM implements common.Engine

func (*Engine) HealthCheck ¶ added in v1.13.3

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

HealthCheck implements common.Handler

func (*Engine) Start ¶ added in v1.13.3

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

Start implements common.Engine

type Message ¶

type Message struct {
	InboundMessageF func() common.Message
	OnFinalizeF     func()
	OnDropF         func()
}

Message is a test message

func (*Message) InboundMessage ¶

func (m *Message) InboundMessage() common.Message

InboundMessage implements common.Message

func (*Message) OnDrop ¶

func (m *Message) OnDrop()

OnDrop implements common.Message

func (*Message) OnFinalize ¶

func (m *Message) OnFinalize()

OnFinalize implements common.Message

Source Files ¶

View all Source files

test.go

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