timeout

package
v1.0.6-rc.1 Latest Latest
Warning

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

Go to latest
Published: Nov 30, 2020 License: BSD-3-Clause Imports: 8 Imported by: 23

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Manager

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

Manager registers and fires timeouts for the snow API.

func (*Manager) Cancel

func (m *Manager) Cancel(validatorID ids.ShortID, chainID ids.ID, requestID uint32)

Cancel request timeout with the specified parameters.

func (*Manager) Dispatch

func (m *Manager) Dispatch()

Dispatch ...

func (*Manager) Initialize

func (m *Manager) Initialize(timeoutConfig *timer.AdaptiveTimeoutConfig, benchlist benchlist.Manager) error

Initialize this timeout manager.

func (*Manager) Register

func (m *Manager) Register(validatorID ids.ShortID, chainID ids.ID, requestID uint32, register bool, msgType constants.MsgType, timeout func()) (time.Time, bool)

Register request to time out unless Manager.Cancel is called before the timeout duration passes, with the same request parameters.

func (*Manager) RegisterChain added in v1.0.2

func (m *Manager) RegisterChain(ctx *snow.Context, namespace string) error

RegisterChain ...

Jump to

Keyboard shortcuts

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