avalanche

package
v1.9.8-rc.6 Latest Latest
Warning

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

 Go to latest Published: Jan 17, 2023 License: BSD-3-Clause Imports: 23 Imported by: 10

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	Ctx *snow.ConsensusContext
	common.AllGetsServer
	VM         vertex.DAGVM
	Manager    vertex.Manager
	Sender     common.Sender
	Validators validators.Set

	Params    avalanche.Parameters
	Consensus avalanche.Consensus
}

Config wraps all the parameters needed for an avalanche engine

type Engine 

type Engine interface {
	common.Engine

	// GetVtx returns a vertex by its ID.
	// Returns an error if unknown.
	GetVtx(ctx context.Context, vtxID ids.ID) (avalanche.Vertex, error)
}

Engine describes the events that can occur on a consensus instance

func New added in v1.7.4 

func New(config Config) (Engine, error)

func TraceEngine added in v1.9.1 

func TraceEngine(engine Engine, tracer trace.Tracer) Engine

type EngineTest added in v1.7.5 

type EngineTest struct {
	common.EngineTest

	CantGetVtx bool
	GetVtxF    func(ctx context.Context, vtxID ids.ID) (avalanche.Vertex, error)
}

EngineTest is a test engine

func (*EngineTest) Default added in v1.7.5 

func (e *EngineTest) Default(cant bool)

func (*EngineTest) GetVtx added in v1.7.5 

func (e *EngineTest) GetVtx(ctx context.Context, vtxID ids.ID) (avalanche.Vertex, error)

type Transitive 

type Transitive struct {
	Config

	// list of NoOpsHandler for messages dropped by engine
	common.StateSummaryFrontierHandler
	common.AcceptedStateSummaryHandler
	common.AcceptedFrontierHandler
	common.AcceptedHandler
	common.AncestorsHandler

	RequestID uint32
	// contains filtered or unexported fields
}

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

func (*Transitive) AppGossip added in v1.5.3 

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

func (*Transitive) AppRequest added in v1.5.3 

func (t *Transitive) AppRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, deadline time.Time, request []byte) error

func (*Transitive) AppRequestFailed added in v1.5.3 

func (t *Transitive) AppRequestFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32) error

func (*Transitive) AppResponse added in v1.5.3 

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

func (*Transitive) Chits 

func (t *Transitive) Chits(ctx context.Context, nodeID ids.NodeID, requestID uint32, votes []ids.ID, accepted []ids.ID) error

func (*Transitive) Connected added in v1.7.4 

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

func (*Transitive) Context 

func (t *Transitive) Context() *snow.ConsensusContext

func (*Transitive) CrossChainAppRequest added in v1.9.1 

func (t *Transitive) CrossChainAppRequest(ctx context.Context, chainID ids.ID, requestID uint32, deadline time.Time, request []byte) error

func (*Transitive) CrossChainAppRequestFailed added in v1.9.1 

func (t *Transitive) CrossChainAppRequestFailed(ctx context.Context, chainID ids.ID, requestID uint32) error

func (*Transitive) CrossChainAppResponse added in v1.9.1 

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

func (*Transitive) Disconnected added in v1.7.4 

func (t *Transitive) Disconnected(ctx context.Context, nodeID ids.NodeID) error

func (*Transitive) GetFailed 

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

func (*Transitive) GetVM added in v1.3.2 

func (t *Transitive) GetVM() common.VM

func (*Transitive) GetVtx added in v1.3.2 

func (t *Transitive) GetVtx(ctx context.Context, vtxID ids.ID) (avalanche.Vertex, error)

func (*Transitive) Gossip added in v0.8.0 

func (t *Transitive) Gossip(ctx context.Context) error

func (*Transitive) Halt added in v1.7.4 

func (*Transitive) Halt(context.Context)

func (*Transitive) HealthCheck added in v1.2.1 

func (t *Transitive) HealthCheck(ctx context.Context) (interface{}, error)

func (*Transitive) Initialize 

func (m *Transitive) Initialize(namespace string, reg prometheus.Registerer) error

func (*Transitive) Notify 

func (t *Transitive) Notify(ctx context.Context, msg common.Message) error

func (*Transitive) PullQuery 

func (t *Transitive) PullQuery(ctx context.Context, nodeID ids.NodeID, requestID uint32, vtxID ids.ID) error

func (*Transitive) PushQuery 

func (t *Transitive) PushQuery(ctx context.Context, nodeID ids.NodeID, requestID uint32, vtxBytes []byte) error

func (*Transitive) Put 

func (t *Transitive) Put(ctx context.Context, nodeID ids.NodeID, requestID uint32, vtxBytes []byte) error

func (*Transitive) QueryFailed 

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

func (*Transitive) Shutdown 

func (t *Transitive) Shutdown(ctx context.Context) error

func (*Transitive) Start added in v1.7.4 

func (t *Transitive) Start(ctx context.Context, startReqID uint32) error

func (*Transitive) Timeout added in v1.7.4 

func (*Transitive) Timeout(context.Context) error

Source Files

View all Source files

Directories

Path Synopsis
Package state manages the meta-data required by consensus for an avalanche dag.
 Package state manages the meta-data required by consensus for an avalanche dag.
Package vertex is a generated GoMock package.
 Package vertex is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.