Documentation ¶
Index ¶
- type Consensus
- type Factory
- type Parameters
- type TestVertex
- func (v *TestVertex) Bytes() []byte
- func (v *TestVertex) HasWhitelist() bool
- func (v *TestVertex) Height() (uint64, error)
- func (v *TestVertex) Parents() ([]Vertex, error)
- func (v *TestVertex) Txs() ([]snowstorm.Tx, error)
- func (v *TestVertex) Verify() error
- func (v *TestVertex) Whitelist() (ids.Set, error)
- type Topological
- func (ta *Topological) Add(vtx Vertex) error
- func (ta *Topological) Finalized() bool
- func (ta *Topological) HealthCheck() (interface{}, error)
- func (ta *Topological) Initialize(ctx *snow.ConsensusContext, params Parameters, frontier []Vertex) error
- func (ta *Topological) IsVirtuous(tx snowstorm.Tx) bool
- func (ta *Topological) NumProcessing() int
- func (ta *Topological) Orphans() ids.Set
- func (ta *Topological) Parameters() Parameters
- func (ta *Topological) Preferences() ids.Set
- func (ta *Topological) Quiesce() bool
- func (ta *Topological) RecordPoll(responses ids.UniqueBag) error
- func (ta *Topological) TxIssued(tx snowstorm.Tx) bool
- func (ta *Topological) VertexIssued(vtx Vertex) bool
- func (ta *Topological) Virtuous() ids.Set
- type TopologicalFactory
- type Vertex
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consensus ¶
type Consensus interface { // Takes in alpha, beta1, beta2, the accepted frontier, the join statuses, // the mutation statuses, and the consumer statuses. If accept or reject is // called, the status maps should be immediately updated accordingly. // Assumes each element in the accepted frontier will return accepted from // the join status map. Initialize(*snow.ConsensusContext, Parameters, []Vertex) error // Returns the parameters that describe this avalanche instance Parameters() Parameters // Returns the number of vertices processing NumProcessing() int // Returns true if the transaction is virtuous. // That is, no transaction has been added that conflicts with it IsVirtuous(snowstorm.Tx) bool // Adds a new decision. Assumes the dependencies have already been added. // Assumes that mutations don't conflict with themselves. Returns if a // critical error has occurred. Add(Vertex) error // VertexIssued returns true iff Vertex has been added VertexIssued(Vertex) bool // TxIssued returns true if a vertex containing this transanction has been added TxIssued(snowstorm.Tx) bool // Returns the set of transaction IDs that are virtuous but not contained in // any preferred vertices. Orphans() ids.Set // Returns a set of vertex IDs that were virtuous at the last update. Virtuous() ids.Set // Returns a set of vertex IDs that are preferred Preferences() ids.Set // RecordPoll collects the results of a network poll. If a result has not // been added, the result is dropped. Returns if a critical error has // occurred. RecordPoll(ids.UniqueBag) error // Quiesce is guaranteed to return true if the instance is finalized. It // may, but doesn't need to, return true if all processing vertices are // rogue. It must return false if there is a virtuous vertex that is still // processing. Quiesce() bool // Finalized returns true if all transactions that have been added have been // finalized. Note, it is possible that after returning finalized, a new // decision may be added such that this instance is no longer finalized. Finalized() bool // HealthCheck returns information about the consensus health. HealthCheck() (interface{}, error) }
Consensus represents a general avalanche instance that can be used directly to process a series of partially ordered elements.
type Factory ¶
type Factory interface {
New() Consensus
}
Factory returns new instances of Consensus
type Parameters ¶
type Parameters struct { snowball.Parameters Parents int `json:"parents"` BatchSize int `json:"batchSize"` }
Parameters the avalanche parameters include the snowball parameters and the optimal number of parents
func (Parameters) Valid ¶
func (p Parameters) Valid() error
Valid returns nil if the parameters describe a valid initialization.
type TestVertex ¶ added in v1.6.11
type TestVertex struct { choices.TestDecidable VerifyErrV error ParentsV []Vertex ParentsErrV error HasWhitelistV bool WhitelistV ids.Set WhitelistErrV error HeightV uint64 HeightErrV error TxsV []snowstorm.Tx TxsErrV error BytesV []byte }
TestVertex is a useful test vertex
func (*TestVertex) Bytes ¶ added in v1.6.11
func (v *TestVertex) Bytes() []byte
func (*TestVertex) HasWhitelist ¶ added in v1.6.11
func (v *TestVertex) HasWhitelist() bool
func (*TestVertex) Height ¶ added in v1.6.11
func (v *TestVertex) Height() (uint64, error)
func (*TestVertex) Parents ¶ added in v1.6.11
func (v *TestVertex) Parents() ([]Vertex, error)
func (*TestVertex) Verify ¶ added in v1.6.11
func (v *TestVertex) Verify() error
type Topological ¶
Topological performs the avalanche algorithm by utilizing a topological sort of the voting results. Assumes that vertices are inserted in topological order.
func (*Topological) Add ¶
func (ta *Topological) Add(vtx Vertex) error
func (*Topological) Finalized ¶
func (ta *Topological) Finalized() bool
func (*Topological) HealthCheck ¶ added in v1.6.11
func (ta *Topological) HealthCheck() (interface{}, error)
HealthCheck returns information about the consensus health.
func (*Topological) Initialize ¶
func (ta *Topological) Initialize( ctx *snow.ConsensusContext, params Parameters, frontier []Vertex, ) error
func (*Topological) IsVirtuous ¶
func (ta *Topological) IsVirtuous(tx snowstorm.Tx) bool
func (*Topological) NumProcessing ¶ added in v1.6.11
func (ta *Topological) NumProcessing() int
func (*Topological) Orphans ¶
func (ta *Topological) Orphans() ids.Set
func (*Topological) Parameters ¶
func (ta *Topological) Parameters() Parameters
func (*Topological) Preferences ¶
func (ta *Topological) Preferences() ids.Set
func (*Topological) Quiesce ¶
func (ta *Topological) Quiesce() bool
func (*Topological) RecordPoll ¶
func (ta *Topological) RecordPoll(responses ids.UniqueBag) error
func (*Topological) VertexIssued ¶
func (ta *Topological) VertexIssued(vtx Vertex) bool
func (*Topological) Virtuous ¶
func (ta *Topological) Virtuous() ids.Set
type TopologicalFactory ¶
type TopologicalFactory struct{}
TopologicalFactory implements Factory by returning a topological struct
func (TopologicalFactory) New ¶
func (TopologicalFactory) New() Consensus
type Vertex ¶
type Vertex interface { choices.Decidable // Vertex verification should be performed before issuance. verify.Verifiable snowstorm.Whitelister // Returns the vertices this vertex depends on Parents() ([]Vertex, error) // Returns the height of this vertex. A vertex's height is defined by one // greater than the maximum height of the parents. Height() (uint64, error) // Returns a series of state transitions to be performed on acceptance Txs() ([]snowstorm.Tx, error) // Returns the binary representation of this vertex Bytes() []byte }
Vertex is a collection of multiple transactions tied to other vertices