beacon

Jun 6, 2023

Changes in this version

type MultiSlotState

+ func (as *MultiSlotState) SetHeadSlotIfHigher(slot structs.Slot) (structs.Slot, bool)

type State

+ SetHeadSlotIfHigher func(structs.Slot) (structs.Slot, bool)

Apr 23, 2023

Changes in this version

type MultiSlotState

+ func (as *MultiSlotState) SetHeadSlotPayloadAttributesIfHigher(slot uint64) (uint64, bool)

type State

+ SetHeadSlotPayloadAttributesIfHigher func(uint64) (uint64, bool)

Apr 13, 2023

Changes in this version

type BeaconClient

+ SubscribeToPayloadAttributesEvents func(payloadAttrC chan bcli.PayloadAttributesEvent)

type Config

+ RunPayloadAttributesSubscription bool

type Manager

+ func (s *Manager) RunPayloadAttributesSubscription(ctx context.Context, state State, client BeaconClient, ...)

type MultiSlotState

+ func (as *MultiSlotState) HeadSlotPayloadAttributes() uint64

+ func (as *MultiSlotState) ParentBlockHash() string

+ func (as *MultiSlotState) SetHeadSlotPayloadAttributes(slot uint64)

+ func (as *MultiSlotState) SetParentBlockHash(blockHash string)

type State

+ HeadSlotPayloadAttributes func() uint64

+ ParentBlockHash func() string

+ SetHeadSlotPayloadAttributes func(uint64)

+ SetParentBlockHash func(string)

Mar 28, 2023

Changes in this version

+ const NumberOfSlotsInState

+ type MultiSlotState struct

+ 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

Mar 23, 2023

Changes in this version

+ const Version

+ var DurationPerEpoch = DurationPerSlot * time.Duration(structs.SlotsPerEpoch)

+ var DurationPerSlot = time.Second * 12

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

+ type AtomicState struct

+ func (as *AtomicState) Duties() structs.DutiesState

+ func (as *AtomicState) Fork() structs.ForkState

+ func (as *AtomicState) ForkVersion(slot structs.Slot) structs.ForkVersion

+ func (as *AtomicState) Genesis() structs.GenesisInfo

+ func (as *AtomicState) HeadSlot() structs.Slot

+ func (as *AtomicState) KnownValidators() structs.ValidatorsState

+ func (as *AtomicState) KnownValidatorsUpdateTime() time.Time

+ func (as *AtomicState) Randao() string

+ func (as *AtomicState) SetDuties(duties structs.DutiesState)

+ func (as *AtomicState) SetFork(fork structs.ForkState)

+ func (as *AtomicState) SetGenesis(genesis structs.GenesisInfo)

+ func (as *AtomicState) SetHeadSlot(headSlot structs.Slot)

+ func (as *AtomicState) SetKnownValidators(validators structs.ValidatorsState)

+ func (as *AtomicState) SetRandao(randao string)

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

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

+ type BeaconClient interface

+ Genesis func() (structs.GenesisInfo, error)

+ GetForkSchedule func() (*bcli.GetForkScheduleResponse, error)

+ GetProposerDuties func(structs.Epoch) (*bcli.RegisteredProposersResponse, error)

+ GetWithdrawals func(structs.Slot) (*bcli.GetWithdrawalsResponse, error)

+ KnownValidators func(structs.Slot) (bcli.AllValidatorsResponse, error)

+ Randao func(structs.Slot) (string, error)

+ SubscribeToHeadEvents func(ctx context.Context, slotC chan bcli.HeadEvent)

+ SyncStatus func() (*bcli.SyncStatusPayloadData, error)

+ type Config struct

+ AltairForkVersion string

+ BellatrixForkVersion string

+ CapellaForkVersion string

+ type Datastore interface

+ GetRegistration func(context.Context, types.PublicKey) (types.SignedValidatorRegistration, error)

+ type Manager struct

+ Config Config

+ Log log.Logger

+ 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 State interface

+ Duties func() structs.DutiesState

+ Fork func() structs.ForkState

+ HeadSlot func() structs.Slot

+ KnownValidators func() structs.ValidatorsState

+ KnownValidatorsUpdateTime func() time.Time

+ Randao func() string

+ SetDuties func(structs.DutiesState)

+ SetFork func(structs.ForkState)

+ SetGenesis func(structs.GenesisInfo)

+ SetHeadSlot func(structs.Slot)

+ SetKnownValidators func(structs.ValidatorsState)

+ SetRandao func(string)

+ SetWithdrawals func(structs.WithdrawalsState)

+ Withdrawals func() structs.WithdrawalsState

+ type ValidatorCache interface

+ Get func(types.PublicKey) (structs.ValidatorCacheEntry, bool)