mtp

package

Go to main page

Versions in this module

v0

v0.3.9

Mar 21, 2026

Changes in this version

+ const DelayedACKThreshold

+ const DelayedACKTimeout

+ const MinRetransmitCheck

type FECConfig

+ func (c *FECConfig) GetAdjusted(packetLoss float64) *FECConfig

type MTPConn

+ func (c *MTPConn) Migrate(resolver UDPResolver, address string) error

type Pacer

+ func (p *Pacer) Close()

type PacketCodec

+ func (c *PacketCodec) Close()

v0.3.8

Mar 21, 2026

v0.3.7

Mar 20, 2026

v0.3.6

Mar 20, 2026

v0.3.5

Mar 20, 2026

Changes in this version

+ const FlagCompressed

type CodecConfig

+ Compression *CompressionConfig

+ type CompressionConfig struct

+ Enable bool

+ Level int

+ MinSize int

type Listener

+ func ListenWithConfig(address string, secret string, compression *CompressionConfig) (*Listener, error)

type MTPConn

+ func DialMigrateWithConfig(resolver UDPResolver, address string, secret string, sessionID string, ...) (*MTPConn, error)

+ func DialWithConfig(resolver UDPResolver, address string, secret string, ...) (*MTPConn, error)

v0.3.4

Mar 15, 2026

Changes in this version

+ const BBRGain

+ const FECMaxDataShards

+ const FECMaxParityShards

+ const FECMinDataShards

+ const FECMinParityShards

type ARQEngine

+ func (a *ARQEngine) GetFECConfig() *FECConfig

+ func (a *ARQEngine) GetLossRate() float64

+ func (a *ARQEngine) SetFECConfig(config *FECConfig)

+ type CodecConfig struct

+ DCIDRotInterval int

+ EnableDCIDRot bool

+ Secret string

+ type FECConfig struct

+ AutoAdjust bool

+ DataShards int

+ PacketLoss float64

+ ParityShards int

+ func NewFECConfig() *FECConfig

+ func (c *FECConfig) Adjust(packetLoss float64)

type FecDecoder

+ func (f *FecDecoder) Reconfigure(config *FECConfig)

type FecEncoder

+ func (f *FecEncoder) Reconfigure(config *FECConfig)

+ type FecGroup struct

+ type Pacer struct

+ func NewPacer(rate int, burst int) *Pacer

+ func (p *Pacer) GetTokens() float64

+ func (p *Pacer) SetBurst(burst int)

+ func (p *Pacer) SetRate(rate int)

+ func (p *Pacer) Wait()

type PacketCodec

+ func NewPacketCodecWithConfig(cfg CodecConfig) *PacketCodec

+ func (c *PacketCodec) GetDCID() []byte

v0.3.3

Mar 14, 2026

v0.3.2

Mar 14, 2026

v0.3.1

Mar 9, 2026

v0.3.0

Mar 9, 2026

Changes in this version

+ const DefaultWindowSize

+ const DuplicateACKThreshold

+ const FECDataShards

+ const FECMaxPayload

+ const FECParityShards

+ const FlagFragment

+ const FlagMigrate

+ const FlagNone

+ const FlagSACK

+ const InitialRTO

+ const MaxPayloadSize

+ const MaxRTO

+ const MaxRetransmissions

+ const MaxWindowSize

+ const MinRTO

+ const PacketACK

+ const PacketDATA

+ const PacketFEC

+ const PacketFIN

+ const PacketFINACK

+ const PacketPING

+ const PacketPONG

+ const PacketSYN

+ const PacketSYNACK

+ type ARQEngine struct

+ func NewARQEngine(codec *PacketCodec, sendFunc func([]byte) error, deliverBufSize int) *ARQEngine

+ func (a *ARQEngine) Close()

+ func (a *ARQEngine) Delivered() <-chan *Packet

+ func (a *ARQEngine) HandlePacket(pkt *Packet)

+ func (a *ARQEngine) Send(payload []byte) error

+ func (a *ARQEngine) SendControl(pkt *Packet) error

+ func (a *ARQEngine) Stats() (sent, recv, retransmissions uint64, window int, rto time.Duration)

+ type FecDecoder struct

+ func NewFecDecoder(onRecover func(uint32, []byte)) (*FecDecoder, error)

+ func (f *FecDecoder) AddData(seq uint32, payload []byte)

+ func (f *FecDecoder) AddParity(startSeq uint32, parityIdx uint8, payload []byte)

+ type FecEncoder struct

+ func NewFecEncoder(onParity func(uint32, uint8, []byte)) (*FecEncoder, error)

+ func (f *FecEncoder) AddDataPacket(seq uint32, payload []byte)

+ type Listener struct

+ func Listen(address string, secret string) (*Listener, error)

+ func (l *Listener) Accept() (net.Conn, error)

+ func (l *Listener) Addr() net.Addr

+ func (l *Listener) Close() error

+ func (l *Listener) GetSession(sessionID string) *MTPConn

+ func (l *Listener) RemoveConnection(sessionID string)

+ type MTPConn struct

+ BytesRecv atomic.Int64

+ BytesSent atomic.Int64

+ PacketsRecv atomic.Int64

+ PacketsSent atomic.Int64

+ func Dial(resolver UDPResolver, address string, secret string) (*MTPConn, error)

+ func DialMigrate(resolver UDPResolver, address string, secret string, sessionID string) (*MTPConn, error)

+ func (c *MTPConn) Close() error

+ func (c *MTPConn) DispatchPacket(data []byte)

+ func (c *MTPConn) LocalAddr() net.Addr

+ func (c *MTPConn) Read(b []byte) (int, error)

+ func (c *MTPConn) RemoteAddr() net.Addr

+ func (c *MTPConn) SessionID() string

+ func (c *MTPConn) SetDeadline(t time.Time) error

+ func (c *MTPConn) SetReadDeadline(t time.Time) error

+ func (c *MTPConn) SetWriteDeadline(t time.Time) error

+ func (c *MTPConn) Write(b []byte) (int, error)

+ type Packet struct

+ AckNum uint32

+ Flags uint8

+ Payload []byte

+ SACKBlocks []uint32

+ SeqNum uint32

+ Type uint8

+ type PacketCodec struct

+ func NewPacketCodec(secret string) *PacketCodec

+ func (c *PacketCodec) Decode(wire []byte) (*Packet, error)

+ func (c *PacketCodec) Encode(pkt *Packet) ([]byte, error)

+ type UDPResolver interface

+ ResolveUDPAddr func(network, address string) (*net.UDPAddr, error)

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