extra

package
v0.1.2 Latest Latest
Warning

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

Go to latest
Published: Apr 2, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AutoMultiConnectionTracer

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

func (*AutoMultiConnectionTracer) AcknowledgedPacket

func (*AutoMultiConnectionTracer) BufferedPacket

func (*AutoMultiConnectionTracer) ChoseALPN

func (amct *AutoMultiConnectionTracer) ChoseALPN(protocol string)

func (*AutoMultiConnectionTracer) Close

func (amct *AutoMultiConnectionTracer) Close()

func (*AutoMultiConnectionTracer) ClosedConnection

func (amct *AutoMultiConnectionTracer) ClosedConnection(error)

func (*AutoMultiConnectionTracer) Debug

func (amct *AutoMultiConnectionTracer) Debug(name, msg string)

func (*AutoMultiConnectionTracer) DroppedEncryptionLevel

func (amct *AutoMultiConnectionTracer) DroppedEncryptionLevel(logging.EncryptionLevel)

func (*AutoMultiConnectionTracer) DroppedKey

func (amct *AutoMultiConnectionTracer) DroppedKey(generation logging.KeyPhase)

func (*AutoMultiConnectionTracer) DroppedPacket

func (*AutoMultiConnectionTracer) ECNStateUpdated

func (amct *AutoMultiConnectionTracer) ECNStateUpdated(state logging.ECNState, trigger logging.ECNStateTrigger)

func (*AutoMultiConnectionTracer) LossTimerCanceled

func (amct *AutoMultiConnectionTracer) LossTimerCanceled()

func (*AutoMultiConnectionTracer) LossTimerExpired

func (*AutoMultiConnectionTracer) LostPacket

func (*AutoMultiConnectionTracer) NegotiatedVersion

func (amct *AutoMultiConnectionTracer) NegotiatedVersion(chosen logging.VersionNumber, clientVersions, serverVersions []logging.VersionNumber)

func (*AutoMultiConnectionTracer) ReceivedLongHeaderPacket

func (*AutoMultiConnectionTracer) ReceivedRetry

func (amct *AutoMultiConnectionTracer) ReceivedRetry(*logging.Header)

func (*AutoMultiConnectionTracer) ReceivedShortHeaderPacket

func (amct *AutoMultiConnectionTracer) ReceivedShortHeaderPacket(*logging.ShortHeader, logging.ByteCount, logging.ECN, []logging.Frame)

func (*AutoMultiConnectionTracer) ReceivedTransportParameters

func (amct *AutoMultiConnectionTracer) ReceivedTransportParameters(*logging.TransportParameters)

func (*AutoMultiConnectionTracer) ReceivedVersionNegotiationPacket

func (amct *AutoMultiConnectionTracer) ReceivedVersionNegotiationPacket(dest, src logging.ArbitraryLenConnectionID, _ []logging.VersionNumber)

func (*AutoMultiConnectionTracer) RestoredTransportParameters

func (amct *AutoMultiConnectionTracer) RestoredTransportParameters(parameters *logging.TransportParameters)

func (*AutoMultiConnectionTracer) SentLongHeaderPacket

func (amct *AutoMultiConnectionTracer) SentLongHeaderPacket(extendedHeader *logging.ExtendedHeader, count logging.ByteCount, ecn logging.ECN, ackframe *logging.AckFrame, frames []logging.Frame)

func (*AutoMultiConnectionTracer) SentShortHeaderPacket

func (*AutoMultiConnectionTracer) SentTransportParameters

func (amct *AutoMultiConnectionTracer) SentTransportParameters(*logging.TransportParameters)

func (*AutoMultiConnectionTracer) SetLossTimer

func (*AutoMultiConnectionTracer) StartedConnection

func (amct *AutoMultiConnectionTracer) StartedConnection(local, remote net.Addr, srcConnID, destConnID logging.ConnectionID)

func (*AutoMultiConnectionTracer) TracerFunc

func (amct *AutoMultiConnectionTracer) TracerFunc(context.Context, logging.Perspective, quic.ConnectionID) *logging.ConnectionTracer

func (*AutoMultiConnectionTracer) UpdatedCongestionState

func (amct *AutoMultiConnectionTracer) UpdatedCongestionState(logging.CongestionState)

func (*AutoMultiConnectionTracer) UpdatedKey

func (amct *AutoMultiConnectionTracer) UpdatedKey(generation logging.KeyPhase, remote bool)

func (*AutoMultiConnectionTracer) UpdatedKeyFromTLS

func (*AutoMultiConnectionTracer) UpdatedMetrics

func (amct *AutoMultiConnectionTracer) UpdatedMetrics(rttStats *logging.RTTStats, cwnd, bytesInFlight logging.ByteCount, packetsInFlight int)

func (*AutoMultiConnectionTracer) UpdatedPTOCount

func (amct *AutoMultiConnectionTracer) UpdatedPTOCount(value uint32)

type AutoSelector

type AutoSelector struct {
	ErrorHandler func(error)
	// contains filtered or unexported fields
}

func NewSelector

func NewSelector(multiSelector MultiSelector) *AutoSelector

func (*AutoSelector) Close

func (s *AutoSelector) Close() error

func (*AutoSelector) Initialize

func (s *AutoSelector) Initialize(local, remote pan.UDPAddr, paths []*pan.Path)

func (*AutoSelector) Path

func (s *AutoSelector) Path() *pan.Path

func (*AutoSelector) PathDown

func (s *AutoSelector) PathDown(fp pan.PathFingerprint, pi pan.PathInterface)

func (*AutoSelector) Refresh

func (s *AutoSelector) Refresh(paths []*pan.Path)

func (*AutoSelector) SetPreferences

func (s *AutoSelector) SetPreferences(prefs map[string]string) error

type DefaultSelector

type DefaultSelector struct {
	pan.DefaultSelector
}

func (*DefaultSelector) SetPreferences

func (s *DefaultSelector) SetPreferences(map[string]string) error

type MultiConnectionTracer

type MultiConnectionTracer interface {
	TracerForConnection(id uint64, p logging.Perspective, odcid logging.ConnectionID) error
	StartedConnection(local, remote *pan.UDPAddr, srcConnID, destConnID logging.ConnectionID) error
	NegotiatedVersion(local, remote *pan.UDPAddr, chosen logging.VersionNumber, clientVersions, serverVersions []logging.VersionNumber) error
	ClosedConnection(local, remote *pan.UDPAddr, err error) error
	SentTransportParameters(*pan.UDPAddr, *pan.UDPAddr, *logging.TransportParameters) error
	ReceivedTransportParameters(*pan.UDPAddr, *pan.UDPAddr, *logging.TransportParameters) error
	RestoredTransportParameters(local, remote *pan.UDPAddr, parameters *logging.TransportParameters) error
	SentPacket(local, remote *pan.UDPAddr, hdr *logging.ExtendedHeader, size logging.ByteCount, ack *logging.AckFrame, frames []logging.Frame) error
	ReceivedVersionNegotiationPacket(*pan.UDPAddr, *pan.UDPAddr, *logging.Header, []logging.VersionNumber) error
	ReceivedRetry(*pan.UDPAddr, *pan.UDPAddr, *logging.Header) error
	ReceivedPacket(local, remote *pan.UDPAddr, hdr *logging.ExtendedHeader, size logging.ByteCount, frames []logging.Frame) error
	BufferedPacket(*pan.UDPAddr, *pan.UDPAddr, logging.PacketType) error
	DroppedPacket(*pan.UDPAddr, *pan.UDPAddr, logging.PacketType, logging.ByteCount, logging.PacketDropReason) error
	UpdatedMetrics(local, remote *pan.UDPAddr, rttStats *RTTStats, cwnd, bytesInFlight logging.ByteCount, packetsInFlight int) error
	AcknowledgedPacket(*pan.UDPAddr, *pan.UDPAddr, logging.EncryptionLevel, logging.PacketNumber) error
	LostPacket(*pan.UDPAddr, *pan.UDPAddr, logging.EncryptionLevel, logging.PacketNumber, logging.PacketLossReason) error
	UpdatedCongestionState(*pan.UDPAddr, *pan.UDPAddr, logging.CongestionState) error
	UpdatedPTOCount(local, remote *pan.UDPAddr, value uint32) error
	UpdatedKeyFromTLS(*pan.UDPAddr, *pan.UDPAddr, logging.EncryptionLevel, logging.Perspective) error
	UpdatedKey(local, remote *pan.UDPAddr, generation logging.KeyPhase, rem bool) error
	DroppedEncryptionLevel(*pan.UDPAddr, *pan.UDPAddr, logging.EncryptionLevel) error
	DroppedKey(local, remote *pan.UDPAddr, generation logging.KeyPhase) error
	SetLossTimer(*pan.UDPAddr, *pan.UDPAddr, logging.TimerType, logging.EncryptionLevel, time.Time) error
	LossTimerExpired(*pan.UDPAddr, *pan.UDPAddr, logging.TimerType, logging.EncryptionLevel) error
	LossTimerCanceled(local, remote *pan.UDPAddr) error
	Close(local, remote *pan.UDPAddr) error
	Debug(local, remote *pan.UDPAddr, name, msg string) error
}

type MultiSelector

type MultiSelector interface {
	Initialize(map[string]string, pan.UDPAddr, pan.UDPAddr, []*pan.Path) error
	SetPreferences(map[string]string, pan.UDPAddr, pan.UDPAddr) error
	Path(pan.UDPAddr, pan.UDPAddr) (*pan.Path, error)
	PathDown(pan.UDPAddr, pan.UDPAddr, pan.PathFingerprint, pan.PathInterface) error
	Refresh(pan.UDPAddr, pan.UDPAddr, []*pan.Path) error
	Close(pan.UDPAddr, pan.UDPAddr) error
}

func NewFallbackSelectorFunc

func NewFallbackSelectorFunc(fn func(pan.UDPAddr, pan.UDPAddr) Selector) MultiSelector

type RTTStats

type RTTStats struct {
	LatestRTT, MaxAckDelay, MeanDeviation, MinRTT, PTO, SmoothedRTT time.Duration
}

func NewRTTStats

func NewRTTStats(stats *logging.RTTStats) *RTTStats

type Selector

type Selector interface {
	pan.Selector
	SetPreferences(map[string]string) error
}

Jump to

Keyboard shortcuts

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