Versions in this module Expand all Collapse all v0 v0.3.0-alpha7 Dec 28, 2021 v0.3.0-alpha6 Dec 21, 2021 v0.3.0-alpha5 Dec 21, 2021 v0.3.0-alpha4 Dec 21, 2021 v0.3.0-alpha3 Dec 20, 2021 v0.3.0-alpha2 Dec 20, 2021 v0.3.0-alpha1 Dec 20, 2021 v0.2.1 Dec 2, 2021 v0.2.0 Dec 2, 2021 Changes in this version + 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 struct + func NewClient(conn io.ReadWriteCloser) (*Client, error) + func (c *Client) Call(serviceMethod string, args interface{}, reply interface{}) error + func (c *Client) Close() error + type ConnectionTracerClient struct + 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 struct + AckFrame *logging.AckFrame + Bool bool + ByteCount logging.ByteCount + Chosen logging.VersionNumber + ClientVersions []logging.VersionNumber + CongestionState logging.CongestionState + Cwnd logging.ByteCount + DestConnID *logging.ConnectionID + DropReason logging.PacketDropReason + EncryptionLevel logging.EncryptionLevel + ErrorMsg *string + ExtendedHeader *logging.ExtendedHeader + Frames []logging.Frame + Generation logging.KeyPhase + Header *logging.Header + ID int + Key *string + Local *pan.UDPAddr + LossReason logging.PacketLossReason + OdcID *logging.ConnectionID + PTOCount uint32 + PacketNumber logging.PacketNumber + PacketType logging.PacketType + Packets int + Parameters *logging.TransportParameters + Perspective logging.Perspective + RTTStats *RTTStats + Remote *pan.UDPAddr + ServerVersions []logging.VersionNumber + SrcConnID *logging.ConnectionID + Time *time.Time + TimerType logging.TimerType + TracingID uint64 + Value *string + Versions []logging.VersionNumber + func (m *ConnectionTracerMsg) String() string + type ConnectionTracerServer struct + func NewConnectionTracerServer(ct ServerConnectionTracer) *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 struct + Value *int + type IDServer struct + func (s *IDServer) GetID(arg, resp *IDMsg) error + type NilMsg struct + type RTTStats struct + LatestRTT time.Duration + MaxAckDelay time.Duration + MeanDeviation time.Duration + MinRTT time.Duration + PTO time.Duration + SmoothedRTT time.Duration + func NewRTTStats(stats *logging.RTTStats) *RTTStats + type SelectorMsg struct + Fingerprint *pan.PathFingerprint + Local *pan.UDPAddr + PathInterface *pan.PathInterface + Paths []*Path + Remote *pan.UDPAddr + type ServerConnectionTracer interface + AcknowledgedPacket func(*pan.UDPAddr, *pan.UDPAddr, logging.EncryptionLevel, logging.PacketNumber) error + BufferedPacket func(*pan.UDPAddr, *pan.UDPAddr, logging.PacketType) error + Close func(local, remote *pan.UDPAddr) error + ClosedConnection func(local, remote *pan.UDPAddr, err error) error + Debug func(local, remote *pan.UDPAddr, name, msg string) error + DroppedEncryptionLevel func(*pan.UDPAddr, *pan.UDPAddr, logging.EncryptionLevel) error + DroppedKey func(local, remote *pan.UDPAddr, generation logging.KeyPhase) error + DroppedPacket func(*pan.UDPAddr, *pan.UDPAddr, logging.PacketType, logging.ByteCount, ...) error + LossTimerCanceled func(local, remote *pan.UDPAddr) error + LossTimerExpired func(*pan.UDPAddr, *pan.UDPAddr, logging.TimerType, logging.EncryptionLevel) error + LostPacket func(*pan.UDPAddr, *pan.UDPAddr, logging.EncryptionLevel, logging.PacketNumber, ...) error + NegotiatedVersion func(local, remote *pan.UDPAddr, chosen logging.VersionNumber, ...) error + ReceivedPacket func(local, remote *pan.UDPAddr, hdr *logging.ExtendedHeader, ...) error + ReceivedRetry func(*pan.UDPAddr, *pan.UDPAddr, *logging.Header) error + ReceivedTransportParameters func(*pan.UDPAddr, *pan.UDPAddr, *logging.TransportParameters) error + ReceivedVersionNegotiationPacket func(*pan.UDPAddr, *pan.UDPAddr, *logging.Header, []logging.VersionNumber) error + RestoredTransportParameters func(local, remote *pan.UDPAddr, parameters *logging.TransportParameters) error + SentPacket func(local, remote *pan.UDPAddr, hdr *logging.ExtendedHeader, ...) error + SentTransportParameters func(*pan.UDPAddr, *pan.UDPAddr, *logging.TransportParameters) error + SetLossTimer func(*pan.UDPAddr, *pan.UDPAddr, logging.TimerType, logging.EncryptionLevel, ...) error + StartedConnection func(local, remote *pan.UDPAddr, srcConnID, destConnID logging.ConnectionID) error + TracerForConnection func(id uint64, p logging.Perspective, odcid logging.ConnectionID) error + UpdatedCongestionState func(*pan.UDPAddr, *pan.UDPAddr, logging.CongestionState) error + UpdatedKey func(local, remote *pan.UDPAddr, generation logging.KeyPhase, rem bool) error + UpdatedKeyFromTLS func(*pan.UDPAddr, *pan.UDPAddr, logging.EncryptionLevel, logging.Perspective) error + UpdatedMetrics func(local, remote *pan.UDPAddr, rttStats *RTTStats, ...) error + UpdatedPTOCount func(local, remote *pan.UDPAddr, value uint32) error + type TracerClient struct + 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 struct + Addr net.Addr + ByteCount *logging.ByteCount + ConnectionID *logging.ConnectionID + DropReason *logging.PacketDropReason + Frames []logging.Frame + Header *logging.Header + ID *int + PacketType *logging.PacketType + Perspective *logging.Perspective + TracingID *uint64 + type TracerServer struct + func NewTracerServer(tracer logging.Tracer) *TracerServer + func (s *TracerServer) DroppedPacket(args, resp *TracerMsg) error + func (s *TracerServer) SentPacket(args, resp *TracerMsg) error v0.1.0 Nov 23, 2021 Changes in this version + var DefaultDaemonAddress = &net.UnixAddr + var ErrDeref = errors.New("Can not dereference Nil value") + func NewSelectorServer(selector ServerSelector) (*rpc.Server, error) + type Msg struct + Fingerprint *pan.PathFingerprint + Local *pan.UDPAddr + PathInterface *pan.PathInterface + Paths []*Path + Remote *pan.UDPAddr + type Path struct + Destination pan.IA + Expiry time.Time + Fingerprint pan.PathFingerprint + Metadata *pan.PathMetadata + Source pan.IA + func NewPathFrom(p *pan.Path) *Path + func (p *Path) PanPath() *pan.Path + type SelectorClient struct + func NewSelectorClient(conn io.ReadWriteCloser) *SelectorClient + func (s *SelectorClient) Close() error + func (s *SelectorClient) Initialize(local, remote pan.UDPAddr, paths []*pan.Path) + func (s *SelectorClient) Path() *pan.Path + func (s *SelectorClient) PathDown(fp pan.PathFingerprint, pi pan.PathInterface) + func (s *SelectorClient) Refresh(paths []*pan.Path) + type SelectorServer struct + func (s *SelectorServer) Close(args, resp *Msg) error + func (s *SelectorServer) Initialize(args, resp *Msg) error + func (s *SelectorServer) Path(args, resp *Msg) error + func (s *SelectorServer) PathDown(args, resp *Msg) error + func (s *SelectorServer) Refresh(args, resp *Msg) error + type ServerSelector interface + Close func(pan.UDPAddr) error + Initialize func(pan.UDPAddr, pan.UDPAddr, []*pan.Path) + Path func(pan.UDPAddr) *pan.Path + PathDown func(pan.UDPAddr, pan.PathFingerprint, pan.PathInterface) + Refresh func(pan.UDPAddr, []*pan.Path) + func NewServerSelectorFunc(fn func(pan.UDPAddr) pan.Selector) ServerSelector
Go to main page