pacemaker

Documentation

Index

• type Pacemaker
  • func NewPacemaker(n int) *Pacemaker
  • func (p *Pacemaker) AdvanceView(view types.View)
  • func (p *Pacemaker) EnteringViewEvent() chan types.View
  • func (p *Pacemaker) GetCurView() types.View
  • func (p *Pacemaker) GetTimerForView() time.Duration
  • func (p *Pacemaker) ProcessRemoteTmo(tmo *TMO) (bool, *TC)
• type TC
  • func NewTC(view types.View, requesters map[identity.NodeID]*TMO) *TC
• type TMO
• type TimeoutController
  • func NewTimeoutController(n int) *TimeoutController
  • func (tcl *TimeoutController) AddTmo(tmo *TMO) (bool, *TC)

Types

type Pacemaker

type Pacemaker struct {
	// contains filtered or unexported fields
}

func NewPacemaker

func NewPacemaker(n int) *Pacemaker

func (*Pacemaker) AdvanceView

func (p *Pacemaker) AdvanceView(view types.View)

func (*Pacemaker) EnteringViewEvent

func (p *Pacemaker) EnteringViewEvent() chan types.View

func (*Pacemaker) GetCurView

func (p *Pacemaker) GetCurView() types.View

func (*Pacemaker) GetTimerForView

func (p *Pacemaker) GetTimerForView() time.Duration

func (*Pacemaker) ProcessRemoteTmo

func (p *Pacemaker) ProcessRemoteTmo(tmo *TMO) (bool, *TC)

type TC

type TC struct {
	types.View
	crypto.AggSig
	crypto.Signature
}

func NewTC

func NewTC(view types.View, requesters map[identity.NodeID]*TMO) *TC

type TMO

type TMO struct {
	View   types.View
	NodeID identity.NodeID
	HighQC *blockchain.QC
}

type TimeoutController

type TimeoutController struct {
	// contains filtered or unexported fields
}

func NewTimeoutController

func NewTimeoutController(n int) *TimeoutController

func (*TimeoutController) AddTmo

func (tcl *TimeoutController) AddTmo(tmo *TMO) (bool, *TC)