validator

Apr 7, 2022

Changes in this version

type Controller

+ Eth1EventHandler func(handlers ...ShareEventHandlerFunc) eth1.SyncEventHandler

+ GetAllValidatorShares func() ([]*validatorstorage.Share, error)

type ControllerOptions

+ OperatorPubKey string

+ RegistryStorage registrystorage.OperatorsCollection

+ type ShareEventHandlerFunc func(share *validatorstorage.Share)

Jan 18, 2022

Changes in this version

type Controller

+ StartNetworkMediators func()

type Validator

+ func (v *Validator) GetMsgResolver(networkMsg network.NetworkMsg) func(msg *proto.SignedMessage)

Dec 15, 2021

Changes in this version

type ControllerOptions

+ HistorySyncRateLimit time.Duration

type Options

+ SyncRateLimit time.Duration

Nov 30, 2021

Changes in this version

+ type Controller interface

+ GetValidator func(pubKey string) (*Validator, bool)

+ GetValidatorsIndices func() []spec.ValidatorIndex

+ ListenToEth1Events func(feed *event.Feed)

+ ProcessEth1Event func(e eth1.Event) error

+ StartValidators func()

+ UpdateValidatorMetaDataLoop func()

Nov 22, 2021

Changes in this version

+ func UpdateShareMetadata(share *validatorstorage.Share, bc beacon.Beacon) (bool, error)

Nov 3, 2021

Changes in this version

type ControllerOptions

+ KeyManager beacon.KeyManager

type Options

+ Signer beacon.Signer

Oct 11, 2021

Changes in this version

+ func ReportIBFTStatus(pk string, finished, errorFound bool)

type ControllerOptions

+ Fork forks.Fork

+ MetadataUpdateInterval time.Duration

type IController

+ UpdateValidatorMetaDataLoop func()

type Options

+ Fork forks.Fork

Sep 24, 2021

Changes in this version

+ func ReportValidatorStatus(pk string, meta *beacon.ValidatorMetadata, logger *zap.Logger)

+ func ReportValidatorStatusReady(pk string)

Sep 13, 2021

Changes in this version

type ControllerOptions

+ CleanRegistryData bool

type IController

+ ProcessEth1Event func(e eth1.Event) error

Sep 6, 2021

Changes in this version

type ControllerOptions

+ RegistryResync bool

type Options

+ DB basedb.IDb

Jul 14, 2021

Changes in this version

type IController

+ GetValidatorsIndices func() []spec.ValidatorIndex

Jul 14, 2021

Changes in this version

type ControllerOptions

+ ShareEncryptionKeyProvider eth1.ShareEncryptionKeyProvider

type Validator

+ func (v *Validator) GetIBFT(r beacon.Role) (ibft.IBFT, bool)

Jul 1, 2021

Changes in this version

+ func IdentifierFormat(pubKey []byte, role beacon.Role) string

+ func ShareFromValidatorAddedEvent(validatorAddedEvent eth1.ValidatorAddedEvent) (*validatorstorage.Share, error)

Jun 10, 2021

Changes in this version

type IController

+ NewValidatorSubject func() pubsub.Subscriber

Jun 8, 2021

Changes in this version

+ func GenerateNodes(cnt int) (map[uint64]*bls.SecretKey, map[uint64]*proto.Node)

+ type ControllerOptions struct

+ Beacon beacon.Beacon

+ Context context.Context

+ DB basedb.IDb

+ ETHNetwork *core.Network

+ Logger *zap.Logger

+ Network network.Network

+ Shares []validatorstorage.ShareOptions

+ SignatureCollectionTimeout time.Duration

+ SlotQueue slotqueue.Queue

+ type IController interface

+ GetValidator func(pubKey string) (*Validator, bool)

+ GetValidatorsPubKeys func() [][]byte

+ ListenToEth1Events func(cn pubsub.SubjectChannel)

+ StartValidators func() map[string]*Validator

+ Subject func() pubsub.Subscriber

+ func NewController(options ControllerOptions) IController

+ type Options struct

+ Beacon beacon.Beacon

+ Context context.Context

+ ETHNetwork *core.Network

+ Logger *zap.Logger

+ Network network.Network

+ Share *storage.Share

+ SignatureCollectionTimeout time.Duration

+ SlotQueue slotqueue.Queue

+ type Validator struct

+ Share *storage.Share

+ func New(opt Options, ibftStorage collections.Iibft) *Validator

+ func (v *Validator) ExecuteDuty(ctx context.Context, slot uint64, duty *ethpb.DutiesResponse_Duty)

+ func (v *Validator) Start() error