Documentation
¶
Overview ¶
Package dag provides DAG consensus functionality
Package dag implements consensus for Directed Acyclic Graphs.
DAG handles parallel transactions with causal dependencies, where vertices can reference multiple parents. The consensus pipeline flows: photon → wave → focus → (prism + horizon) → flare → nebula. This enables concurrent transaction processing while respecting causality.
Index ¶
- type DAGConsensus
- func (d *DAGConsensus) AddVertex(ctx context.Context, vertex *Vertex) error
- func (d *DAGConsensus) Frontier() []ids.ID
- func (d *DAGConsensus) GetConflicting(ctx context.Context, vertex *Vertex) []*Vertex
- func (d *DAGConsensus) GetVertex(vertexID ids.ID) (*Vertex, bool)
- func (d *DAGConsensus) IsAccepted(vertexID ids.ID) bool
- func (d *DAGConsensus) IsRejected(vertexID ids.ID) bool
- func (d *DAGConsensus) Poll(ctx context.Context, responses map[ids.ID]int) error
- func (d *DAGConsensus) Preference() ids.ID
- func (d *DAGConsensus) ProcessVote(ctx context.Context, vertexID ids.ID, accept bool) error
- func (d *DAGConsensus) ResolveConflict(ctx context.Context, vertices []*Vertex) (*Vertex, error)
- func (d *DAGConsensus) Stats() map[string]interface{}
- type Engine
- type Transaction
- type Tx
- type Vertex
- func (v *Vertex) Accept(ctx context.Context) error
- func (v *Vertex) AddChild(child *Vertex)
- func (v *Vertex) AddParent(parent *Vertex)
- func (v *Vertex) Bytes() []byte
- func (v *Vertex) Children() []*Vertex
- func (v *Vertex) Height() uint64
- func (v *Vertex) ID() ids.ID
- func (v *Vertex) IsAccepted() bool
- func (v *Vertex) IsProcessing() bool
- func (v *Vertex) IsRejected() bool
- func (v *Vertex) LuxConsensus() *engine.LuxConsensus
- func (v *Vertex) Parent() ids.ID
- func (v *Vertex) ParentIDs() []ids.ID
- func (v *Vertex) Parents() []*Vertex
- func (v *Vertex) Reject(ctx context.Context) error
- func (v *Vertex) SetLuxConsensus(lc *engine.LuxConsensus)
- func (v *Vertex) SetProcessing(processing bool)
- func (v *Vertex) Verify(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DAGConsensus ¶ added in v1.21.3
type DAGConsensus struct {
// contains filtered or unexported fields
}
DAGConsensus implements real Lux consensus for DAG structures using Photon → Wave → Prism
func NewDAGConsensus ¶ added in v1.21.3
func NewDAGConsensus(k, alpha, beta int) *DAGConsensus
NewDAGConsensus creates a real consensus engine for DAG
func (*DAGConsensus) AddVertex ¶ added in v1.21.3
func (d *DAGConsensus) AddVertex(ctx context.Context, vertex *Vertex) error
AddVertex adds a vertex to the DAG
func (*DAGConsensus) Frontier ¶ added in v1.21.3
func (d *DAGConsensus) Frontier() []ids.ID
Frontier returns the current frontier vertices
func (*DAGConsensus) GetConflicting ¶ added in v1.21.3
func (d *DAGConsensus) GetConflicting(ctx context.Context, vertex *Vertex) []*Vertex
GetConflicting returns vertices that conflict with the given vertex
func (*DAGConsensus) GetVertex ¶ added in v1.21.3
func (d *DAGConsensus) GetVertex(vertexID ids.ID) (*Vertex, bool)
GetVertex returns a vertex by ID
func (*DAGConsensus) IsAccepted ¶ added in v1.21.3
func (d *DAGConsensus) IsAccepted(vertexID ids.ID) bool
IsAccepted checks if a vertex is accepted
func (*DAGConsensus) IsRejected ¶ added in v1.21.3
func (d *DAGConsensus) IsRejected(vertexID ids.ID) bool
IsRejected checks if a vertex is rejected
func (*DAGConsensus) Preference ¶ added in v1.21.3
func (d *DAGConsensus) Preference() ids.ID
Preference returns current preferred vertex
func (*DAGConsensus) ProcessVote ¶ added in v1.21.3
ProcessVote processes a vote for a vertex
func (*DAGConsensus) ResolveConflict ¶ added in v1.21.3
ResolveConflict resolves conflicts between vertices using Lux consensus with Prism DAG refraction
func (*DAGConsensus) Stats ¶ added in v1.21.3
func (d *DAGConsensus) Stats() map[string]interface{}
Stats returns consensus statistics
type Engine ¶
type Engine interface {
// GetVtx gets a vertex by ID
GetVtx(context.Context, ids.ID) (Transaction, error)
// BuildVtx builds a new vertex
BuildVtx(context.Context) (Transaction, error)
// ParseVtx parses a vertex from bytes
ParseVtx(context.Context, []byte) (Transaction, error)
// Start starts the engine
Start(context.Context, uint32) error
// Shutdown shuts down the engine
Shutdown(context.Context) error
}
Engine defines the DAG consensus engine interface
func NewWithParams ¶ added in v1.21.3
func NewWithParams(params config.Parameters) Engine
NewWithParams creates an engine with specific parameters
type Transaction ¶
type Transaction interface {
ID() ids.ID
Parent() ids.ID
Height() uint64
Bytes() []byte
Verify(context.Context) error
Accept(context.Context) error
Reject(context.Context) error
}
Transaction represents a DAG transaction
type Tx ¶
type Tx interface {
ID() ids.ID
ParentIDs() []ids.ID
Bytes() []byte
Verify(context.Context) error
Accept(context.Context) error
Reject(context.Context) error
}
Tx represents a transaction in the DAG
type Vertex ¶ added in v1.21.3
type Vertex struct {
// contains filtered or unexported fields
}
Vertex represents a vertex in the DAG
func (*Vertex) IsAccepted ¶ added in v1.21.3
IsAccepted returns whether the vertex is accepted
func (*Vertex) IsProcessing ¶ added in v1.21.3
IsProcessing returns whether the vertex is being processed
func (*Vertex) IsRejected ¶ added in v1.21.3
IsRejected returns whether the vertex is rejected
func (*Vertex) LuxConsensus ¶ added in v1.21.3
func (v *Vertex) LuxConsensus() *engine.LuxConsensus
LuxConsensus returns the Lux consensus instance
func (*Vertex) Parent ¶ added in v1.21.3
Parent returns the first parent ID (for interface compatibility)
func (*Vertex) SetLuxConsensus ¶ added in v1.21.3
func (v *Vertex) SetLuxConsensus(lc *engine.LuxConsensus)
SetLuxConsensus sets the Lux consensus instance for this vertex
func (*Vertex) SetProcessing ¶ added in v1.21.3
SetProcessing sets the processing state
Source Files
Directories