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(namespace string, registerer prometheus.Registerer) error
  • func (m *Manager) Register(validatorID ids.ShortID, chainID ids.ID, requestID uint32, timeout func()) time.Time

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(
	namespace string,
	registerer prometheus.Registerer,
) error

Initialize this timeout manager.

func (*Manager) Register

func (m *Manager) Register(validatorID ids.ShortID, chainID ids.ID, requestID uint32, timeout func()) time.Time

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