beam

type BeamBlock struct {
	// Embedded chain block for compatibility
	chain.Block
	// contains filtered or unexported fields
}

type BeamBlockWrapper struct {
	chain.Block
	// contains filtered or unexported fields
}

type BeamMetrics struct {
	BlocksAdded      uint64
	BlocksFinalized  uint64
	PollsProcessed   uint64
	BeamSplits       uint64 // Times the beam split (reorgs)
	AveragePollTime  time.Duration
	AverageFocusTime time.Duration
}

type BeamState struct {
	PreferredID       ids.ID
	PreferredHeight   uint64
	FinalizedID       ids.ID
	FinalizedHeight   uint64
	OutstandingBlocks int
	BeamIntensity     int // Consensus strength (0-100)
}

type Block interface {
	chain.Block

	// BeamHeight returns the block's position in the beam
	BeamHeight() uint64

	// BeamScore returns the block's consensus score
	BeamScore() uint64

	// Photons returns the number of photon queries for this block
	Photons() int
}

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

type Health struct {
	Healthy           bool
	BeamCoherence     float64 // 0-1, how coherent the beam is
	FocusStrength     int     // Current focus strength
	LastPollTime      time.Time
	ConsecutivePolls  int
	OutstandingBlocks int
}

type Linearizer interface {
	// Add a new block to the beam
	Add(ctx context.Context, block Block) error

	// Vote for a block preference
	Vote(ctx context.Context, blockID ids.ID) error

	// RecordPoll records the result of photon sampling
	RecordPoll(ctx context.Context, votes map[ids.ID]int) error

	// Preferred returns the current preferred block
	Preferred() ids.ID

	// Finalized returns finalized blocks since last call
	Finalized() []ids.ID

	// IsFinalized checks if a block has been finalized
	IsFinalized(blockID ids.ID) bool

	// HealthCheck returns consensus health metrics
	HealthCheck(ctx context.Context) (Health, error)
}

type Parameters struct {
	K               int           // Photon sample size
	AlphaPreference int           // Wave threshold for preference
	AlphaConfidence int           // Wave threshold for confidence
	Beta            int           // Focus rounds for finality
	MaxPollTime     time.Duration // Maximum time for a poll
}