avalanche

Jul 28, 2022

Changes in this version

type Config

+ Ctx *snow.ConsensusContext

+ Manager vertex.Manager

+ Sender common.Sender

+ VM vertex.DAGVM

+ Validators validators.Set

type Engine

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

+ GetVtx func(vtxID ids.ID) (avalanche.Vertex, error)

+ type EngineTest struct

+ CantGetVtx bool

+ GetVtxF func(vtxID ids.ID) (avalanche.Vertex, error)

+ func (e *EngineTest) Default(cant bool)

+ func (e *EngineTest) GetVtx(vtxID ids.ID) (avalanche.Vertex, error)

type Transitive

+ RequestID uint32

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

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

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

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

+ func (t *Transitive) ChitsV2(nodeID ids.NodeID, requestID uint32, votes []ids.ID, _ ids.ID) error

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

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

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

+ func (t *Transitive) GetVtx(vtxID ids.ID) (avalanche.Vertex, error)

+ func (t *Transitive) Gossip() error

+ func (t *Transitive) Halt()

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

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

+ func (t *Transitive) Timeout() error

Apr 19, 2020

Changes in this version

+ type BootstrapConfig struct

+ State State

+ TxBlocked *queue.Jobs

+ VM DAGVM

+ VtxBlocked *queue.Jobs

+ type Config struct

+ Consensus avalanche.Consensus

+ Params avalanche.Parameters

+ type DAGVM interface

+ GetTx func(ids.ID) (snowstorm.Tx, error)

+ ParseTx func(tx []byte) (snowstorm.Tx, error)

+ PendingTxs func() []snowstorm.Tx

+ type Engine interface

+ Initialize func(Config)

+ type State interface

+ BuildVertex func(parentIDs ids.Set, txs []snowstorm.Tx) (avalanche.Vertex, error)

+ Edge func() (vtxIDs []ids.ID)

+ GetVertex func(vtxID ids.ID) (avalanche.Vertex, error)

+ ParseVertex func(vertex []byte) (avalanche.Vertex, error)

+ type Transitive struct

+ func (b *Transitive) CurrentAcceptedFrontier() ids.Set

+ func (b *Transitive) FilterAccepted(containerIDs ids.Set) ids.Set

+ func (b *Transitive) ForceAccepted(acceptedContainerIDs ids.Set)

+ func (t *Transitive) Chits(vdr ids.ShortID, requestID uint32, votes ids.Set)

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

+ func (t *Transitive) Get(vdr ids.ShortID, requestID uint32, vtxID ids.ID)

+ func (t *Transitive) GetFailed(vdr ids.ShortID, requestID uint32, vtxID ids.ID)

+ func (t *Transitive) Initialize(config Config)

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

+ func (t *Transitive) PullQuery(vdr ids.ShortID, requestID uint32, vtxID ids.ID)

+ func (t *Transitive) PushQuery(vdr ids.ShortID, requestID uint32, vtxID ids.ID, vtx []byte)

+ func (t *Transitive) Put(vdr ids.ShortID, requestID uint32, vtxID ids.ID, vtxBytes []byte)

+ func (t *Transitive) QueryFailed(vdr ids.ShortID, requestID uint32)

+ func (t *Transitive) Shutdown()

+ type VMTest struct

+ CantGetTx bool

+ CantIssueTx bool

+ CantParseTx bool

+ CantPendingTxs bool

+ GetTxF func(ids.ID) (snowstorm.Tx, error)

+ IssueTxF func([]byte, func(choices.Status), func(choices.Status)) (ids.ID, error)

+ ParseTxF func([]byte) (snowstorm.Tx, error)

+ PendingTxsF func() []snowstorm.Tx

+ func (vm *VMTest) Default(cant bool)

+ func (vm *VMTest) GetTx(txID ids.ID) (snowstorm.Tx, error)

+ func (vm *VMTest) IssueTx(b []byte, issued, finalized func(choices.Status)) (ids.ID, error)

+ func (vm *VMTest) ParseTx(b []byte) (snowstorm.Tx, error)

+ func (vm *VMTest) PendingTxs() []snowstorm.Tx