protocolv2

package

Go to main page

Versions in this module

v1

v1.15.1

Sep 9, 2023

v1.15.0

Aug 30, 2023

Changes in this version

+ var UnderlayActiveOpens = metrics.RegisterMetric("underlay", "ActiveOpens")

+ var UnderlayCurrEstablished = metrics.RegisterMetric("underlay", "CurrEstablished")

+ var UnderlayMalformedUDP = metrics.RegisterMetric("underlay", "UnderlayMalformedUDP")

+ var UnderlayMaxConn = metrics.RegisterMetric("underlay", "MaxConn")

+ var UnderlayPassiveOpens = metrics.RegisterMetric("underlay", "PassiveOpens")

+ var UnderlayUnsolicitedUDP = metrics.RegisterMetric("underlay", "UnsolicitedUDP")

+ func MaxPaddingSize(mtu int, ipVersion netutil.IPVersion, transport netutil.TransportProtocol, ...) int

type Mux

+ func NewMux(isClinet bool) *Mux

+ func (m *Mux) Accept() (net.Conn, error)

+ func (m *Mux) Addr() net.Addr

+ func (m *Mux) Close() error

+ func (m *Mux) DialContext(ctx context.Context) (net.Conn, error)

+ func (m *Mux) SetClientMultiplexFactor(n int) *Mux

+ func (m *Mux) SetClientPassword(password []byte) *Mux

+ func (m *Mux) SetEndpoints(endpoints []UnderlayProperties) *Mux

+ func (m *Mux) SetServerHandler(handler netutil.ConnHandler) *Mux

+ func (m *Mux) SetServerUsers(users map[string]*appctlpb.User) *Mux

type Session

+ func (s *Session) LocalAddr() net.Addr

+ func (s *Session) RemoteAddr() net.Addr

+ func (s *Session) SetDeadline(t time.Time) error

+ func (s *Session) SetReadDeadline(t time.Time) error

+ func (s *Session) SetWriteDeadline(t time.Time) error

+ func (s *Session) String() string

type TCPUnderlay

+ func NewTCPUnderlay(ctx context.Context, network, laddr, raddr string, mtu int, ...) (*TCPUnderlay, error)

+ func (b *TCPUnderlay) Accept() (net.Conn, error)

+ func (b *TCPUnderlay) Done() chan struct{}

+ func (t *TCPUnderlay) Addr() net.Addr

type UDPUnderlay

+ func NewUDPUnderlay(ctx context.Context, network, laddr, raddr string, mtu int, ...) (*UDPUnderlay, error)

+ func (b *UDPUnderlay) Accept() (net.Conn, error)

+ func (b *UDPUnderlay) Addr() net.Addr

+ func (b *UDPUnderlay) Done() chan struct{}

+ func (u *UDPUnderlay) LocalAddr() net.Addr

+ func (u *UDPUnderlay) RemoteAddr() net.Addr

type Underlay

+ Done func() chan struct{}

+ type UnderlayProperties interface

+ IPVersion func() netutil.IPVersion

+ LocalAddr func() net.Addr

+ MTU func() int

+ RemoteAddr func() net.Addr

+ TransportProtocol func() netutil.TransportProtocol

v1.14.1

Jun 2, 2023

Changes in this version

type TCPUnderlay

+ func DialTCP(ctx context.Context, network, laddr, raddr string, mtu int, ...) (*TCPUnderlay, error)

+ func (t *TCPUnderlay) LocalAddr() net.Addr

+ func (t *TCPUnderlay) Read(b []byte) (int, error)

+ func (t *TCPUnderlay) RemoteAddr() net.Addr

+ func (t *TCPUnderlay) SetDeadline(d time.Time) error

+ func (t *TCPUnderlay) SetReadDeadline(d time.Time) error

+ func (t *TCPUnderlay) SetWriteDeadline(d time.Time) error

+ func (t *TCPUnderlay) Write(b []byte) (int, error)

+ type TCPUnderlayListener struct

+ func ListenTCP(laddr string, users map[string]*appctlpb.User) (*TCPUnderlayListener, error)

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

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

+ func (l *TCPUnderlayListener) Close() error

+ func (l *TCPUnderlayListener) Start()

+ func (l *TCPUnderlayListener) WrapConn(conn net.Conn) net.Conn

v1.14.0

Apr 28, 2023

Changes in this version

type UDPUnderlay

+ func (u *UDPUnderlay) String() string

v1.13.0

Apr 1, 2023

Changes in this version

+ const MaxPDU

+ func MaxFragmentSize(mtu int, ipVersion netutil.IPVersion, transport netutil.TransportProtocol) int

+ type BaseStruct struct

+ Epoch uint8

+ Protocol uint8

+ Timestamp uint32

+ type Metadata interface

+ Marshal func() ([]byte, error)

+ Protocol func() byte

+ Unmarshal func([]byte) error

+ type Mux struct

+ func (m *Mux) ListenAndServeAll() error

+ type Segment struct

+ Metadata Metadata

+ Payload []byte

+ func (s *Segment) Fragment() (uint8, error)

+ func (s *Segment) Less(than *Segment) bool

+ func (s *Segment) Protocol() byte

+ func (s *Segment) Seq() (uint32, error)

+ type SegmentTree struct

+ func (t *SegmentTree) DeleteMin() (*Segment, error)

+ func (t *SegmentTree) DeleteMinBlocking() *Segment

+ func (t *SegmentTree) Insert(seg *Segment) error

+ func (t *SegmentTree) InsertBlocking(seg *Segment)

+ func (t *SegmentTree) Len() int

+ func (t *SegmentTree) MaxSeq() (uint32, error)

+ func (t *SegmentTree) MinSeq() (uint32, error)

+ func (t *SegmentTree) Remaining() int

+ type Session struct

+ func NewSession(id uint32, isClient bool, mtu int) *Session

+ func (s *Session) Close() error

+ func (s *Session) Read(b []byte) (n int, err error)

+ func (s *Session) Write(b []byte) (n int, err error)

+ type TCPUnderlay struct

+ func (t *TCPUnderlay) AddSession(s *Session) error

+ func (t *TCPUnderlay) Close() error

+ func (t *TCPUnderlay) IPVersion() netutil.IPVersion

+ func (t *TCPUnderlay) MTU() int

+ func (t *TCPUnderlay) RemoveSession(sessionID uint32) error

+ func (t *TCPUnderlay) RunEventLoop() (err error)

+ func (t *TCPUnderlay) String() string

+ func (t *TCPUnderlay) TransportProtocol() netutil.TransportProtocol

+ type UDPUnderlay struct

+ func (u *UDPUnderlay) AddSession(s *Session) error

+ func (u *UDPUnderlay) Close() error

+ func (u *UDPUnderlay) IPVersion() netutil.IPVersion

+ func (u *UDPUnderlay) MTU() int

+ func (u *UDPUnderlay) RemoveSession(sessionID uint32) error

+ func (u *UDPUnderlay) RunEventLoop() error

+ func (u *UDPUnderlay) TransportProtocol() netutil.TransportProtocol

+ type Underlay interface

+ AddSession func(*Session) error

+ Close func() error

+ IPVersion func() netutil.IPVersion

+ MTU func() int

+ RemoveSession func(sessionID uint32) error

+ RunEventLoop func() error

+ TransportProtocol func() netutil.TransportProtocol

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