Help us shape the future of Go! Take the 2026 Go Developer Survey

linear

package
v1.14.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 25, 2025 License: BSD-3-Clause Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	core.AllGetsServer

	Ctx                 *consensus.Context
	VM                  block.ChainVM
	Sender              core.Sender
	Validators          validators.Manager
	ConnectedValidators tracker.Peers
	Params              sampling.Parameters
	Consensus           linear.Consensus
	PartialSync         bool
}

Config wraps all the parameters needed for a linear engine

type Engine

type Engine struct {
	Config

	// list of NoOpsHandler for messages dropped by engine
	core.StateSummaryFrontierHandler
	core.AcceptedStateSummaryHandler
	core.AcceptedFrontierHandler
	core.AcceptedHandler
	core.AncestorsHandler
	core.AppHandler
	validators.Connector
	// contains filtered or unexported fields
}

Engine implements the Engine interface by attempting to fetch all Engine dependencies.

func New

func New(config Config) (*Engine, error)

func (*Engine) Chits

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

func (*Engine) Context

func (e *Engine) Context() *consensus.Context

func (*Engine) GetFailed

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

func (*Engine) Gossip

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

func (*Engine) HealthCheck

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

func (*Engine) Notify

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

func (*Engine) PullQuery

func (e *Engine) PullQuery(ctx context.Context, nodeID ids.NodeID, requestID uint32, blkID ids.ID, requestedHeight uint64) error

func (*Engine) PushQuery

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

func (*Engine) Put

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

func (*Engine) QueryFailed

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

func (*Engine) Shutdown

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

func (*Engine) Start

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

Directories

Path Synopsis
blockmock
Package blockmock is a generated GoMock package.
Package blockmock is a generated GoMock package.
Package job provides a Scheduler to manage and execute Jobs with dependencies.
Package job provides a Scheduler to manage and execute Jobs with dependencies.

Jump to

Keyboard shortcuts

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