beacon

package
v0.5.0-alpha.2 Latest Latest
Warning

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

 Go to latest Published: May 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)
	SubscribeToPayloadAttributesEvents(payloadAttrC chan bcli.PayloadAttributesEvent)
}

type Config 

type Config struct {
	AltairForkVersion    string
	BellatrixForkVersion string
	CapellaForkVersion   string

	RunPayloadAttributesSubscription bool
}

type Datastore 

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

type Manager 

type Manager struct {
	Log    log.Logger
	Config Config
	// contains filtered or unexported fields
}

func NewManager 

func NewManager(l log.Logger, cfg 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

func (*Manager) RunPayloadAttributesSubscription added in v0.4.14 

func (s *Manager) RunPayloadAttributesSubscription(ctx context.Context, state State, client BeaconClient, events chan bcli.HeadEvent)

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) HeadSlotPayloadAttributes added in v0.4.14 

func (as *MultiSlotState) HeadSlotPayloadAttributes() uint64

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) ParentBlockHash added in v0.4.14 

func (as *MultiSlotState) ParentBlockHash() string

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) SetHeadSlotPayloadAttributesIfHigher added in v0.4.15 

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

func (*MultiSlotState) SetKnownValidators added in v0.4.2 

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

func (*MultiSlotState) SetParentBlockHash added in v0.4.14 

func (as *MultiSlotState) SetParentBlockHash(blockHash string)

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)

	HeadSlotPayloadAttributes() uint64
	SetHeadSlotPayloadAttributesIfHigher(uint64) (uint64, bool)

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

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

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

	ParentBlockHash() string
	SetParentBlockHash(string)
}

type ValidatorCache 

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

Source Files

View all Source files

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
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.