beacon

package
v0.4.13 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 11, 2023 License: AGPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const (
	NumberOfSlotsInState = 2
)
View Source
const (
	Version = "0.3.6"
)

Variables

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

Functions

This section is empty.

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 added in v0.4.2

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

func (*MultiSlotState) Duties added in v0.4.2

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

func (*MultiSlotState) Fork added in v0.4.2

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

func (*MultiSlotState) ForkVersion added in v0.4.2

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

func (*MultiSlotState) Genesis added in v0.4.2

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

func (*MultiSlotState) HeadSlot added in v0.4.2

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

func (*MultiSlotState) KnownValidators added in v0.4.2

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

func (*MultiSlotState) KnownValidatorsUpdateTime added in v0.4.2

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

func (*MultiSlotState) Randao added in v0.4.2

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

func (*MultiSlotState) SetDuties added in v0.4.2

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

func (*MultiSlotState) SetFork added in v0.4.2

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

func (*MultiSlotState) SetGenesis added in v0.4.2

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

func (*MultiSlotState) SetHeadSlot added in v0.4.2

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

func (*MultiSlotState) SetKnownValidators added in v0.4.2

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

func (*MultiSlotState) SetRandao added in v0.4.2

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

func (*MultiSlotState) SetWithdrawals added in v0.4.2

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

func (*MultiSlotState) Withdrawals added in v0.4.2

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)
}

Directories

Path Synopsis
mocks
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL