Documentation ¶
Index ¶
- func NewPacemaker(e *EventDrivenHotStuffImpl) *pacemakerImpl
- type Event
- type EventDrivenHotStuff
- type EventDrivenHotStuffImpl
- func (ehs *EventDrivenHotStuffImpl) GetEvents() chan Event
- func (ehs *EventDrivenHotStuffImpl) GetHeight() uint64
- func (ehs *EventDrivenHotStuffImpl) GetHighQC() *pb.QuorumCert
- func (ehs *EventDrivenHotStuffImpl) GetLeaf() *pb.Block
- func (ehs *EventDrivenHotStuffImpl) GetVHeight() uint64
- func (ehs *EventDrivenHotStuffImpl) OnCommit(block *pb.Block)
- func (ehs *EventDrivenHotStuffImpl) OnPropose()
- func (ehs *EventDrivenHotStuffImpl) OnReceiveProposal(msg *pb.Prepare) (*tcrsa.SigShare, error)
- func (ehs *EventDrivenHotStuffImpl) OnReceiveVote(partSig *tcrsa.SigShare)
- func (ehs *EventDrivenHotStuffImpl) SafeExit()
- func (ehs *EventDrivenHotStuffImpl) SetLeaf(b *pb.Block)
- func (ehs *EventDrivenHotStuffImpl) Update(block *pb.Block)
- type Pacemaker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewPacemaker ¶
func NewPacemaker(e *EventDrivenHotStuffImpl) *pacemakerImpl
Types ¶
type EventDrivenHotStuff ¶
type EventDrivenHotStuffImpl ¶
type EventDrivenHotStuffImpl struct { consensus.HotStuffImpl // contains filtered or unexported fields }
func NewEventDrivenHotStuff ¶
func NewEventDrivenHotStuff(id int, handleMethod func(string) string) *EventDrivenHotStuffImpl
func (*EventDrivenHotStuffImpl) GetEvents ¶
func (ehs *EventDrivenHotStuffImpl) GetEvents() chan Event
func (*EventDrivenHotStuffImpl) GetHeight ¶
func (ehs *EventDrivenHotStuffImpl) GetHeight() uint64
func (*EventDrivenHotStuffImpl) GetHighQC ¶
func (ehs *EventDrivenHotStuffImpl) GetHighQC() *pb.QuorumCert
func (*EventDrivenHotStuffImpl) GetLeaf ¶
func (ehs *EventDrivenHotStuffImpl) GetLeaf() *pb.Block
func (*EventDrivenHotStuffImpl) GetVHeight ¶
func (ehs *EventDrivenHotStuffImpl) GetVHeight() uint64
func (*EventDrivenHotStuffImpl) OnCommit ¶
func (ehs *EventDrivenHotStuffImpl) OnCommit(block *pb.Block)
func (*EventDrivenHotStuffImpl) OnPropose ¶
func (ehs *EventDrivenHotStuffImpl) OnPropose()
func (*EventDrivenHotStuffImpl) OnReceiveProposal ¶
func (*EventDrivenHotStuffImpl) OnReceiveVote ¶
func (ehs *EventDrivenHotStuffImpl) OnReceiveVote(partSig *tcrsa.SigShare)
func (*EventDrivenHotStuffImpl) SafeExit ¶
func (ehs *EventDrivenHotStuffImpl) SafeExit()
func (*EventDrivenHotStuffImpl) SetLeaf ¶
func (ehs *EventDrivenHotStuffImpl) SetLeaf(b *pb.Block)
func (*EventDrivenHotStuffImpl) Update ¶
func (ehs *EventDrivenHotStuffImpl) Update(block *pb.Block)
Update update blocks before block
type Pacemaker ¶
type Pacemaker interface { UpdateHighQC(qcHigh *pb.QuorumCert) OnBeat() OnNextSyncView() OnReceiverNewView(qc *pb.QuorumCert) Run(ctx context.Context) }
Click to show internal directories.
Click to hide internal directories.