beacon

Documentation

Index

• Constants
• Variables
• type AtomicState
  • func (as *AtomicState) Randao() structs.RandaoState
  • func (as *AtomicState) SetRandao(randao structs.RandaoState)
  • func (as *AtomicState) SetWithdrawals(withdrawals structs.WithdrawalsState)
  • func (as *AtomicState) Withdrawals() structs.WithdrawalsState
• type BeaconClient
• type Config
• type Datastore
• type Manager
  • func NewManager(l log.Logger, cgf Config) *Manager
  • func (s *Manager) Init(ctx context.Context, state State, client BeaconClient, d Datastore, ...) error
  • func (s *Manager) Run(ctx context.Context, state State, client BeaconClient, d Datastore, ...) error
• type MultiSlotState
  • func (as *MultiSlotState) Duties() structs.DutiesState
  • func (as *MultiSlotState) Fork() structs.ForkState
  • func (as *MultiSlotState) ForkVersion(slot structs.Slot) structs.ForkVersion
  • func (as *MultiSlotState) Genesis() structs.GenesisInfo
  • func (as *MultiSlotState) HeadSlot() structs.Slot
  • func (as *MultiSlotState) KnownValidators() structs.ValidatorsState
  • func (as *MultiSlotState) KnownValidatorsUpdateTime() time.Time
  • func (as *MultiSlotState) Randao(slot uint64) structs.RandaoState
  • func (as *MultiSlotState) SetDuties(duties structs.DutiesState)
  • func (as *MultiSlotState) SetFork(fork structs.ForkState)
  • func (as *MultiSlotState) SetGenesis(genesis structs.GenesisInfo)
  • func (as *MultiSlotState) SetHeadSlot(headSlot structs.Slot)
  • func (as *MultiSlotState) SetKnownValidators(validators structs.ValidatorsState)
  • func (as *MultiSlotState) SetRandao(randao structs.RandaoState)
  • func (as *MultiSlotState) SetWithdrawals(withdrawals structs.WithdrawalsState)
  • func (as *MultiSlotState) Withdrawals(slot uint64) structs.WithdrawalsState
• type State
• type ValidatorCache

Constants

const (
	NumberOfSlotsInState = 2
)

const (
	Version = "0.3.6"
)

Variables

var (
	ErrUnkownFork = errors.New("beacon node fork is unknown")
)

Types

type AtomicState

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

func (*AtomicState) Randao

func (as *AtomicState) Randao() structs.RandaoState

func (*AtomicState) SetRandao

func (as *AtomicState) SetRandao(randao structs.RandaoState)

func (*AtomicState) SetWithdrawals

func (as *AtomicState) SetWithdrawals(withdrawals structs.WithdrawalsState)

func (*AtomicState) Withdrawals

func (as *AtomicState) Withdrawals() structs.WithdrawalsState

type BeaconClient

type BeaconClient interface {
	SubscribeToHeadEvents(ctx context.Context, slotC chan bcli.HeadEvent)
	GetProposerDuties(structs.Epoch) (*bcli.RegisteredProposersResponse, error)
	SyncStatus() (*bcli.SyncStatusPayloadData, error)
	KnownValidators(structs.Slot) (bcli.AllValidatorsResponse, error)
	Genesis() (structs.GenesisInfo, error)
	GetWithdrawals(structs.Slot) (*bcli.GetWithdrawalsResponse, error)
	Randao(structs.Slot) (string, error)
	GetForkSchedule() (*bcli.GetForkScheduleResponse, error)
}

type Config

type Config struct {
	AltairForkVersion    string
	BellatrixForkVersion string
	CapellaForkVersion   string
}

type Datastore

type Datastore interface {
	GetRegistration(context.Context, types.PublicKey) (types.SignedValidatorRegistration, error)
}

type Manager

type Manager struct {
	Log    log.Logger
	Config Config
}

func NewManager

func NewManager(l log.Logger, cgf Config) *Manager

func (*Manager) Init

func (s *Manager) Init(ctx context.Context, state State, client BeaconClient, d Datastore, vCache ValidatorCache) error

func (*Manager) Run

func (s *Manager) Run(ctx context.Context, state State, client BeaconClient, d Datastore, vCache ValidatorCache) error

type MultiSlotState

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

func (*MultiSlotState) Duties

func (as *MultiSlotState) Duties() structs.DutiesState

func (*MultiSlotState) Fork

func (as *MultiSlotState) Fork() structs.ForkState

func (*MultiSlotState) ForkVersion

func (as *MultiSlotState) ForkVersion(slot structs.Slot) structs.ForkVersion

func (*MultiSlotState) Genesis

func (as *MultiSlotState) Genesis() structs.GenesisInfo

func (*MultiSlotState) HeadSlot

func (as *MultiSlotState) HeadSlot() structs.Slot

func (*MultiSlotState) KnownValidators

func (as *MultiSlotState) KnownValidators() structs.ValidatorsState

func (*MultiSlotState) KnownValidatorsUpdateTime

func (as *MultiSlotState) KnownValidatorsUpdateTime() time.Time

func (*MultiSlotState) Randao

func (as *MultiSlotState) Randao(slot uint64) structs.RandaoState

func (*MultiSlotState) SetDuties

func (as *MultiSlotState) SetDuties(duties structs.DutiesState)

func (*MultiSlotState) SetFork

func (as *MultiSlotState) SetFork(fork structs.ForkState)

func (*MultiSlotState) SetGenesis

func (as *MultiSlotState) SetGenesis(genesis structs.GenesisInfo)

func (*MultiSlotState) SetHeadSlot

func (as *MultiSlotState) SetHeadSlot(headSlot structs.Slot)

func (*MultiSlotState) SetKnownValidators

func (as *MultiSlotState) SetKnownValidators(validators structs.ValidatorsState)

func (*MultiSlotState) SetRandao

func (as *MultiSlotState) SetRandao(randao structs.RandaoState)

func (*MultiSlotState) SetWithdrawals

func (as *MultiSlotState) SetWithdrawals(withdrawals structs.WithdrawalsState)

func (*MultiSlotState) Withdrawals

func (as *MultiSlotState) Withdrawals(slot uint64) structs.WithdrawalsState

type State

type State interface {
	SetGenesis(structs.GenesisInfo)

	Duties() structs.DutiesState
	SetDuties(structs.DutiesState)

	KnownValidators() structs.ValidatorsState
	KnownValidatorsUpdateTime() time.Time
	SetKnownValidators(structs.ValidatorsState)

	HeadSlot() structs.Slot
	SetHeadSlot(structs.Slot)

	Withdrawals(uint64) structs.WithdrawalsState
	SetWithdrawals(structs.WithdrawalsState)

	SetRandao(structs.RandaoState)
	Randao(uint64) structs.RandaoState

	Fork() structs.ForkState
	SetFork(structs.ForkState)
}

type ValidatorCache

type ValidatorCache interface {
	Get(types.PublicKey) (structs.ValidatorCacheEntry, bool)
}