wave

type Config struct {
	K         int           // Sample size
	Alpha     float64       // Threshold ratio (used when FPC disabled)
	Beta      uint32        // Confidence threshold
	RoundTO   time.Duration // Round timeout
	EnableFPC bool          // Enable Fast Probabilistic Consensus
	ThetaMin  float64       // FPC minimum threshold (default: 0.5)
	ThetaMax  float64       // FPC maximum threshold (default: 0.8)
}

type Photon[T comparable] struct {
	Item      T
	Prefer    bool
	Sender    types.NodeID
	Timestamp time.Time
}

type State[ID comparable] struct {
	// The item ID
	ID ID

	// Confidence score
	Confidence int

	// Whether the item is finalized
	Finalized bool

	// Parent IDs
	Parents []ID

	// Height in the consensus graph
	Height uint64
}

type Transport[T comparable] interface {
	RequestVotes(ctx context.Context, peers []types.NodeID, item T) <-chan Photon[T]
	MakeLocalPhoton(item T, prefer bool) Photon[T]
}

type Wave[T comparable] struct {
	// contains filtered or unexported fields
}

type WaveState struct {
	Decided bool
	Result  types.Decision
	Count   uint32
}