Versions in this module Expand all Collapse all v0 v0.0.4 Jan 15, 2025 v0.0.1 Jan 15, 2025 Changes in this version + var NoProposerSettingsFound = errors.New("no proposer settings found in bucket") + var ProtectionDbFileName = "validator.db" + type AttestationRecord struct + PubKey [fieldparams.BLSPubkeyLength]byte + SigningRoot [32]byte + Source primitives.Epoch + Target primitives.Epoch + type AttestationRecordSaveRequest struct + type Config struct + PubKeys [][fieldparams.BLSPubkeyLength]byte + type Proposal struct + SigningRoot []byte + Slot primitives.Slot + type ProposalHistoryForPubkey struct + Proposals []Proposal + type QueuedAttestationRecords struct + func NewQueuedAttestationRecords() *QueuedAttestationRecords + func (p *QueuedAttestationRecords) Append(ar *AttestationRecord) + func (p *QueuedAttestationRecords) Flush() []*AttestationRecord + func (p *QueuedAttestationRecords) Len() int + type SlashingKind int + const DoubleVote + const NotSlashable + const SurroundedVote + const SurroundingVote + type Store struct + func NewKVStore(ctx context.Context, dirPath string, config *Config) (*Store, error) + func (s *Store) AttestationHistoryForPubKey(ctx context.Context, pubKey [fieldparams.BLSPubkeyLength]byte) ([]*AttestationRecord, error) + func (s *Store) AttestedPublicKeys(ctx context.Context) ([][fieldparams.BLSPubkeyLength]byte, error) + func (s *Store) Backup(ctx context.Context, outputDir string, permissionOverride bool) error + func (s *Store) CheckSlashableAttestation(ctx context.Context, pubKey [fieldparams.BLSPubkeyLength]byte, ...) (SlashingKind, error) + func (s *Store) ClearDB() error + func (s *Store) Close() error + func (s *Store) DatabasePath() string + func (s *Store) EIPImportBlacklistedPublicKeys(ctx context.Context) ([][fieldparams.BLSPubkeyLength]byte, error) + func (s *Store) GenesisValidatorsRoot(_ context.Context) ([]byte, error) + func (s *Store) GraffitiOrderedIndex(_ context.Context, fileHash [32]byte) (uint64, error) + func (s *Store) HighestSignedProposal(ctx context.Context, publicKey [fieldparams.BLSPubkeyLength]byte) (primitives.Slot, bool, error) + func (s *Store) LowestSignedProposal(ctx context.Context, publicKey [fieldparams.BLSPubkeyLength]byte) (primitives.Slot, bool, error) + func (s *Store) LowestSignedSourceEpoch(ctx context.Context, publicKey [fieldparams.BLSPubkeyLength]byte) (primitives.Epoch, bool, error) + func (s *Store) LowestSignedTargetEpoch(ctx context.Context, publicKey [fieldparams.BLSPubkeyLength]byte) (primitives.Epoch, bool, error) + func (s *Store) ProposalHistoryForPubKey(ctx context.Context, publicKey [fieldparams.BLSPubkeyLength]byte) ([]*Proposal, error) + func (s *Store) ProposalHistoryForSlot(ctx context.Context, publicKey [fieldparams.BLSPubkeyLength]byte, ...) ([32]byte, bool, error) + func (s *Store) ProposedPublicKeys(ctx context.Context) ([][fieldparams.BLSPubkeyLength]byte, error) + func (s *Store) ProposerSettings(ctx context.Context) (*validatorServiceConfig.ProposerSettings, error) + func (s *Store) ProposerSettingsExists(ctx context.Context) (bool, error) + func (s *Store) PruneAttestations(ctx context.Context) error + func (s *Store) RunDownMigrations(ctx context.Context) error + func (s *Store) RunUpMigrations(ctx context.Context) error + func (s *Store) SaveAttestationForPubKey(ctx context.Context, pubKey [fieldparams.BLSPubkeyLength]byte, ...) error + func (s *Store) SaveAttestationsForPubKey(ctx context.Context, pubKey [fieldparams.BLSPubkeyLength]byte, ...) error + func (s *Store) SaveEIPImportBlacklistedPublicKeys(ctx context.Context, publicKeys [][fieldparams.BLSPubkeyLength]byte) error + func (s *Store) SaveGenesisValidatorsRoot(_ context.Context, genValRoot []byte) error + func (s *Store) SaveGraffitiOrderedIndex(_ context.Context, index uint64) error + func (s *Store) SaveProposalHistoryForSlot(ctx context.Context, pubKey [fieldparams.BLSPubkeyLength]byte, ...) error + func (s *Store) SaveProposerSettings(ctx context.Context, settings *validatorServiceConfig.ProposerSettings) error + func (s *Store) SigningRootAtTargetEpoch(ctx context.Context, pubKey [fieldparams.BLSPubkeyLength]byte, ...) ([32]byte, error) + func (s *Store) Size() (int64, error) + func (s *Store) UpdateProposerSettingsDefault(ctx context.Context, options *validatorServiceConfig.ProposerOption) error + func (s *Store) UpdateProposerSettingsForPubkey(ctx context.Context, pubkey [fieldparams.BLSPubkeyLength]byte, ...) error + func (s *Store) UpdatePublicKeysBuckets(pubKeys [][fieldparams.BLSPubkeyLength]byte) error