timeout

Documentation

Index

• type Manager
  • func (m *Manager) Cancel(validatorID ids.ShortID, chainID ids.ID, requestID uint32)
  • func (m *Manager) Dispatch()
  • func (m *Manager) Initialize(timeoutConfig *timer.AdaptiveTimeoutConfig, benchlist benchlist.Manager) error
  • func (m *Manager) Register(validatorID ids.ShortID, chainID ids.ID, requestID uint32, register bool, ...) (time.Time, bool)
  • func (m *Manager) RegisterChain(ctx *snow.Context, namespace string)

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

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

RegisterChain ...