internal

Documentation

Index

• type RTT
  • func NewRTT() *RTT
  • func (r *RTT) Add(latestRTT, ackDelay time.Duration)
  • func (r *RTT) RTO() time.Duration
  • func (r *RTT) RTT() time.Duration
  • func (r *RTT) RTTVAR() time.Duration
  • func (r *RTT) SRTT() time.Duration
• type RingBuffer
  • func NewRingBuffer[T any](size int) *RingBuffer[T]
  • func (r *RingBuffer[T]) Free() int
  • func (r *RingBuffer[T]) Len() int
  • func (r *RingBuffer[T]) Read(p []T) int
  • func (r *RingBuffer[T]) Reset()
  • func (r *RingBuffer[T]) Write(p []T) (int, error)

Types

type RTT

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

func NewRTT

func NewRTT() *RTT

func (*RTT) Add

func (r *RTT) Add(latestRTT, ackDelay time.Duration)

func (*RTT) RTO

func (r *RTT) RTO() time.Duration

func (*RTT) RTT

func (r *RTT) RTT() time.Duration

func (*RTT) RTTVAR

func (r *RTT) RTTVAR() time.Duration

func (*RTT) SRTT

func (r *RTT) SRTT() time.Duration

type RingBuffer

type RingBuffer[T any] struct {
	// contains filtered or unexported fields
}

func NewRingBuffer

func NewRingBuffer[T any](size int) *RingBuffer[T]

func (*RingBuffer[T]) Free

func (r *RingBuffer[T]) Free() int

func (*RingBuffer[T]) Len

func (r *RingBuffer[T]) Len() int

func (*RingBuffer[T]) Read

func (r *RingBuffer[T]) Read(p []T) int

func (*RingBuffer[T]) Reset

func (r *RingBuffer[T]) Reset()

func (*RingBuffer[T]) Write

func (r *RingBuffer[T]) Write(p []T) (int, error)