Documentation
¶
Index ¶
- func IsAckSignValidate(va *protos.ConfirmAckBlock) bool
- type ActiveTrx
- type BlockProcessor
- type DposService
- func (dps *DposService) GetAccountPrv(account types.Address) (*types.Account, error)
- func (dps *DposService) GetOnlineRepresentatives() []types.Address
- func (dps *DposService) GetP2PService() p2p.Service
- func (dps *DposService) Init() error
- func (dps *DposService) ReceiveConfirmAck(v interface{})
- func (dps *DposService) ReceiveConfirmReq(v interface{})
- func (dps *DposService) ReceivePublish(v interface{})
- func (dps *DposService) ReceiveSyncBlock(v interface{})
- func (dps *DposService) SetWalletStore(wallet *wallet.WalletStore)
- func (dps *DposService) Start() error
- func (dps *DposService) Status() int32
- func (dps *DposService) Stop() error
- type Election
- type Votes
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsAckSignValidate ¶
func IsAckSignValidate(va *protos.ConfirmAckBlock) bool
Types ¶
type ActiveTrx ¶
type ActiveTrx struct {
// contains filtered or unexported fields
}
func NewActiveTrx ¶
func NewActiveTrx() *ActiveTrx
func (*ActiveTrx) SetDposService ¶
func (act *ActiveTrx) SetDposService(dps *DposService)
type BlockProcessor ¶
type BlockProcessor struct {
// contains filtered or unexported fields
}
func NewBlockProcessor ¶
func NewBlockProcessor() *BlockProcessor
func (*BlockProcessor) SetDpos ¶
func (bp *BlockProcessor) SetDpos(dp *DposService)
func (*BlockProcessor) Start ¶
func (bp *BlockProcessor) Start()
func (*BlockProcessor) Stop ¶
func (bp *BlockProcessor) Stop()
type DposService ¶
type DposService struct { common.ServiceLifecycle // contains filtered or unexported fields }
func NewDposService ¶
func (*DposService) GetAccountPrv ¶
func (*DposService) GetOnlineRepresentatives ¶ added in v0.0.2
func (dps *DposService) GetOnlineRepresentatives() []types.Address
func (*DposService) GetP2PService ¶ added in v0.0.2
func (dps *DposService) GetP2PService() p2p.Service
func (*DposService) Init ¶
func (dps *DposService) Init() error
func (*DposService) ReceiveConfirmAck ¶
func (dps *DposService) ReceiveConfirmAck(v interface{})
func (*DposService) ReceiveConfirmReq ¶
func (dps *DposService) ReceiveConfirmReq(v interface{})
func (*DposService) ReceivePublish ¶
func (dps *DposService) ReceivePublish(v interface{})
func (*DposService) ReceiveSyncBlock ¶
func (dps *DposService) ReceiveSyncBlock(v interface{})
func (*DposService) SetWalletStore ¶
func (dps *DposService) SetWalletStore(wallet *wallet.WalletStore)
func (*DposService) Start ¶
func (dps *DposService) Start() error
func (*DposService) Status ¶
func (dps *DposService) Status() int32
func (*DposService) Stop ¶
func (dps *DposService) Stop() error
type Election ¶
type Election struct {
// contains filtered or unexported fields
}
func NewElection ¶
func NewElection(dps *DposService, block types.Block) (*Election, error)
Click to show internal directories.
Click to hide internal directories.