enodes

Apr 19, 2021

Changes in this version

+ type ValEnodeEntryInfo struct

+ Enode string

+ HighestKnownVersion uint

+ LastQueryTimestamp string

+ NumQueryAttemptsForHKVersion uint

+ PublicKey string

+ Version uint

+ type ValidatorEnodeDB struct

+ func OpenValidatorEnodeDB(path string, handler ValidatorEnodeHandler) (*ValidatorEnodeDB, error)

+ func (vet *ValidatorEnodeDB) Close() error

+ func (vet *ValidatorEnodeDB) GetAddressFromNodeID(nodeID enode.ID) (common.Address, error)

+ func (vet *ValidatorEnodeDB) GetHighestKnownVersionFromAddress(address common.Address) (uint, error)

+ func (vet *ValidatorEnodeDB) GetNodeFromAddress(address common.Address) (*enode.Node, error)

+ func (vet *ValidatorEnodeDB) GetValEnodes(valAddresses []common.Address) (map[common.Address]*istanbul.AddressEntry, error)

+ func (vet *ValidatorEnodeDB) GetVersionFromAddress(address common.Address) (uint, error)

+ func (vet *ValidatorEnodeDB) PruneEntries(addressesToKeep map[common.Address]bool) error

+ func (vet *ValidatorEnodeDB) RefreshValPeers(valConnSet map[common.Address]bool, ourAddress common.Address)

+ func (vet *ValidatorEnodeDB) RemoveEntry(address common.Address) error

+ func (vet *ValidatorEnodeDB) String() string

+ func (vet *ValidatorEnodeDB) UpdateQueryEnodeStats(valEnodeEntries []*istanbul.AddressEntry) error

+ func (vet *ValidatorEnodeDB) UpsertHighestKnownVersion(valEnodeEntries []*istanbul.AddressEntry) error

+ func (vet *ValidatorEnodeDB) UpsertVersionAndEnode(valEnodeEntries []*istanbul.AddressEntry) error

+ func (vet *ValidatorEnodeDB) ValEnodeTableInfo() (map[string]*ValEnodeEntryInfo, error)

+ type ValidatorEnodeHandler interface

+ AddValidatorPeer func(node *enode.Node, address common.Address)

+ ClearValidatorPeers func()

+ RemoveValidatorPeer func(node *enode.Node)

+ ReplaceValidatorPeers func(newNodes []*enode.Node)

+ type VersionCertificateDB struct

+ func OpenVersionCertificateDB(path string) (*VersionCertificateDB, error)

+ func (svdb *VersionCertificateDB) Close() error

+ func (svdb *VersionCertificateDB) Get(address common.Address) (*VersionCertificateEntry, error)

+ func (svdb *VersionCertificateDB) GetAll() ([]*VersionCertificateEntry, error)

+ func (svdb *VersionCertificateDB) GetVersion(address common.Address) (uint, error)

+ func (svdb *VersionCertificateDB) Info() (map[string]*VersionCertificateEntryInfo, error)

+ func (svdb *VersionCertificateDB) Prune(addressesToKeep map[common.Address]bool) error

+ func (svdb *VersionCertificateDB) Remove(address common.Address) error

+ func (svdb *VersionCertificateDB) String() string

+ func (svdb *VersionCertificateDB) Upsert(savEntries []*VersionCertificateEntry) ([]*VersionCertificateEntry, error)

+ type VersionCertificateEntry struct

+ Address common.Address

+ PublicKey *ecdsa.PublicKey

+ Signature []byte

+ Version uint

+ func (entry *VersionCertificateEntry) DecodeRLP(s *rlp.Stream) error

+ func (entry *VersionCertificateEntry) EncodeRLP(w io.Writer) error

+ func (entry *VersionCertificateEntry) String() string

+ type VersionCertificateEntryInfo struct

+ Address string

+ Version uint