Documentation ¶
Index ¶
- type Config
- type Engine
- type EngineTest
- type Transitive
- 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) Chits(nodeID ids.NodeID, requestID uint32, votes []ids.ID) 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) Context() *snow.ConsensusContext
- func (t *Transitive) Disconnected(nodeID ids.NodeID) error
- func (t *Transitive) GetFailed(nodeID ids.NodeID, requestID uint32) 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 (m *Transitive) Initialize(namespace string, reg prometheus.Registerer) error
- func (t *Transitive) Notify(msg common.Message) error
- func (t *Transitive) PullQuery(nodeID ids.NodeID, requestID uint32, vtxID ids.ID) error
- func (t *Transitive) PushQuery(nodeID ids.NodeID, requestID uint32, vtxBytes []byte) error
- func (t *Transitive) Put(nodeID ids.NodeID, requestID uint32, vtxBytes []byte) error
- func (t *Transitive) QueryFailed(nodeID ids.NodeID, requestID uint32) error
- func (t *Transitive) Shutdown() error
- func (t *Transitive) Start(startReqID uint32) error
- func (t *Transitive) Timeout() error
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(vtxID ids.ID) (avalanche.Vertex, error) }
Engine describes the events that can occur on a consensus instance
type EngineTest ¶ added in v1.7.16
type EngineTest struct { common.EngineTest CantGetVtx bool GetVtxF func(vtxID ids.ID) (avalanche.Vertex, error) }
EngineTest is a test engine
func (*EngineTest) Default ¶ added in v1.7.16
func (e *EngineTest) Default(cant bool)
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 (*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 (*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) 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
func (*Transitive) QueryFailed ¶
func (t *Transitive) QueryFailed(nodeID 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
Source Files ¶
Click to show internal directories.
Click to hide internal directories.