pacemaker

package
v0.0.0-...-2e52d37 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 18, 2022 License: MIT Imports: 7 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL