Documentation ¶
Index ¶
- Variables
- func GenerateMultipleValidatorStatusResponse(pubkeys [][]byte) *ethpb.MultipleValidatorStatusResponse
- type FakeValidator
- func (_ *FakeValidator) AllValidatorsAreExited(ctx context.Context) (bool, error)
- func (fv *FakeValidator) BalancesByPubkeys(_ context.Context) map[[fieldparams.BLSPubkeyLength]byte]uint64
- func (fv *FakeValidator) CanonicalHeadSlot(_ context.Context) (types.Slot, error)
- func (_ *FakeValidator) CheckDoppelGanger(_ context.Context) error
- func (fv *FakeValidator) Done()
- func (fv *FakeValidator) HandleKeyReload(_ context.Context, newKeys [][fieldparams.BLSPubkeyLength]byte) (anyActive bool, err error)
- func (fv *FakeValidator) IndicesToPubkeys(_ context.Context) map[uint64][fieldparams.BLSPubkeyLength]byte
- func (fv *FakeValidator) Keymanager() (keymanager.IKeymanager, error)
- func (_ *FakeValidator) LogAttestationsSubmitted()
- func (fv *FakeValidator) LogSyncCommitteeMessagesSubmitted()
- func (fv *FakeValidator) LogValidatorGainsAndLosses(_ context.Context, _ types.Slot) error
- func (fv *FakeValidator) NextSlot() <-chan types.Slot
- func (fv *FakeValidator) ProposeBlock(_ context.Context, slot types.Slot, _ [fieldparams.BLSPubkeyLength]byte)
- func (fv *FakeValidator) PubkeysToIndices(_ context.Context) map[[fieldparams.BLSPubkeyLength]byte]uint64
- func (fv *FakeValidator) PubkeysToStatuses(_ context.Context) map[[fieldparams.BLSPubkeyLength]byte]ethpb.ValidatorStatus
- func (fv *FakeValidator) PushProposerSettings(_ context.Context, _ keymanager.IKeymanager) error
- func (fv *FakeValidator) ReceiveBlocks(_ context.Context, connectionErrorChannel chan<- error)
- func (fv *FakeValidator) ResetAttesterProtectionData()
- func (fv *FakeValidator) RolesAt(_ context.Context, slot types.Slot) (map[[fieldparams.BLSPubkeyLength]byte][]iface.ValidatorRole, error)
- func (_ *FakeValidator) SetPubKeyToValidatorIndexMap(_ context.Context, _ keymanager.IKeymanager) error
- func (_ *FakeValidator) SignValidatorRegistrationRequest(_ context.Context, _ iface.SigningFunc, _ *ethpb.ValidatorRegistrationV1) (*ethpb.SignedValidatorRegistrationV1, error)
- func (fv *FakeValidator) SlasherReady(_ context.Context) error
- func (fv *FakeValidator) SlotDeadline(_ types.Slot) time.Time
- func (_ *FakeValidator) SubmitAggregateAndProof(_ context.Context, _ types.Slot, _ [fieldparams.BLSPubkeyLength]byte)
- func (fv *FakeValidator) SubmitAttestation(_ context.Context, slot types.Slot, _ [fieldparams.BLSPubkeyLength]byte)
- func (_ *FakeValidator) SubmitSignedContributionAndProof(_ context.Context, _ types.Slot, _ [fieldparams.BLSPubkeyLength]byte)
- func (_ *FakeValidator) SubmitSyncCommitteeMessage(_ context.Context, _ types.Slot, _ [fieldparams.BLSPubkeyLength]byte)
- func (_ *FakeValidator) UpdateDomainDataCaches(context.Context, types.Slot)
- func (fv *FakeValidator) UpdateDuties(_ context.Context, slot types.Slot) error
- func (fv *FakeValidator) UpdateProtections(_ context.Context, _ uint64) error
- func (fv *FakeValidator) WaitForActivation(_ context.Context, _ chan [][fieldparams.BLSPubkeyLength]byte) error
- func (fv *FakeValidator) WaitForChainStart(_ context.Context) error
- func (fv *FakeValidator) WaitForKeymanagerInitialization(_ context.Context) error
- func (fv *FakeValidator) WaitForSync(_ context.Context) error
Constants ¶
This section is empty.
Variables ¶
var ActiveKey = bytesutil.ToBytes48([]byte("active"))
ActiveKey represents a public key whose status is ACTIVE.
var AllValidatorsAreExitedCtxKey = ctxKey("exited")
AllValidatorsAreExitedCtxKey represents the metadata context key used for exits.
Functions ¶
func GenerateMultipleValidatorStatusResponse ¶
func GenerateMultipleValidatorStatusResponse(pubkeys [][]byte) *ethpb.MultipleValidatorStatusResponse
GenerateMultipleValidatorStatusResponse prepares a response from the passed in keys.
Types ¶
type FakeValidator ¶
type FakeValidator struct { DoneCalled bool WaitForWalletInitializationCalled bool SlasherReadyCalled bool NextSlotCalled bool UpdateDutiesCalled bool UpdateProtectionsCalled bool RoleAtCalled bool AttestToBlockHeadCalled bool ProposeBlockCalled bool LogValidatorGainsAndLossesCalled bool SaveProtectionsCalled bool DeleteProtectionCalled bool SlotDeadlineCalled bool HandleKeyReloadCalled bool WaitForChainStartCalled int WaitForSyncCalled int WaitForActivationCalled int CanonicalHeadSlotCalled int ReceiveBlocksCalled int RetryTillSuccess int ProposeBlockArg1 uint64 AttestToBlockHeadArg1 uint64 RoleAtArg1 uint64 UpdateDutiesArg1 uint64 NextSlotRet <-chan types.Slot PublicKey string UpdateDutiesRet error ProposerSettingsErr error RolesAtRet []iface.ValidatorRole Balances map[[fieldparams.BLSPubkeyLength]byte]uint64 IndexToPubkeyMap map[uint64][fieldparams.BLSPubkeyLength]byte PubkeyToIndexMap map[[fieldparams.BLSPubkeyLength]byte]uint64 PubkeysToStatusesMap map[[fieldparams.BLSPubkeyLength]byte]ethpb.ValidatorStatus Km keymanager.IKeymanager }
FakeValidator for mocking.
func (*FakeValidator) AllValidatorsAreExited ¶
func (_ *FakeValidator) AllValidatorsAreExited(ctx context.Context) (bool, error)
AllValidatorsAreExited for mocking
func (*FakeValidator) BalancesByPubkeys ¶
func (fv *FakeValidator) BalancesByPubkeys(_ context.Context) map[[fieldparams.BLSPubkeyLength]byte]uint64
BalancesByPubkeys for mocking.
func (*FakeValidator) CanonicalHeadSlot ¶
CanonicalHeadSlot for mocking.
func (*FakeValidator) CheckDoppelGanger ¶
func (_ *FakeValidator) CheckDoppelGanger(_ context.Context) error
CheckDoppelGanger for mocking
func (*FakeValidator) HandleKeyReload ¶
func (fv *FakeValidator) HandleKeyReload(_ context.Context, newKeys [][fieldparams.BLSPubkeyLength]byte) (anyActive bool, err error)
HandleKeyReload for mocking
func (*FakeValidator) IndicesToPubkeys ¶
func (fv *FakeValidator) IndicesToPubkeys(_ context.Context) map[uint64][fieldparams.BLSPubkeyLength]byte
IndicesToPubkeys for mocking.
func (*FakeValidator) Keymanager ¶
func (fv *FakeValidator) Keymanager() (keymanager.IKeymanager, error)
Keymanager for mocking
func (*FakeValidator) LogAttestationsSubmitted ¶
func (_ *FakeValidator) LogAttestationsSubmitted()
LogAttestationsSubmitted for mocking.
func (*FakeValidator) LogSyncCommitteeMessagesSubmitted ¶
func (fv *FakeValidator) LogSyncCommitteeMessagesSubmitted()
LogSyncCommitteeMessagesSubmitted --
func (*FakeValidator) LogValidatorGainsAndLosses ¶
LogValidatorGainsAndLosses for mocking.
func (*FakeValidator) NextSlot ¶
func (fv *FakeValidator) NextSlot() <-chan types.Slot
NextSlot for mocking.
func (*FakeValidator) ProposeBlock ¶
func (fv *FakeValidator) ProposeBlock(_ context.Context, slot types.Slot, _ [fieldparams.BLSPubkeyLength]byte)
ProposeBlock for mocking.
func (*FakeValidator) PubkeysToIndices ¶
func (fv *FakeValidator) PubkeysToIndices(_ context.Context) map[[fieldparams.BLSPubkeyLength]byte]uint64
PubkeysToIndices for mocking.
func (*FakeValidator) PubkeysToStatuses ¶
func (fv *FakeValidator) PubkeysToStatuses(_ context.Context) map[[fieldparams.BLSPubkeyLength]byte]ethpb.ValidatorStatus
PubkeysToStatuses for mocking.
func (*FakeValidator) PushProposerSettings ¶
func (fv *FakeValidator) PushProposerSettings(_ context.Context, _ keymanager.IKeymanager) error
PushProposerSettings for mocking
func (*FakeValidator) ReceiveBlocks ¶
func (fv *FakeValidator) ReceiveBlocks(_ context.Context, connectionErrorChannel chan<- error)
ReceiveBlocks for mocking
func (*FakeValidator) ResetAttesterProtectionData ¶
func (fv *FakeValidator) ResetAttesterProtectionData()
ResetAttesterProtectionData for mocking.
func (*FakeValidator) RolesAt ¶
func (fv *FakeValidator) RolesAt(_ context.Context, slot types.Slot) (map[[fieldparams.BLSPubkeyLength]byte][]iface.ValidatorRole, error)
RolesAt for mocking.
func (*FakeValidator) SetPubKeyToValidatorIndexMap ¶
func (_ *FakeValidator) SetPubKeyToValidatorIndexMap(_ context.Context, _ keymanager.IKeymanager) error
SetPubKeyToValidatorIndexMap for mocking
func (*FakeValidator) SignValidatorRegistrationRequest ¶
func (_ *FakeValidator) SignValidatorRegistrationRequest(_ context.Context, _ iface.SigningFunc, _ *ethpb.ValidatorRegistrationV1) (*ethpb.SignedValidatorRegistrationV1, error)
SignValidatorRegistrationRequest for mocking
func (*FakeValidator) SlasherReady ¶
func (fv *FakeValidator) SlasherReady(_ context.Context) error
SlasherReady for mocking.
func (*FakeValidator) SlotDeadline ¶
func (fv *FakeValidator) SlotDeadline(_ types.Slot) time.Time
SlotDeadline for mocking.
func (*FakeValidator) SubmitAggregateAndProof ¶
func (_ *FakeValidator) SubmitAggregateAndProof(_ context.Context, _ types.Slot, _ [fieldparams.BLSPubkeyLength]byte)
SubmitAggregateAndProof for mocking.
func (*FakeValidator) SubmitAttestation ¶
func (fv *FakeValidator) SubmitAttestation(_ context.Context, slot types.Slot, _ [fieldparams.BLSPubkeyLength]byte)
SubmitAttestation for mocking.
func (*FakeValidator) SubmitSignedContributionAndProof ¶
func (_ *FakeValidator) SubmitSignedContributionAndProof(_ context.Context, _ types.Slot, _ [fieldparams.BLSPubkeyLength]byte)
SubmitSignedContributionAndProof for mocking
func (*FakeValidator) SubmitSyncCommitteeMessage ¶
func (_ *FakeValidator) SubmitSyncCommitteeMessage(_ context.Context, _ types.Slot, _ [fieldparams.BLSPubkeyLength]byte)
SubmitSyncCommitteeMessage for mocking.
func (*FakeValidator) UpdateDomainDataCaches ¶
func (_ *FakeValidator) UpdateDomainDataCaches(context.Context, types.Slot)
UpdateDomainDataCaches for mocking.
func (*FakeValidator) UpdateDuties ¶
UpdateDuties for mocking.
func (*FakeValidator) UpdateProtections ¶
func (fv *FakeValidator) UpdateProtections(_ context.Context, _ uint64) error
UpdateProtections for mocking.
func (*FakeValidator) WaitForActivation ¶
func (fv *FakeValidator) WaitForActivation(_ context.Context, _ chan [][fieldparams.BLSPubkeyLength]byte) error
WaitForActivation for mocking.
func (*FakeValidator) WaitForChainStart ¶
func (fv *FakeValidator) WaitForChainStart(_ context.Context) error
WaitForChainStart for mocking.
func (*FakeValidator) WaitForKeymanagerInitialization ¶
func (fv *FakeValidator) WaitForKeymanagerInitialization(_ context.Context) error
WaitForKeymanagerInitialization for mocking.
func (*FakeValidator) WaitForSync ¶
func (fv *FakeValidator) WaitForSync(_ context.Context) error
WaitForSync for mocking.