Documentation
¶
Index ¶
- Variables
- func NewConnectionTracerClient(client *Client, id uint64, p logging.Perspective, odcid logging.ConnectionID) logging.ConnectionTracer
- func NewServer(selector ServerSelector, tracer logging.Tracer, ...) (*rpc.Server, error)
- func NewTracerClient(client *Client) logging.Tracer
- type Client
- type ConnectionTracerClient
- func (c *ConnectionTracerClient) AcknowledgedPacket(level logging.EncryptionLevel, pnum logging.PacketNumber)
- func (c *ConnectionTracerClient) BufferedPacket(ptype logging.PacketType)
- func (c *ConnectionTracerClient) Close()
- func (c *ConnectionTracerClient) ClosedConnection(e error)
- func (c *ConnectionTracerClient) Debug(name, msg string)
- func (c *ConnectionTracerClient) DroppedEncryptionLevel(level logging.EncryptionLevel)
- func (c *ConnectionTracerClient) DroppedKey(generation logging.KeyPhase)
- func (c *ConnectionTracerClient) DroppedPacket(ptype logging.PacketType, size logging.ByteCount, ...)
- func (c *ConnectionTracerClient) LossTimerCanceled()
- func (c *ConnectionTracerClient) LossTimerExpired(ttype logging.TimerType, level logging.EncryptionLevel)
- func (c *ConnectionTracerClient) LostPacket(level logging.EncryptionLevel, pnum logging.PacketNumber, ...)
- func (c *ConnectionTracerClient) NegotiatedVersion(chosen logging.VersionNumber, ...)
- func (c *ConnectionTracerClient) ReceivedPacket(hdr *logging.ExtendedHeader, size logging.ByteCount, frames []logging.Frame)
- func (c *ConnectionTracerClient) ReceivedRetry(hdr *logging.Header)
- func (c *ConnectionTracerClient) ReceivedTransportParameters(parameters *logging.TransportParameters)
- func (c *ConnectionTracerClient) ReceivedVersionNegotiationPacket(hdr *logging.Header, versions []logging.VersionNumber)
- func (c *ConnectionTracerClient) RestoredTransportParameters(parameters *logging.TransportParameters)
- func (c *ConnectionTracerClient) SentPacket(hdr *logging.ExtendedHeader, size logging.ByteCount, ack *logging.AckFrame, ...)
- func (c *ConnectionTracerClient) SentTransportParameters(parameters *logging.TransportParameters)
- func (c *ConnectionTracerClient) SetLossTimer(ttype logging.TimerType, level logging.EncryptionLevel, t time.Time)
- func (c *ConnectionTracerClient) StartedConnection(local, remote net.Addr, srcConnID, destConnID logging.ConnectionID)
- func (c *ConnectionTracerClient) UpdatedCongestionState(state logging.CongestionState)
- func (c *ConnectionTracerClient) UpdatedKey(generation logging.KeyPhase, remote bool)
- func (c *ConnectionTracerClient) UpdatedKeyFromTLS(level logging.EncryptionLevel, p logging.Perspective)
- func (c *ConnectionTracerClient) UpdatedMetrics(rttStats *logging.RTTStats, cwnd, bytesInFlight logging.ByteCount, ...)
- func (c *ConnectionTracerClient) UpdatedPTOCount(value uint32)
- type ConnectionTracerMsg
- type ConnectionTracerServer
- func (c *ConnectionTracerServer) AcknowledgedPacket(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) BufferedPacket(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) Close(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) ClosedConnection(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) Debug(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) DroppedEncryptionLevel(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) DroppedKey(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) DroppedPacket(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) LossTimerCanceled(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) LossTimerExpired(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) LostPacket(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) NegotiatedVersion(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) NewTracerForConnection(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) ReceivedPacket(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) ReceivedRetry(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) ReceivedTransportParameters(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) ReceivedVersionNegotiationPacket(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) RestoredTransportParameters(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) SentPacket(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) SentTransportParameters(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) SetLossTimer(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) StartedConnection(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) UpdatedCongestionState(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) UpdatedKey(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) UpdatedKeyFromTLS(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) UpdatedMetrics(args *ConnectionTracerMsg, resp *NilMsg) error
- func (c *ConnectionTracerServer) UpdatedPTOCount(args *ConnectionTracerMsg, resp *NilMsg) error
- type IDMsg
- type IDServer
- type NilMsg
- type Path
- type RTTStats
- type SelectorClient
- type SelectorMsg
- type SelectorServer
- func (s *SelectorServer) Close(args, resp *SelectorMsg) error
- func (s *SelectorServer) Initialize(args, resp *SelectorMsg) error
- func (s *SelectorServer) Path(args, resp *SelectorMsg) error
- func (s *SelectorServer) PathDown(args, resp *SelectorMsg) error
- func (s *SelectorServer) Refresh(args, resp *SelectorMsg) error
- type ServerConnectionTracer
- type ServerSelector
- type TracerClient
- func (c TracerClient) DroppedPacket(addr net.Addr, tp logging.PacketType, n logging.ByteCount, ...)
- func (c TracerClient) SentPacket(addr net.Addr, hdr *logging.Header, n logging.ByteCount, fs []logging.Frame)
- func (c TracerClient) TracerForConnection(ctx context.Context, p logging.Perspective, odcid logging.ConnectionID) logging.ConnectionTracer
- type TracerMsg
- type TracerServer
Constants ¶
This section is empty.
Variables ¶
View Source
var ( DefaultDaemonAddress = &net.UnixAddr{ Name: "/tmp/panapid.sock", Net: "unix", } ErrDeref = errors.New("Can not dereference Nil value") )
Functions ¶
func NewConnectionTracerClient ¶ added in v0.2.0
func NewConnectionTracerClient(client *Client, id uint64, p logging.Perspective, odcid logging.ConnectionID) logging.ConnectionTracer
func NewServer ¶ added in v0.2.0
func NewServer(selector ServerSelector, tracer logging.Tracer, connectionTracer ServerConnectionTracer) (*rpc.Server, error)
func NewTracerClient ¶ added in v0.2.0
Types ¶
type Client ¶ added in v0.2.0
type Client struct {
// contains filtered or unexported fields
}
type ConnectionTracerClient ¶ added in v0.2.0
type ConnectionTracerClient struct {
// contains filtered or unexported fields
}
func (*ConnectionTracerClient) AcknowledgedPacket ¶ added in v0.2.0
func (c *ConnectionTracerClient) AcknowledgedPacket(level logging.EncryptionLevel, pnum logging.PacketNumber)
func (*ConnectionTracerClient) BufferedPacket ¶ added in v0.2.0
func (c *ConnectionTracerClient) BufferedPacket(ptype logging.PacketType)
func (*ConnectionTracerClient) Close ¶ added in v0.2.0
func (c *ConnectionTracerClient) Close()
func (*ConnectionTracerClient) ClosedConnection ¶ added in v0.2.0
func (c *ConnectionTracerClient) ClosedConnection(e error)
func (*ConnectionTracerClient) Debug ¶ added in v0.2.0
func (c *ConnectionTracerClient) Debug(name, msg string)
func (*ConnectionTracerClient) DroppedEncryptionLevel ¶ added in v0.2.0
func (c *ConnectionTracerClient) DroppedEncryptionLevel(level logging.EncryptionLevel)
func (*ConnectionTracerClient) DroppedKey ¶ added in v0.2.0
func (c *ConnectionTracerClient) DroppedKey(generation logging.KeyPhase)
func (*ConnectionTracerClient) DroppedPacket ¶ added in v0.2.0
func (c *ConnectionTracerClient) DroppedPacket(ptype logging.PacketType, size logging.ByteCount, reason logging.PacketDropReason)
func (*ConnectionTracerClient) LossTimerCanceled ¶ added in v0.2.0
func (c *ConnectionTracerClient) LossTimerCanceled()
func (*ConnectionTracerClient) LossTimerExpired ¶ added in v0.2.0
func (c *ConnectionTracerClient) LossTimerExpired(ttype logging.TimerType, level logging.EncryptionLevel)
func (*ConnectionTracerClient) LostPacket ¶ added in v0.2.0
func (c *ConnectionTracerClient) LostPacket(level logging.EncryptionLevel, pnum logging.PacketNumber, reason logging.PacketLossReason)
func (*ConnectionTracerClient) NegotiatedVersion ¶ added in v0.2.0
func (c *ConnectionTracerClient) NegotiatedVersion(chosen logging.VersionNumber, clientVersions, serverVersions []logging.VersionNumber)
func (*ConnectionTracerClient) ReceivedPacket ¶ added in v0.2.0
func (c *ConnectionTracerClient) ReceivedPacket(hdr *logging.ExtendedHeader, size logging.ByteCount, frames []logging.Frame)
func (*ConnectionTracerClient) ReceivedRetry ¶ added in v0.2.0
func (c *ConnectionTracerClient) ReceivedRetry(hdr *logging.Header)
func (*ConnectionTracerClient) ReceivedTransportParameters ¶ added in v0.2.0
func (c *ConnectionTracerClient) ReceivedTransportParameters(parameters *logging.TransportParameters)
func (*ConnectionTracerClient) ReceivedVersionNegotiationPacket ¶ added in v0.2.0
func (c *ConnectionTracerClient) ReceivedVersionNegotiationPacket(hdr *logging.Header, versions []logging.VersionNumber)
func (*ConnectionTracerClient) RestoredTransportParameters ¶ added in v0.2.0
func (c *ConnectionTracerClient) RestoredTransportParameters(parameters *logging.TransportParameters)
func (*ConnectionTracerClient) SentPacket ¶ added in v0.2.0
func (c *ConnectionTracerClient) SentPacket(hdr *logging.ExtendedHeader, size logging.ByteCount, ack *logging.AckFrame, frames []logging.Frame)
func (*ConnectionTracerClient) SentTransportParameters ¶ added in v0.2.0
func (c *ConnectionTracerClient) SentTransportParameters(parameters *logging.TransportParameters)
func (*ConnectionTracerClient) SetLossTimer ¶ added in v0.2.0
func (c *ConnectionTracerClient) SetLossTimer(ttype logging.TimerType, level logging.EncryptionLevel, t time.Time)
func (*ConnectionTracerClient) StartedConnection ¶ added in v0.2.0
func (c *ConnectionTracerClient) StartedConnection(local, remote net.Addr, srcConnID, destConnID logging.ConnectionID)
func (*ConnectionTracerClient) UpdatedCongestionState ¶ added in v0.2.0
func (c *ConnectionTracerClient) UpdatedCongestionState(state logging.CongestionState)
func (*ConnectionTracerClient) UpdatedKey ¶ added in v0.2.0
func (c *ConnectionTracerClient) UpdatedKey(generation logging.KeyPhase, remote bool)
func (*ConnectionTracerClient) UpdatedKeyFromTLS ¶ added in v0.2.0
func (c *ConnectionTracerClient) UpdatedKeyFromTLS(level logging.EncryptionLevel, p logging.Perspective)
func (*ConnectionTracerClient) UpdatedMetrics ¶ added in v0.2.0
func (*ConnectionTracerClient) UpdatedPTOCount ¶ added in v0.2.0
func (c *ConnectionTracerClient) UpdatedPTOCount(value uint32)
type ConnectionTracerMsg ¶ added in v0.2.0
type ConnectionTracerMsg struct {
Local, Remote *pan.UDPAddr
OdcID, SrcConnID, DestConnID *logging.ConnectionID
Chosen logging.VersionNumber
Versions, ClientVersions, ServerVersions []logging.VersionNumber
ErrorMsg, Key, Value *string
Parameters *logging.TransportParameters
ByteCount, Cwnd logging.ByteCount
Packets, ID int
Header *logging.Header
ExtendedHeader *logging.ExtendedHeader
Frames []logging.Frame
AckFrame *logging.AckFrame
PacketType logging.PacketType
DropReason logging.PacketDropReason
LossReason logging.PacketLossReason
EncryptionLevel logging.EncryptionLevel
PacketNumber logging.PacketNumber
CongestionState logging.CongestionState
PTOCount uint32
TracingID uint64
Perspective logging.Perspective
Bool bool
Generation logging.KeyPhase
TimerType logging.TimerType
Time *time.Time
RTTStats *RTTStats
}
func (*ConnectionTracerMsg) String ¶ added in v0.2.0
func (m *ConnectionTracerMsg) String() string
type ConnectionTracerServer ¶ added in v0.2.0
type ConnectionTracerServer struct {
// contains filtered or unexported fields
}
func NewConnectionTracerServer ¶ added in v0.2.0
func NewConnectionTracerServer(ct ServerConnectionTracer) *ConnectionTracerServer
func (*ConnectionTracerServer) AcknowledgedPacket ¶ added in v0.2.0
func (c *ConnectionTracerServer) AcknowledgedPacket(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) BufferedPacket ¶ added in v0.2.0
func (c *ConnectionTracerServer) BufferedPacket(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) Close ¶ added in v0.2.0
func (c *ConnectionTracerServer) Close(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) ClosedConnection ¶ added in v0.2.0
func (c *ConnectionTracerServer) ClosedConnection(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) Debug ¶ added in v0.2.0
func (c *ConnectionTracerServer) Debug(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) DroppedEncryptionLevel ¶ added in v0.2.0
func (c *ConnectionTracerServer) DroppedEncryptionLevel(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) DroppedKey ¶ added in v0.2.0
func (c *ConnectionTracerServer) DroppedKey(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) DroppedPacket ¶ added in v0.2.0
func (c *ConnectionTracerServer) DroppedPacket(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) LossTimerCanceled ¶ added in v0.2.0
func (c *ConnectionTracerServer) LossTimerCanceled(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) LossTimerExpired ¶ added in v0.2.0
func (c *ConnectionTracerServer) LossTimerExpired(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) LostPacket ¶ added in v0.2.0
func (c *ConnectionTracerServer) LostPacket(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) NegotiatedVersion ¶ added in v0.2.0
func (c *ConnectionTracerServer) NegotiatedVersion(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) NewTracerForConnection ¶ added in v0.2.0
func (c *ConnectionTracerServer) NewTracerForConnection(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) ReceivedPacket ¶ added in v0.2.0
func (c *ConnectionTracerServer) ReceivedPacket(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) ReceivedRetry ¶ added in v0.2.0
func (c *ConnectionTracerServer) ReceivedRetry(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) ReceivedTransportParameters ¶ added in v0.2.0
func (c *ConnectionTracerServer) ReceivedTransportParameters(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) ReceivedVersionNegotiationPacket ¶ added in v0.2.0
func (c *ConnectionTracerServer) ReceivedVersionNegotiationPacket(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) RestoredTransportParameters ¶ added in v0.2.0
func (c *ConnectionTracerServer) RestoredTransportParameters(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) SentPacket ¶ added in v0.2.0
func (c *ConnectionTracerServer) SentPacket(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) SentTransportParameters ¶ added in v0.2.0
func (c *ConnectionTracerServer) SentTransportParameters(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) SetLossTimer ¶ added in v0.2.0
func (c *ConnectionTracerServer) SetLossTimer(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) StartedConnection ¶ added in v0.2.0
func (c *ConnectionTracerServer) StartedConnection(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) UpdatedCongestionState ¶ added in v0.2.0
func (c *ConnectionTracerServer) UpdatedCongestionState(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) UpdatedKey ¶ added in v0.2.0
func (c *ConnectionTracerServer) UpdatedKey(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) UpdatedKeyFromTLS ¶ added in v0.2.0
func (c *ConnectionTracerServer) UpdatedKeyFromTLS(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) UpdatedMetrics ¶ added in v0.2.0
func (c *ConnectionTracerServer) UpdatedMetrics(args *ConnectionTracerMsg, resp *NilMsg) error
func (*ConnectionTracerServer) UpdatedPTOCount ¶ added in v0.2.0
func (c *ConnectionTracerServer) UpdatedPTOCount(args *ConnectionTracerMsg, resp *NilMsg) error
type Path ¶
type Path struct {
Source pan.IA
Destination pan.IA
Metadata *pan.PathMetadata
Fingerprint pan.PathFingerprint
//ForwardingPath pan.ForwardingPath
Expiry time.Time
}
func NewPathFrom ¶
type RTTStats ¶ added in v0.2.0
type RTTStats struct {
LatestRTT, MaxAckDelay, MeanDeviation, MinRTT, PTO, SmoothedRTT time.Duration
}
func NewRTTStats ¶ added in v0.2.0
type SelectorClient ¶
type SelectorClient struct {
// contains filtered or unexported fields
}
func NewSelectorClient ¶
func NewSelectorClient(client *Client) *SelectorClient
func (*SelectorClient) Close ¶
func (s *SelectorClient) Close() error
func (*SelectorClient) Initialize ¶
func (s *SelectorClient) Initialize(local, remote pan.UDPAddr, paths []*pan.Path)
func (*SelectorClient) Path ¶
func (s *SelectorClient) Path() *pan.Path
func (*SelectorClient) PathDown ¶
func (s *SelectorClient) PathDown(fp pan.PathFingerprint, pi pan.PathInterface)
func (*SelectorClient) Refresh ¶
func (s *SelectorClient) Refresh(paths []*pan.Path)
type SelectorMsg ¶ added in v0.2.0
type SelectorMsg struct {
Local *pan.UDPAddr
Remote *pan.UDPAddr
Fingerprint *pan.PathFingerprint
PathInterface *pan.PathInterface
Paths []*Path
}
type SelectorServer ¶
type SelectorServer struct {
// contains filtered or unexported fields
}
func NewSelectorServer ¶
func NewSelectorServer(selector ServerSelector) *SelectorServer
func (*SelectorServer) Close ¶
func (s *SelectorServer) Close(args, resp *SelectorMsg) error
func (*SelectorServer) Initialize ¶
func (s *SelectorServer) Initialize(args, resp *SelectorMsg) error
func (*SelectorServer) Path ¶
func (s *SelectorServer) Path(args, resp *SelectorMsg) error
func (*SelectorServer) PathDown ¶
func (s *SelectorServer) PathDown(args, resp *SelectorMsg) error
func (*SelectorServer) Refresh ¶
func (s *SelectorServer) Refresh(args, resp *SelectorMsg) error
type ServerConnectionTracer ¶ added in v0.2.0
type ServerConnectionTracer 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 ServerSelector ¶
type ServerSelector interface {
Initialize(pan.UDPAddr, pan.UDPAddr, []*pan.Path) 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 NewServerSelectorFunc ¶
type TracerClient ¶ added in v0.2.0
type TracerClient struct {
// contains filtered or unexported fields
}
func (TracerClient) DroppedPacket ¶ added in v0.2.0
func (c TracerClient) DroppedPacket(addr net.Addr, tp logging.PacketType, n logging.ByteCount, r logging.PacketDropReason)
func (TracerClient) SentPacket ¶ added in v0.2.0
func (TracerClient) TracerForConnection ¶ added in v0.2.0
func (c TracerClient) TracerForConnection(ctx context.Context, p logging.Perspective, odcid logging.ConnectionID) logging.ConnectionTracer
type TracerMsg ¶ added in v0.2.0
type TracerMsg struct {
//Context context.Context
ID *int
TracingID *uint64
Perspective *logging.Perspective
ConnectionID *logging.ConnectionID
Addr net.Addr
Header *logging.Header
ByteCount *logging.ByteCount
Frames []logging.Frame
PacketType *logging.PacketType
DropReason *logging.PacketDropReason
}
type TracerServer ¶ added in v0.2.0
type TracerServer struct {
// contains filtered or unexported fields
}
func NewTracerServer ¶ added in v0.2.0
func NewTracerServer(tracer logging.Tracer) *TracerServer
func (*TracerServer) DroppedPacket ¶ added in v0.2.0
func (s *TracerServer) DroppedPacket(args, resp *TracerMsg) error
func (*TracerServer) SentPacket ¶ added in v0.2.0
func (s *TracerServer) SentPacket(args, resp *TracerMsg) error
Click to show internal directories.
Click to hide internal directories.