streamlet

func (*Streamlet) GetChainStatus ¶

func (sl *Streamlet) GetChainStatus() string

func (*Streamlet) GetNotarizedHeight ¶

func (sl *Streamlet) GetNotarizedHeight() int

func (*Streamlet) MakeProposal ¶

func (sl *Streamlet) MakeProposal(view types.View, payload []*message.Transaction) *blockchain.Block

func (*Streamlet) ProcessBlock ¶

func (sl *Streamlet) ProcessBlock(block *blockchain.Block) error

ProcessBlock processes an incoming block as follows: 1. check if the view of the block matches current view (ignore for now) 2. check if the view of the block matches the proposer's view (ignore for now) 3. insert the block into the block tree 4. if the view of the block is lower than the current view, don't vote 5. if the block is extending the longest notarized chain, vote for the block 6. if the view of the block is higher than the the current view, buffer the block and process it when entering that view

func (*Streamlet) ProcessLocalTmo ¶

func (sl *Streamlet) ProcessLocalTmo(view types.View)

func (*Streamlet) ProcessRemoteTmo ¶

func (sl *Streamlet) ProcessRemoteTmo(tmo *pacemaker.TMO)

func (*Streamlet) ProcessVote ¶

func (sl *Streamlet) ProcessVote(vote *blockchain.Vote)