linear

package
v1.13.21 Latest Latest
Warning

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

Go to latest
Published: Jul 24, 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