ssv

package

Go to main page

Versions in this module

v0

v0.3.9

Apr 11, 2024

Changes in this version

type Runner

+ func NewAttesterRunner(beaconNetwork types.BeaconNetwork, share *types.Share, ...) Runner

v0.3.8

Apr 9, 2024

Changes in this version

type Validator

+ OperatorSigner types.OperatorSigner

+ SignatureVerifier types.SignatureVerifier

v0.3.7

Mar 28, 2024

Changes in this version

type BaseRunner

+ func (b *BaseRunner) FallBackAndVerifyEachSignature(container *PartialSigContainer, root [32]byte)

type PartialSigContainer

+ func (ps *PartialSigContainer) GetSignature(signer types.OperatorID, signingRoot [32]byte) (types.Signature, error)

+ func (ps *PartialSigContainer) GetSignatures(signingRoot [32]byte) map[types.OperatorID][]byte

+ func (ps *PartialSigContainer) HasSigner(signer types.OperatorID, signingRoot [32]byte) bool

+ func (ps *PartialSigContainer) Remove(signer uint64, signingRoot [32]byte)

v0.3.7-b

Jul 30, 2024

v0.3.6

Feb 1, 2024

v0.3.5

Jan 21, 2024

v0.3.4

Nov 7, 2023

Changes in this version

type BaseRunner

+ func (b *BaseRunner) ShouldProcessNonBeaconDuty(duty *types.Duty) error

v0.3.3

Oct 19, 2023

v0.3.2

Sep 11, 2023

Changes in this version

type BaseRunner

+ func (b *BaseRunner) ShouldProcessDuty(duty *types.Duty) error

type Runner

+ func NewVoluntaryExitRunner(beaconNetwork types.BeaconNetwork, share *types.Share, beacon BeaconNode, ...) Runner

+ type VoluntaryExitCalls interface

+ SubmitVoluntaryExit func(voluntaryExit *phase0.SignedVoluntaryExit, sig phase0.BLSSignature) error

+ type VoluntaryExitRunner struct

+ BaseRunner *BaseRunner

+ func (r *VoluntaryExitRunner) Decode(data []byte) error

+ func (r *VoluntaryExitRunner) Encode() ([]byte, error)

+ func (r *VoluntaryExitRunner) GetBaseRunner() *BaseRunner

+ func (r *VoluntaryExitRunner) GetBeaconNode() BeaconNode

+ func (r *VoluntaryExitRunner) GetNetwork() Network

+ func (r *VoluntaryExitRunner) GetRoot() ([32]byte, error)

+ func (r *VoluntaryExitRunner) GetShare() *types.Share

+ func (r *VoluntaryExitRunner) GetSigner() types.KeyManager

+ func (r *VoluntaryExitRunner) GetState() *State

+ func (r *VoluntaryExitRunner) GetValCheckF() qbft.ProposedValueCheckF

+ func (r *VoluntaryExitRunner) HasRunningDuty() bool

+ func (r *VoluntaryExitRunner) ProcessConsensus(signedMsg *qbft.SignedMessage) error

+ func (r *VoluntaryExitRunner) ProcessPostConsensus(signedMsg *types.SignedPartialSignatureMessage) error

+ func (r *VoluntaryExitRunner) ProcessPreConsensus(signedMsg *types.SignedPartialSignatureMessage) error

+ func (r *VoluntaryExitRunner) StartNewDuty(duty *types.Duty) error

v0.3.1

Jul 12, 2023

Changes in this version

type BaseRunner

+ func NewBaseRunner(state *State, share *types.Share, controller *qbft.Controller, ...) *BaseRunner

+ func (b *BaseRunner) SetHighestDecidedSlot(slot spec.Slot)

+ type ValidatorRegistrationCalls interface

+ SubmitValidatorRegistration func(pubkey []byte, feeRecipient bellatrix.ExecutionAddress, ...) error

v0.3.0

Mar 12, 2023

Changes in this version

type BaseRunner

+ func (b *BaseRunner) ValidatePostConsensusMsg(runner Runner, signedMsg *types.SignedPartialSignatureMessage) error

+ func (b *BaseRunner) ValidatePreConsensusMsg(runner Runner, signedMsg *types.SignedPartialSignatureMessage) error

type ProposerCalls

+ GetBlindedBeaconBlock func(slot phase0.Slot, committeeIndex phase0.CommitteeIndex, ...) (ssz.Marshaler, spec.DataVersion, error)

+ SubmitBlindedBeaconBlock func(block *bellatrix2.SignedBlindedBeaconBlock) error

type ProposerRunner

+ ProducesBlindedBlocks bool

type Runner

+ func NewValidatorRegistrationRunner(beaconNetwork types.BeaconNetwork, share *types.Share, beacon BeaconNode, ...) Runner

+ type ValidatorRegistrationRunner struct

+ BaseRunner *BaseRunner

+ func (r *ValidatorRegistrationRunner) Decode(data []byte) error

+ func (r *ValidatorRegistrationRunner) Encode() ([]byte, error)

+ func (r *ValidatorRegistrationRunner) GetBaseRunner() *BaseRunner

+ func (r *ValidatorRegistrationRunner) GetBeaconNode() BeaconNode

+ func (r *ValidatorRegistrationRunner) GetNetwork() Network

+ func (r *ValidatorRegistrationRunner) GetRoot() ([32]byte, error)

+ func (r *ValidatorRegistrationRunner) GetShare() *types.Share

+ func (r *ValidatorRegistrationRunner) GetSigner() types.KeyManager

+ func (r *ValidatorRegistrationRunner) GetState() *State

+ func (r *ValidatorRegistrationRunner) GetValCheckF() qbft.ProposedValueCheckF

+ func (r *ValidatorRegistrationRunner) HasRunningDuty() bool

+ func (r *ValidatorRegistrationRunner) ProcessConsensus(signedMsg *qbft.SignedMessage) error

+ func (r *ValidatorRegistrationRunner) ProcessPostConsensus(signedMsg *types.SignedPartialSignatureMessage) error

+ func (r *ValidatorRegistrationRunner) ProcessPreConsensus(signedMsg *types.SignedPartialSignatureMessage) error

+ func (r *ValidatorRegistrationRunner) StartNewDuty(duty *types.Duty) error

v0.2.7

Nov 2, 2022

Changes in this version

+ func AggregatorValueCheckF(signer types.BeaconSigner, network types.BeaconNetwork, ...) qbft.ProposedValueCheckF

+ func AttesterValueCheckF(signer types.BeaconSigner, network types.BeaconNetwork, ...) qbft.ProposedValueCheckF

+ func ProposerValueCheckF(signer types.BeaconSigner, network types.BeaconNetwork, ...) qbft.ProposedValueCheckF

+ func SyncCommitteeContributionValueCheckF(signer types.BeaconSigner, network types.BeaconNetwork, ...) qbft.ProposedValueCheckF

+ func SyncCommitteeValueCheckF(signer types.BeaconSigner, network types.BeaconNetwork, ...) qbft.ProposedValueCheckF

+ type AggregatorRunner struct

+ BaseRunner *BaseRunner

+ func (r *AggregatorRunner) Decode(data []byte) error

+ func (r *AggregatorRunner) Encode() ([]byte, error)

+ func (r *AggregatorRunner) GetBaseRunner() *BaseRunner

+ func (r *AggregatorRunner) GetBeaconNode() BeaconNode

+ func (r *AggregatorRunner) GetNetwork() Network

+ func (r *AggregatorRunner) GetRoot() ([]byte, error)

+ func (r *AggregatorRunner) GetShare() *types.Share

+ func (r *AggregatorRunner) GetSigner() types.KeyManager

+ func (r *AggregatorRunner) GetState() *State

+ func (r *AggregatorRunner) GetValCheckF() qbft.ProposedValueCheckF

+ func (r *AggregatorRunner) HasRunningDuty() bool

+ func (r *AggregatorRunner) ProcessConsensus(signedMsg *qbft.SignedMessage) error

+ func (r *AggregatorRunner) ProcessPostConsensus(signedMsg *SignedPartialSignatureMessage) error

+ func (r *AggregatorRunner) ProcessPreConsensus(signedMsg *SignedPartialSignatureMessage) error

+ func (r *AggregatorRunner) StartNewDuty(duty *types.Duty) error

+ type AttesterRunner struct

+ BaseRunner *BaseRunner

+ func (r *AttesterRunner) Decode(data []byte) error

+ func (r *AttesterRunner) Encode() ([]byte, error)

+ func (r *AttesterRunner) GetBaseRunner() *BaseRunner

+ func (r *AttesterRunner) GetBeaconNode() BeaconNode

+ func (r *AttesterRunner) GetNetwork() Network

+ func (r *AttesterRunner) GetRoot() ([]byte, error)

+ func (r *AttesterRunner) GetShare() *types.Share

+ func (r *AttesterRunner) GetSigner() types.KeyManager

+ func (r *AttesterRunner) GetState() *State

+ func (r *AttesterRunner) GetValCheckF() qbft.ProposedValueCheckF

+ func (r *AttesterRunner) HasRunningDuty() bool

+ func (r *AttesterRunner) ProcessConsensus(signedMsg *qbft.SignedMessage) error

+ func (r *AttesterRunner) ProcessPostConsensus(signedMsg *SignedPartialSignatureMessage) error

+ func (r *AttesterRunner) ProcessPreConsensus(signedMsg *SignedPartialSignatureMessage) error

+ func (r *AttesterRunner) StartNewDuty(duty *types.Duty) error

+ type BaseRunner struct

+ BeaconNetwork types.BeaconNetwork

+ BeaconRoleType types.BeaconRole

+ QBFTController *qbft.Controller

+ Share *types.Share

+ State *State

+ func (b *BaseRunner) HashRunningDuty() bool

+ type DomainCalls interface

+ DomainData func(epoch phase0.Epoch, domain phase0.DomainType) (phase0.Domain, error)

+ type Getters interface

+ GetBaseRunner func() *BaseRunner

+ GetBeaconNode func() BeaconNode

+ GetNetwork func() Network

+ GetSigner func() types.KeyManager

+ GetValCheckF func() qbft.ProposedValueCheckF

type PartialSignatureMessage

+ Signer types.OperatorID

type PartialSignatureMessages

+ Messages []*PartialSignatureMessage

+ Type PartialSigMsgType

+ func (msgs PartialSignatureMessages) Validate() error

+ type ProposerRunner struct

+ BaseRunner *BaseRunner

+ func (r *ProposerRunner) Decode(data []byte) error

+ func (r *ProposerRunner) Encode() ([]byte, error)

+ func (r *ProposerRunner) GetBaseRunner() *BaseRunner

+ func (r *ProposerRunner) GetBeaconNode() BeaconNode

+ func (r *ProposerRunner) GetNetwork() Network

+ func (r *ProposerRunner) GetRoot() ([]byte, error)

+ func (r *ProposerRunner) GetShare() *types.Share

+ func (r *ProposerRunner) GetSigner() types.KeyManager

+ func (r *ProposerRunner) GetState() *State

+ func (r *ProposerRunner) GetValCheckF() qbft.ProposedValueCheckF

+ func (r *ProposerRunner) HasRunningDuty() bool

+ func (r *ProposerRunner) ProcessConsensus(signedMsg *qbft.SignedMessage) error

+ func (r *ProposerRunner) ProcessPostConsensus(signedMsg *SignedPartialSignatureMessage) error

+ func (r *ProposerRunner) ProcessPreConsensus(signedMsg *SignedPartialSignatureMessage) error

+ func (r *ProposerRunner) StartNewDuty(duty *types.Duty) error

type Runner

+ func NewAggregatorRunner(beaconNetwork types.BeaconNetwork, share *types.Share, ...) Runner

+ func NewAttesterRunnner(beaconNetwork types.BeaconNetwork, share *types.Share, ...) Runner

+ func NewProposerRunner(beaconNetwork types.BeaconNetwork, share *types.Share, ...) Runner

+ func NewSyncCommitteeAggregatorRunner(beaconNetwork types.BeaconNetwork, share *types.Share, ...) Runner

+ func NewSyncCommitteeRunner(beaconNetwork types.BeaconNetwork, share *types.Share, ...) Runner

+ HasRunningDuty func() bool

+ ProcessConsensus func(msg *qbft.SignedMessage) error

+ ProcessPostConsensus func(signedMsg *SignedPartialSignatureMessage) error

+ ProcessPreConsensus func(signedMsg *SignedPartialSignatureMessage) error

type SignedPartialSignatureMessage

+ Message PartialSignatureMessages

+ Signer types.OperatorID

type State

+ PostConsensusContainer *PartialSigContainer

+ PreConsensusContainer *PartialSigContainer

+ StartingDuty *types.Duty

+ func NewRunnerState(quorum uint64, duty *types.Duty) *State

+ func (pcs *State) ReconstructBeaconSig(container *PartialSigContainer, root, validatorPubKey []byte) ([]byte, error)

+ type SyncCommitteeAggregatorRunner struct

+ BaseRunner *BaseRunner

+ func (r *SyncCommitteeAggregatorRunner) Decode(data []byte) error

+ func (r *SyncCommitteeAggregatorRunner) Encode() ([]byte, error)

+ func (r *SyncCommitteeAggregatorRunner) GetBaseRunner() *BaseRunner

+ func (r *SyncCommitteeAggregatorRunner) GetBeaconNode() BeaconNode

+ func (r *SyncCommitteeAggregatorRunner) GetNetwork() Network

+ func (r *SyncCommitteeAggregatorRunner) GetRoot() ([]byte, error)

+ func (r *SyncCommitteeAggregatorRunner) GetShare() *types.Share

+ func (r *SyncCommitteeAggregatorRunner) GetSigner() types.KeyManager

+ func (r *SyncCommitteeAggregatorRunner) GetState() *State

+ func (r *SyncCommitteeAggregatorRunner) GetValCheckF() qbft.ProposedValueCheckF

+ func (r *SyncCommitteeAggregatorRunner) HasRunningDuty() bool

+ func (r *SyncCommitteeAggregatorRunner) ProcessConsensus(signedMsg *qbft.SignedMessage) error

+ func (r *SyncCommitteeAggregatorRunner) ProcessPostConsensus(signedMsg *SignedPartialSignatureMessage) error

+ func (r *SyncCommitteeAggregatorRunner) ProcessPreConsensus(signedMsg *SignedPartialSignatureMessage) error

+ func (r *SyncCommitteeAggregatorRunner) StartNewDuty(duty *types.Duty) error

+ type SyncCommitteeRunner struct

+ BaseRunner *BaseRunner

+ func (r *SyncCommitteeRunner) Decode(data []byte) error

+ func (r *SyncCommitteeRunner) Encode() ([]byte, error)

+ func (r *SyncCommitteeRunner) GetBaseRunner() *BaseRunner

+ func (r *SyncCommitteeRunner) GetBeaconNode() BeaconNode

+ func (r *SyncCommitteeRunner) GetNetwork() Network

+ func (r *SyncCommitteeRunner) GetRoot() ([]byte, error)

+ func (r *SyncCommitteeRunner) GetShare() *types.Share

+ func (r *SyncCommitteeRunner) GetSigner() types.KeyManager

+ func (r *SyncCommitteeRunner) GetState() *State

+ func (r *SyncCommitteeRunner) GetValCheckF() qbft.ProposedValueCheckF

+ func (r *SyncCommitteeRunner) HasRunningDuty() bool

+ func (r *SyncCommitteeRunner) ProcessConsensus(signedMsg *qbft.SignedMessage) error

+ func (r *SyncCommitteeRunner) ProcessPostConsensus(signedMsg *SignedPartialSignatureMessage) error

+ func (r *SyncCommitteeRunner) ProcessPreConsensus(signedMsg *SignedPartialSignatureMessage) error

+ func (r *SyncCommitteeRunner) StartNewDuty(duty *types.Duty) error

type Validator

+ Beacon BeaconNode

+ Network Network

+ Share *types.Share

+ Signer types.KeyManager

+ Storage Storage

v0.2.2

Aug 2, 2022

v0.1.1

Jul 12, 2022

Changes in this version

+ func AggregatorValueCheck(signer types.BeaconSigner, network types.BeaconNetwork) qbft.ProposedValueCheckF

+ func BeaconAttestationValueCheck(signer types.BeaconSigner, network types.BeaconNetwork) qbft.ProposedValueCheckF

+ func BeaconBlockValueCheck(signer types.BeaconSigner, network types.BeaconNetwork) qbft.ProposedValueCheckF

+ func SyncCommitteeContributionValueCheck(signer types.BeaconSigner, network types.BeaconNetwork) qbft.ProposedValueCheckF

+ func SyncCommitteeValueCheck(signer types.BeaconSigner, network types.BeaconNetwork) qbft.ProposedValueCheckF

+ type AggregatorCalls interface

+ SubmitAggregateSelectionProof func(slot phase0.Slot, committeeIndex phase0.CommitteeIndex, slotSig []byte) (*phase0.AggregateAndProof, error)

+ SubmitSignedAggregateSelectionProof func(msg *phase0.SignedAggregateAndProof) error

+ type AttesterCalls interface

+ GetAttestationData func(slot phase0.Slot, committeeIndex phase0.CommitteeIndex) (*phase0.AttestationData, error)

+ SubmitAttestation func(attestation *phase0.Attestation) error

+ type BeaconNode interface

+ GetBeaconNetwork func() types.BeaconNetwork

+ type DutyRunners map[types.BeaconRole]*Runner

+ func (ci DutyRunners) DutyRunnerForMsgID(msgID types.MessageID) *Runner

+ type Network interface

+ Broadcast func(message types.Encoder) error

+ type PartialSigContainer struct

+ Quorum uint64

+ Signatures map[string]map[types.OperatorID][]byte

+ func NewPartialSigContainer(quorum uint64) *PartialSigContainer

+ func (ps *PartialSigContainer) AddSignature(sigMsg *PartialSignatureMessage) error

+ func (ps *PartialSigContainer) HasQuorum(root []byte) bool

+ func (ps *PartialSigContainer) ReconstructSignature(root, validatorPubKey []byte) ([]byte, error)

+ type PartialSigMsgType uint64

+ const ContributionProofs

+ const PostConsensusPartialSig

+ const RandaoPartialSig

+ const SelectionProofPartialSig

+ type PartialSignatureMessage struct

+ MetaData *PartialSignatureMetaData

+ PartialSignature []byte

+ Signers []types.OperatorID

+ SigningRoot []byte

+ Slot spec.Slot

+ func (pcsm *PartialSignatureMessage) Decode(data []byte) error

+ func (pcsm *PartialSignatureMessage) Encode() ([]byte, error)

+ func (pcsm *PartialSignatureMessage) GetRoot() ([]byte, error)

+ func (pcsm *PartialSignatureMessage) Validate() error

+ type PartialSignatureMessages []*PartialSignatureMessage

+ func (msgs *PartialSignatureMessages) Decode(data []byte) error

+ func (msgs *PartialSignatureMessages) Encode() ([]byte, error)

+ func (msgs PartialSignatureMessages) GetRoot() ([]byte, error)

+ type PartialSignatureMetaData struct

+ ContributionSubCommitteeIndex uint64

+ type ProposerCalls interface

+ GetBeaconBlock func(slot phase0.Slot, committeeIndex phase0.CommitteeIndex, ...) (*altair.BeaconBlock, error)

+ SubmitBeaconBlock func(block *altair.SignedBeaconBlock) error

+ type Runner struct

+ BeaconNetwork types.BeaconNetwork

+ BeaconRoleType types.BeaconRole

+ CurrentDuty *types.Duty

+ QBFTController *qbft.Controller

+ Share *types.Share

+ State *State

+ func NewDutyRunner(beaconRoleType types.BeaconRole, beaconNetwork types.BeaconNetwork, ...) *Runner

+ func (dr *Runner) CanStartNewDuty(duty *types.Duty) error

+ func (dr *Runner) Decide(input *types.ConsensusData) error

+ func (dr *Runner) Decode(data []byte) error

+ func (dr *Runner) Encode() ([]byte, error)

+ func (dr *Runner) GetRoot() ([]byte, error)

+ func (dr *Runner) ProcessConsensusMessage(msg *qbft.SignedMessage) (decided bool, decidedValue *types.ConsensusData, err error)

+ func (dr *Runner) ProcessContributionProofsMessage(signedMsg *SignedPartialSignatureMessage) (bool, [][]byte, error)

+ func (dr *Runner) ProcessPostConsensusMessage(signedMsg *SignedPartialSignatureMessage) (bool, [][]byte, error)

+ func (dr *Runner) ProcessRandaoMessage(signedMsg *SignedPartialSignatureMessage) (bool, [][]byte, error)

+ func (dr *Runner) ProcessSelectionProofMessage(signedMsg *SignedPartialSignatureMessage) (bool, [][]byte, error)

+ func (dr *Runner) SignDutyPostConsensus(decidedValue *types.ConsensusData, signer types.KeyManager) (PartialSignatureMessages, error)

+ func (dr *Runner) SignRandaoPreConsensus(epoch spec.Epoch, slot spec.Slot, signer types.KeyManager) (*PartialSignatureMessage, error)

+ func (dr *Runner) SignSlotWithSelectionProofPreConsensus(slot spec.Slot, signer types.KeyManager) (*PartialSignatureMessage, error)

+ func (dr *Runner) SignSyncSubCommitteeContributionProof(slot spec.Slot, indexes []uint64, signer types.KeyManager) (PartialSignatureMessages, error)

+ func (dr *Runner) StartNewDuty(duty *types.Duty) error

+ type SignedPartialSignatureMessage struct

+ Messages PartialSignatureMessages

+ Signature types.Signature

+ Signers []types.OperatorID

+ Type PartialSigMsgType

+ func (spcsm *SignedPartialSignatureMessage) Aggregate(signedMsg types.MessageSignature) error

+ func (spcsm *SignedPartialSignatureMessage) Decode(data []byte) error

+ func (spcsm *SignedPartialSignatureMessage) Encode() ([]byte, error)

+ func (spcsm *SignedPartialSignatureMessage) GetRoot() ([]byte, error)

+ func (spcsm *SignedPartialSignatureMessage) GetSignature() types.Signature

+ func (spcsm *SignedPartialSignatureMessage) GetSigners() []types.OperatorID

+ func (spcsm *SignedPartialSignatureMessage) MatchedSigners(ids []types.OperatorID) bool

+ func (spcsm *SignedPartialSignatureMessage) Validate() error

+ type State struct

+ ContributionProofs *PartialSigContainer

+ ContributionSubCommitteeIndexes map[string]uint64

+ DecidedValue *types.ConsensusData

+ Finished bool

+ PostConsensusPartialSig *PartialSigContainer

+ RandaoPartialSig *PartialSigContainer

+ RunningInstance *qbft.Instance

+ SelectionProofPartialSig *PartialSigContainer

+ SignedAggregate *spec.SignedAggregateAndProof

+ SignedAttestation *spec.Attestation

+ SignedContributions map[string]*altair.SignedContributionAndProof

+ SignedProposal *altair.SignedBeaconBlock

+ SignedSyncCommittee *altair.SyncCommitteeMessage

+ func NewDutyExecutionState(quorum uint64) *State

+ func (pcs *State) Decode(data []byte) error

+ func (pcs *State) Encode() ([]byte, error)

+ func (pcs *State) GetRoot() ([]byte, error)

+ func (pcs *State) ReconstructAttestationSig(root, validatorPubKey []byte) (*spec.Attestation, error)

+ func (pcs *State) ReconstructBeaconBlockSig(root, validatorPubKey []byte) (*altair.SignedBeaconBlock, error)

+ func (pcs *State) ReconstructContributionProofSig(root, validatorPubKey []byte) ([]byte, uint64, error)

+ func (pcs *State) ReconstructContributionSig(root, validatorPubKey []byte) (*altair.SignedContributionAndProof, error)

+ func (pcs *State) ReconstructRandaoSig(root, validatorPubKey []byte) ([]byte, error)

+ func (pcs *State) ReconstructSelectionProofSig(root, validatorPubKey []byte) ([]byte, error)

+ func (pcs *State) ReconstructSignedAggregateSelectionProofSig(root, validatorPubKey []byte) (*spec.SignedAggregateAndProof, error)

+ func (pcs *State) ReconstructSyncCommitteeSig(root, validatorPubKey []byte) (*altair.SyncCommitteeMessage, error)

+ type Storage interface

+ type SyncCommitteeCalls interface

+ GetSyncMessageBlockRoot func() (phase0.Root, error)

+ SubmitSyncMessage func(msg *altair.SyncCommitteeMessage) error

+ type SyncCommitteeContributionCalls interface

+ GetSyncCommitteeContribution func(slot phase0.Slot, subnetID uint64, pubKey phase0.BLSPubKey) (*altair.SyncCommitteeContribution, error)

+ GetSyncSubcommitteeIndex func(slot phase0.Slot, pubKey phase0.BLSPubKey) ([]uint64, error)

+ IsSyncCommitteeAggregator func(proof []byte) (bool, error)

+ SubmitSignedContributionAndProof func(contribution *altair.SignedContributionAndProof) error

+ SyncCommitteeSubnetID func(subCommitteeID uint64) (uint64, error)

+ type Validator struct

+ DutyRunners DutyRunners

+ func NewValidator(network Network, beacon BeaconNode, storage Storage, share *types.Share, ...) *Validator

+ func (v *Validator) ProcessMessage(msg *types.SSVMessage) error

+ func (v *Validator) StartDuty(duty *types.Duty) error

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