timer

package

v0.4.0 Latest Latest Go to latest Published: Jul 1, 2020 License: GPL-3.0 Imports: 4 Imported by: 0

Details

View Source

const (
	DefaultTimeout        = 20 * time.Second
	DefaultTimeoutScaling = 0.5
)

This section is empty.

func NewLinearTimer(opts Options, onTimeoutPropose, onTimeoutPrevote, onTimeoutPrecommit chan<- Timeout) process.Timer

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

func (t *LinearTimer) TimeoutPrecommit(height process.Height, round process.Round)

func (t *LinearTimer) TimeoutPrevote(height process.Height, round process.Round)

func (t *LinearTimer) TimeoutPropose(height process.Height, round process.Round)

type Options struct {
	Logger         logrus.FieldLogger
	Timeout        time.Duration
	TimeoutScaling float64
}

func DefaultOptions() Options

func (opts Options) WithLogLevel(level logrus.Level) Options

func (opts Options) WithLogOutput(output io.Writer) Options

func (opts Options) WithTimeout(timeout time.Duration) Options

func (opts Options) WithTimeoutScaling(timeoutScaling float64) Options

type Timeout struct {
	Height process.Height
	Round  process.Round
}