wave

type Config ¶

type Config struct {
	Type            ThresholdType
	AlphaPreference int
	AlphaConfidence int
}

Config represents wave threshold configuration

type DynamicWaveThreshold ¶

type DynamicWaveThreshold struct {
	// contains filtered or unexported fields
}

DynamicWaveThreshold implements decoupled alpha thresholding (Previously DynamicQuorum/DecoupledQuorum in Avalanche)

Uses separate thresholds for preference (alpha1) and confidence (alpha2), allowing for more nuanced consensus detection through wave interference.

func NewDynamicWaveThreshold(alphaPreference, alphaConfidence int) *DynamicWaveThreshold

func (d *DynamicWaveThreshold) AddVote(nodeID ids.NodeID, choice ids.ID) bool

func (d *DynamicWaveThreshold) CheckConfidence() (ids.ID, bool)

func (d *DynamicWaveThreshold) CheckPreference() (ids.ID, bool)

func (d *DynamicWaveThreshold) GetLeader() (ids.ID, int)

func (d *DynamicWaveThreshold) GetThreshold() int

func (d *DynamicWaveThreshold) GetTotalVotes() int

func (d *DynamicWaveThreshold) GetVoteCount(choice ids.ID) int

func (d *DynamicWaveThreshold) Reset()

func (d *DynamicWaveThreshold) SetMode(preferenceMode bool)

type Factory ¶

type Factory struct {
	// contains filtered or unexported fields
}

Factory creates wave threshold mechanisms (Previously QuorumFactory in Avalanche)

func NewFactory(alphaPreference, alphaConfidence int) *Factory

func (f *Factory) New(thresholdType ThresholdType) Threshold

func (f *Factory) NewDynamic() Threshold

func (f *Factory) NewStatic() Threshold

type StaticWaveThreshold ¶

type StaticWaveThreshold struct {
	// contains filtered or unexported fields
}

StaticWaveThreshold implements fixed alpha thresholding (Previously StaticQuorum in Avalanche)

Uses a fixed threshold for determining when constructive interference (consensus) has been achieved.

func NewStaticWaveThreshold(alpha int) *StaticWaveThreshold

func (s *StaticWaveThreshold) AddVote(nodeID ids.NodeID, choice ids.ID) bool

func (s *StaticWaveThreshold) GetLeader() (ids.ID, int)

func (s *StaticWaveThreshold) GetThreshold() int

func (s *StaticWaveThreshold) GetTotalVotes() int

func (s *StaticWaveThreshold) GetVoteCount(choice ids.ID) int

func (s *StaticWaveThreshold) GetWavePattern() *WavePattern

func (s *StaticWaveThreshold) Reset()

type Threshold ¶

type Threshold interface {
	// AddVote adds a vote and returns if threshold is reached
	AddVote(nodeID ids.NodeID, choice ids.ID) bool

	// GetThreshold returns the current alpha threshold
	GetThreshold() int

	// GetVoteCount returns votes for a specific choice
	GetVoteCount(choice ids.ID) int

	// GetTotalVotes returns total votes received
	GetTotalVotes() int

	// GetLeader returns the current leading choice and its vote count
	GetLeader() (ids.ID, int)

	// Reset clears all votes
	Reset()
}

Threshold represents wave interference patterns for vote counting (Previously known as Quorum in Avalanche consensus)

When photon reflections (votes) return, they create interference patterns. Constructive interference above the threshold indicates consensus forming.

func NewFromConfig(cfg Config) Threshold

type ThresholdType ¶

type ThresholdType int

ThresholdType identifies the type of threshold mechanism

const (
	Static ThresholdType = iota
	Dynamic
	Adaptive
)

type WavePattern ¶

type WavePattern struct {
	Choices    map[ids.ID]int // Vote counts per choice
	TotalVotes int
	Threshold  int // Alpha threshold
}

WavePattern represents the voting state at a given moment (Previously QuorumState)

func (w *WavePattern) GetAmplitude(choice ids.ID) int

func (w *WavePattern) IsConstructive() bool