Versions in this module Expand all Collapse all v1 v1.0.0 Nov 19, 2020 Changes in this version + const KeyAccountGasFeeRewards + const KeyAccountProposerRewards + const KeyAccountValidatorRewards + const KeyTotalGasFeeRewards + const KeyTotalProposerRewards + const KeyTotalValidatorRewards + var EngineMessageType_name = map[int32]string + var EngineMessageType_value = map[string]int32 + var ErrIntOverflowEngine = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthEngine = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupEngine = fmt.Errorf("proto: unexpected end of group") + var GasFeeAddress = common.HexToAddress("0xdddddddddddddddddddddddddddddddddddddddd") + var Multiplier = big.NewInt(1e18) + var ProposerReward = new(big.Int).Mul(big.NewInt(1000), big.NewInt(params.Ether)) + var TotalValidatorReward = new(big.Int).Mul(big.NewInt(3000), big.NewInt(params.Ether)) + func PrintPanicStack() + func PubKeyToIdentity(pubkey *ecdsa.PublicKey) (ret bdls.Identity) + type API struct + func (api *API) GetAccountGasFeeRewards(account common.Address) (total *big.Int, err error) + func (api *API) GetAccountProposerRewards(account common.Address) (total *big.Int, err error) + func (api *API) GetAccountValidatorRewards(account common.Address) (total *big.Int, err error) + func (api *API) GetStaker(account common.Address) (stakers *committee.Staker, err error) + func (api *API) GetStakers() (stakers []*committee.Staker, err error) + func (api *API) GetTotalGasFeeRewards() (total *big.Int, err error) + func (api *API) GetTotalProposerRewards() (total *big.Int, err error) + func (api *API) GetTotalStaked() (total *big.Int, err error) + func (api *API) GetTotalStakingOperations() (count uint64, err error) + func (api *API) GetTotalValidatorRewards() (total *big.Int, err error) + func (api *API) GetValidators(number *rpc.BlockNumber) ([]common.Address, error) + func (api *API) GetValidatorsAtHash(hash common.Hash) ([]common.Address, error) + func (api *API) Version() string + type BDLSEngine struct + func New(accountManager *accounts.Manager, mux *event.TypeMux, db ethdb.Database) *BDLSEngine + func (e *BDLSEngine) APIs(chain consensus.ChainReader) []rpc.API + func (e *BDLSEngine) Author(header *types.Header) (common.Address, error) + func (e *BDLSEngine) CalcDifficulty(chain consensus.ChainReader, time uint64, parent *types.Header) *big.Int + func (e *BDLSEngine) Close() error + func (e *BDLSEngine) Finalize(chain consensus.ChainReader, header *types.Header, state *state.StateDB, ...) + func (e *BDLSEngine) FinalizeAndAssemble(chain consensus.ChainReader, header *types.Header, state *state.StateDB, ...) (*types.Block, error) + func (e *BDLSEngine) Prepare(chain consensus.ChainReader, header *types.Header) error + func (e *BDLSEngine) Seal(chain consensus.ChainReader, block *types.Block, results chan<- *types.Block, ...) error + func (e *BDLSEngine) SealHash(header *types.Header) (hash common.Hash) + func (e *BDLSEngine) SetBlockValidator(hasBadBlock func(common.Hash) bool, ...) + func (e *BDLSEngine) VerifyHeader(chain consensus.ChainReader, header *types.Header, seal bool) error + func (e *BDLSEngine) VerifyHeaders(chain consensus.ChainReader, headers []*types.Header, seals []bool) (chan<- struct{}, <-chan error) + func (e *BDLSEngine) VerifySeal(chain consensus.ChainReader, header *types.Header) error + func (e *BDLSEngine) VerifyUncles(chain consensus.ChainReader, block *types.Block) error + type EngineMessage struct + Message []byte + Nonce uint32 + Type EngineMessageType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EngineMessage) Descriptor() ([]byte, []int) + func (*EngineMessage) ProtoMessage() + func (m *EngineMessage) GetMessage() []byte + func (m *EngineMessage) GetNonce() uint32 + func (m *EngineMessage) GetType() EngineMessageType + func (m *EngineMessage) Marshal() (dAtA []byte, err error) + func (m *EngineMessage) MarshalTo(dAtA []byte) (int, error) + func (m *EngineMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EngineMessage) Reset() + func (m *EngineMessage) Size() (n int) + func (m *EngineMessage) String() string + func (m *EngineMessage) Unmarshal(dAtA []byte) error + func (m *EngineMessage) XXX_DiscardUnknown() + func (m *EngineMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EngineMessage) XXX_Merge(src proto.Message) + func (m *EngineMessage) XXX_Size() int + func (m *EngineMessage) XXX_Unmarshal(b []byte) error + type EngineMessageType int32 + const EngineMessageType_Consensus + const EngineMessageType_Proposal + func (EngineMessageType) EnumDescriptor() ([]byte, []int) + func (x EngineMessageType) String() string + type MessageInput []byte + type MessageOutput []byte