snowman

package
v1.7.13-rc.5 Latest Latest
Warning

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

Go to latest
Published: Aug 1, 2022 License: BSD-3-Clause Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AncestorTree added in v1.7.16

type AncestorTree interface {
	Add(blkID ids.ID, parentID ids.ID)
	Has(blkID ids.ID) bool
	GetRoot(blkID ids.ID) ids.ID
	Remove(blkID ids.ID)
	RemoveSubtree(blkID ids.ID)
	Len() int
}

func NewAncestorTree added in v1.7.16

func NewAncestorTree() AncestorTree

type Config

type Config struct {
	common.AllGetsServer

	Ctx        *snow.ConsensusContext
	VM         block.ChainVM
	Sender     common.Sender
	Validators validators.Set
	Params     snowball.Parameters
	Consensus  snowman.Consensus
}

Config wraps all the parameters needed for a snowman engine

type Engine

type Engine interface {
	common.Engine
	block.Getter
}

Engine describes the events that can occur to a Snowman instance.

The engine is used to fetch, order, and decide on the fate of blocks. This engine runs the leaderless version of the Snowman consensus protocol. Therefore, the liveness of this protocol tolerant to O(sqrt(n)) Byzantine Nodes where n is the number of nodes in the network. Therefore, this protocol should only be run in a Crash Fault Tolerant environment, or in an environment where lose of liveness and manual intervention is tolerable.

func New added in v1.7.16

func New(config Config) (Engine, error)

type EngineTest added in v1.7.16

type EngineTest struct {
	common.EngineTest

	CantGetBlock bool
	GetBlockF    func(ids.ID) (snowman.Block, error)
}

EngineTest is a test engine

func (*EngineTest) Default added in v1.7.16

func (e *EngineTest) Default(cant bool)

func (*EngineTest) GetBlock added in v1.7.16

func (e *EngineTest) GetBlock(blkID ids.ID) (snowman.Block, 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.7.16

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

func (*Transitive) AppRequest added in v1.7.16

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

func (*Transitive) AppRequestFailed added in v1.7.16

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

func (*Transitive) AppResponse added in v1.7.16

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

func (*Transitive) Chits

func (t *Transitive) Chits(vdr ids.NodeID, requestID uint32, votes []ids.ID) error

func (*Transitive) Connected added in v1.7.16

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

func (*Transitive) Context

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

func (*Transitive) Disconnected added in v1.7.16

func (t *Transitive) Disconnected(nodeID ids.NodeID) error

func (*Transitive) GetBlock added in v1.7.16

func (t *Transitive) GetBlock(blkID ids.ID) (snowman.Block, error)

func (*Transitive) GetFailed

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

func (*Transitive) GetVM added in v1.7.16

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

func (*Transitive) Gossip added in v1.7.16

func (t *Transitive) Gossip() error

func (*Transitive) Halt added in v1.7.16

func (t *Transitive) Halt()

func (*Transitive) HealthCheck added in v1.7.16

func (t *Transitive) HealthCheck() (interface{}, error)

func (*Transitive) Initialize

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

Initialize the metrics

func (*Transitive) Notify

func (t *Transitive) Notify(msg common.Message) error

func (*Transitive) PullQuery

func (t *Transitive) PullQuery(nodeID ids.NodeID, requestID uint32, blkID ids.ID) error

func (*Transitive) PushQuery

func (t *Transitive) PushQuery(vdr ids.NodeID, requestID uint32, blkBytes []byte) error

func (*Transitive) Put

func (t *Transitive) Put(nodeID ids.NodeID, requestID uint32, blkBytes []byte) error

func (*Transitive) QueryFailed

func (t *Transitive) QueryFailed(vdr ids.NodeID, requestID uint32) error

func (*Transitive) Shutdown

func (t *Transitive) Shutdown() error

func (*Transitive) Start added in v1.7.16

func (t *Transitive) Start(startReqID uint32) error

func (*Transitive) Timeout added in v1.7.16

func (t *Transitive) Timeout() error

Directories

Path Synopsis
mocks
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

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