utils

package

v0.0.2 Latest Latest Go to latest Published: Aug 9, 2025 License: MIT Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/XLESSGo/uquic

Links

Open Source Insights

Documentation ¶

Index ¶

func NewBufferedWriteCloser(writer *bufio.Writer, closer io.Closer) io.WriteCloser
type ByteInterval
type LogLevel
type Logger
type RTTStats
type Rand
- func (r *Rand) Int31() int32
- func (r *Rand) Int31n(n int32) int32
type Timer
- func NewTimer() *Timer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewBufferedWriteCloser ¶

func NewBufferedWriteCloser(writer *bufio.Writer, closer io.Closer) io.WriteCloser

NewBufferedWriteCloser creates an io.WriteCloser from a bufio.Writer and an io.Closer

Types ¶

type ByteInterval ¶

type ByteInterval struct {
	Start protocol.ByteCount
	End   protocol.ByteCount
}

ByteInterval is an interval from one ByteCount to the other

func (ByteInterval) Comp ¶

func (i ByteInterval) Comp(v ByteInterval) int8

func (ByteInterval) Match ¶

func (i ByteInterval) Match(n ByteInterval) int8

func (ByteInterval) String ¶

func (i ByteInterval) String() string

type LogLevel ¶

type LogLevel uint8

LogLevel of quic-go

const (
	// LogLevelNothing disables
	LogLevelNothing LogLevel = iota
	// LogLevelError enables err logs
	LogLevelError
	// LogLevelInfo enables info logs (e.g. packets)
	LogLevelInfo
	// LogLevelDebug enables debug logs (e.g. packet contents)
	LogLevelDebug
)

type Logger ¶

type Logger interface {
	SetLogLevel(LogLevel)
	SetLogTimeFormat(format string)
	WithPrefix(prefix string) Logger
	Debug() bool

	Errorf(format string, args ...interface{})
	Infof(format string, args ...interface{})
	Debugf(format string, args ...interface{})
}

A Logger logs.

var DefaultLogger Logger

DefaultLogger is used by quic-go for logging.

type RTTStats ¶

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

RTTStats provides round-trip statistics

func (*RTTStats) LatestRTT ¶

func (r *RTTStats) LatestRTT() time.Duration

LatestRTT returns the most recent rtt measurement. May return Zero if no valid updates have occurred.

func (*RTTStats) MaxAckDelay ¶

func (r *RTTStats) MaxAckDelay() time.Duration

MaxAckDelay gets the max_ack_delay advertised by the peer

func (*RTTStats) MeanDeviation ¶

func (r *RTTStats) MeanDeviation() time.Duration

MeanDeviation gets the mean deviation

func (*RTTStats) MinRTT ¶

func (r *RTTStats) MinRTT() time.Duration

MinRTT Returns the minRTT for the entire connection. May return Zero if no valid updates have occurred.

func (*RTTStats) PTO ¶

func (r *RTTStats) PTO(includeMaxAckDelay bool) time.Duration

PTO gets the probe timeout duration.

func (*RTTStats) ResetForPathMigration ¶

func (r *RTTStats) ResetForPathMigration()

func (*RTTStats) SetInitialRTT ¶

func (r *RTTStats) SetInitialRTT(t time.Duration)

SetInitialRTT sets the initial RTT. It is used during the 0-RTT handshake when restoring the RTT stats from the session state.

func (*RTTStats) SetMaxAckDelay ¶

func (r *RTTStats) SetMaxAckDelay(mad time.Duration)

SetMaxAckDelay sets the max_ack_delay

func (*RTTStats) SmoothedRTT ¶

func (r *RTTStats) SmoothedRTT() time.Duration

SmoothedRTT returns the smoothed RTT for the connection. May return Zero if no valid updates have occurred.

func (*RTTStats) UpdateRTT ¶

func (r *RTTStats) UpdateRTT(sendDelta, ackDelay time.Duration)

UpdateRTT updates the RTT based on a new sample.

type Rand ¶

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

Rand is a wrapper around crypto/rand that adds some convenience functions known from math/rand.

func (*Rand) Int31 ¶

func (r *Rand) Int31() int32

func (*Rand) Int31n ¶

func (r *Rand) Int31n(n int32) int32

copied from the standard library math/rand implementation of Int63n

type Timer ¶

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

A Timer wrapper that behaves correctly when resetting

func NewTimer ¶

func NewTimer() *Timer

NewTimer creates a new timer that is not set

func (*Timer) Chan ¶

func (t *Timer) Chan() <-chan time.Time

Chan returns the channel of the wrapped timer

func (*Timer) Deadline ¶

func (t *Timer) Deadline() time.Time

func (*Timer) Reset ¶

func (t *Timer) Reset(deadline time.Time)

Reset the timer, no matter whether the value was read or not

func (*Timer) SetRead ¶

func (t *Timer) SetRead()

SetRead should be called after the value from the chan was read

func (*Timer) Stop ¶

func (t *Timer) Stop()

Stop stops the timer

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
linkedlist Package list implements a doubly linked list.	Package list implements a doubly linked list.
ringbuffer
tree

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