timeout

package
v1.22.45 Latest Latest
Warning

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

Go to latest
Published: Dec 24, 2025 License: BSD-3-Clause Imports: 4 Imported by: 2

Documentation

Index

Constants

View Source
const (
	GetAcceptedFrontier = router.GetAcceptedFrontier
	AcceptedFrontier    = router.AcceptedFrontier
	GetAccepted         = router.GetAccepted
	Accepted            = router.Accepted
	Get                 = router.Get
	Put                 = router.Put
	PushQuery           = router.PushQuery
	PullQuery           = router.PullQuery
	Chits               = router.Chits
)

Op constants re-exported from core/router

Variables

This section is empty.

Functions

This section is empty.

Types

type Manager

type Manager interface {
	// RegisterTimeout registers a timeout
	RegisterTimeout(time.Duration) func(context.Context, ids.ID) error

	// RegisterRequest registers a request
	RegisterRequest(ids.NodeID, ids.ID, bool, uint32, func())

	// RegisterResponse registers a response
	RegisterResponse(ids.NodeID, ids.ID, uint32, Op) (bool, func())

	// TimeoutDuration returns timeout duration
	TimeoutDuration() time.Duration
}

Manager manages timeouts

func NewManager

func NewManager(duration time.Duration) Manager

NewManager creates a new timeout manager

type Op

type Op = router.Op

Op re-exports from core/router for consistency

Jump to

Keyboard shortcuts

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