timeout

package
v1.22.25 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

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 byte

Op represents an operation

const (
	// GetAcceptedFrontier gets accepted frontier
	GetAcceptedFrontier Op = iota
	// AcceptedFrontier is accepted frontier response
	AcceptedFrontier
	// GetAccepted gets accepted
	GetAccepted
	// Accepted is accepted response
	Accepted
	// Get gets an item
	Get
	// Put puts an item
	Put
	// PushQuery pushes a query
	PushQuery
	// PullQuery pulls a query
	PullQuery
	// Chits is chits response
	Chits
)

Jump to

Keyboard shortcuts

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