conn

Dec 11, 2024

Changes in this version

+ func AddrPortToSockaddrWithAddressFamily(addrPort netip.AddrPort, is4 bool) (name *byte, namelen uint32) — darwin/amd64, linux/amd64

type SocketInfo

+ IPv6Only bool

Oct 19, 2024

Changes in this version

+ const DefaultUDPSocketBufferSize

type ListenConfig — linux/amd64

+ func (lc *ListenConfig) ListenUDPMmsgConn(ctx context.Context, network, address string) (c MmsgConn, info SocketInfo, err error)

type ListenerSocketOptions

+ ProbeUDPGSOSupport bool

+ ReceiveBufferSize int

+ SendBufferSize int

+ UDPGenericReceiveOffload bool

+ type MmsgConn struct — linux/amd64

+ func NewMmsgConn(udpConn *net.UDPConn) (MmsgConn, error)

+ func (c MmsgConn) NewRConn() *MmsgRConn

+ func (c MmsgConn) NewWConn() *MmsgWConn

+ type SocketControlMessage struct

+ PktinfoAddr netip.Addr

+ PktinfoIfindex uint32

+ SegmentSize uint32

+ func ParseSocketControlMessage(cmsg []byte) (m SocketControlMessage, err error)

+ func (m SocketControlMessage) AppendTo(b []byte) []byte

+ type SocketInfo struct

+ MaxUDPGSOSegments uint32

+ UDPGenericReceiveOffload bool

Jan 28, 2024

Changes in this version

+ var ALongTimeAgo = time.Unix(0, 0)

+ func ResolveIP(ctx context.Context, network, host string) (netip.Addr, error)

+ type Addr struct

+ func AddrFromDomainPort(domain string, port uint16) (Addr, error)

+ func AddrFromHostPort(host string, port uint16) (Addr, error)

+ func AddrFromIPPort(addrPort netip.AddrPort) (addr Addr)

+ func MustAddrFromDomainPort(domain string, port uint16) Addr

+ func ParseAddr[T ~[]byte | ~string](s T) (Addr, error)

+ func (a *Addr) UnmarshalText(text []byte) error

+ func (a Addr) AppendTo(b []byte) []byte

+ func (a Addr) Domain() string

+ func (a Addr) Equals(b Addr) bool

+ func (a Addr) Host() string

+ func (a Addr) IP() netip.Addr

+ func (a Addr) IPPort() netip.AddrPort

+ func (a Addr) IsDomain() bool

+ func (a Addr) IsIP() bool

+ func (a Addr) IsValid() bool

+ func (a Addr) MarshalText() ([]byte, error)

+ func (a Addr) Port() uint16

+ func (a Addr) ResolveIP(ctx context.Context, network string) (netip.Addr, error)

+ func (a Addr) ResolveIPPort(ctx context.Context, network string) (netip.AddrPort, error)

+ func (a Addr) String() string

Mar 29, 2023

Changes in this version

+ const SYS_RECVMMSG — linux/amd64

+ const SizeofSockaddrInet4 — windows/amd64

+ const SizeofSockaddrInet6 — windows/amd64

+ var DefaultUDPClientListenConfig = DefaultUDPClientSocketOptions.ListenConfig()

+ var DefaultUDPClientSocketOptions = ListenerSocketOptions

+ var DefaultUDPServerListenConfig = DefaultUDPServerSocketOptions.ListenConfig()

+ var DefaultUDPServerSocketOptions = ListenerSocketOptions

+ func AddrPortToSockaddr(addrPort netip.AddrPort) (name *byte, namelen uint32) — darwin/amd64, windows/amd64

+ func AddrPortToSockaddrInet4(addrPort netip.AddrPort) unix.RawSockaddrInet4 — darwin/amd64

+ func AddrPortToSockaddrInet4(addrPort netip.AddrPort) windows.RawSockaddrInet4 — windows/amd64

+ func AddrPortToSockaddrInet6(addrPort netip.AddrPort) unix.RawSockaddrInet6 — darwin/amd64

+ func AddrPortToSockaddrInet6(addrPort netip.AddrPort) windows.RawSockaddrInet6 — windows/amd64

+ func NewRawUDPConn(udpConn *net.UDPConn) (rawUDPConn, error) — linux/amd64

+ func SockaddrInet4ToAddrPort(sa *unix.RawSockaddrInet4) netip.AddrPort — darwin/amd64, linux/amd64

+ func SockaddrInet4ToAddrPort(sa *windows.RawSockaddrInet4) netip.AddrPort — windows/amd64

+ func SockaddrInet6ToAddrPort(sa *unix.RawSockaddrInet6) netip.AddrPort — darwin/amd64, linux/amd64

+ func SockaddrInet6ToAddrPort(sa *windows.RawSockaddrInet6) netip.AddrPort — windows/amd64

+ func SockaddrToAddrPort(name *byte, namelen uint32) (netip.AddrPort, error) — darwin/amd64, windows/amd64

+ type ListenConfig net.ListenConfig

+ func (lc *ListenConfig) ListenUDP(network, address string) (*net.UDPConn, error)

+ func (lc *ListenConfig) ListenUDPRawConn(network, address string) (rawUDPConn, error)

+ type ListenConfigCache map[ListenerSocketOptions]ListenConfig

+ func NewListenConfigCache() ListenConfigCache

+ func (cache ListenConfigCache) Get(lso ListenerSocketOptions) (lc ListenConfig)

+ type ListenerSocketOptions struct

+ Fwmark int

+ PathMTUDiscovery bool

+ ReceivePacketInfo bool

+ TrafficClass int

+ func (lso ListenerSocketOptions) ListenConfig() ListenConfig

+ type MmsgRConn struct — linux/amd64

+ func (c *MmsgRConn) ReadMsgs(msgvec []Mmsghdr, flags int) (int, error)

+ func (c MmsgRConn) RConn() *MmsgRConn

+ func (c MmsgRConn) WConn() *MmsgWConn

+ type MmsgWConn struct — linux/amd64

+ func (c *MmsgWConn) WriteMsgs(msgvec []Mmsghdr, flags int) error

+ func (c MmsgWConn) RConn() *MmsgRConn

+ func (c MmsgWConn) WConn() *MmsgWConn

Oct 26, 2022

Changes in this version

+ const SizeofCmsghdr — windows/amd64

+ const SizeofInet4Pktinfo — windows/amd64

+ const SizeofInet6Pktinfo — windows/amd64

+ const SizeofPtr — windows/amd64

+ func AddrPortMappedEqual(l, r netip.AddrPort) bool

+ func ParsePktinfoCmsg(cmsg []byte) (netip.Addr, uint32, error)

Sep 12, 2022

Changes in this version

+ const SocketControlMessageBufferSize

+ func UpdatePktinfoCache(pktinfoCache, cmsgs []byte, logger *zap.Logger) ([]byte, error)

Aug 9, 2022

Changes in this version

+ func ResolveAddrPort(address string) (addrPort netip.AddrPort, err error)

Jul 14, 2022

Changes in this version

+ func SockaddrToAddrPort(name *byte, namelen uint32) (netip.AddrPort, error) — linux/amd64

+ func Tov4Mappedv6(addrPort netip.AddrPort) netip.AddrPort

+ func WriteMsgvec(conn *net.UDPConn, msgvec []Mmsghdr) error — linux/amd64

Apr 26, 2022

Changes in this version

+ const UIO_MAXIOV — linux/amd64

+ func AddrPortToSockaddr(addrPort netip.AddrPort) (name *byte, namelen uint32) — linux/amd64

+ func AddrPortToSockaddrInet4(addrPort netip.AddrPort) unix.RawSockaddrInet4 — linux/amd64

+ func AddrPortToSockaddrInet6(addrPort netip.AddrPort) unix.RawSockaddrInet6 — linux/amd64

+ func Recvmmsg(conn *net.UDPConn, msgvec []Mmsghdr) (n int, err error) — linux/amd64

+ func Sendmmsg(conn *net.UDPConn, msgvec []Mmsghdr) error — linux/amd64

+ type Mmsghdr struct — linux/amd64

+ Msghdr unix.Msghdr

+ Msglen uint32

Apr 11, 2022

Changes in this version

+ func UpdateOobCache(oobCache, oob []byte, logger *zap.Logger) ([]byte, error)

+ type Cmsghdr struct — windows/amd64

+ Len uint

+ Level int32

+ Type int32

+ type Inet4Pktinfo struct — windows/amd64

+ Addr [4]byte

+ Ifindex uint32

+ type Inet6Pktinfo struct — windows/amd64

+ Addr [16]byte

+ Ifindex uint32

Apr 8, 2022

Changes in this version

+ const IPV6_MTU_DISCOVER — windows/amd64

+ const IP_MTU_DISCOVER — windows/amd64

+ const IP_PMTUDISC_DO — windows/amd64

+ const IP_PMTUDISC_DONT — windows/amd64

+ const IP_PMTUDISC_MAX — windows/amd64

+ const IP_PMTUDISC_NOT_SET — windows/amd64

+ const IP_PMTUDISC_PROBE — windows/amd64

+ const UDPOOBBufferSize

+ var ErrControlMessageTruncated = errors.New("the control message is larger than the supplied buffer") — darwin/amd64, linux/amd64

+ var ErrMessageTruncated = errors.New("the packet is larger than the supplied buffer") — darwin/amd64, linux/amd64

+ func GetOobForCache(clientOob []byte, logger *zap.Logger) ([]byte, error) — darwin/amd64, js/wasm, windows/amd64

+ func GetOobForCache(oob []byte, logger *zap.Logger) ([]byte, error) — linux/amd64

+ func ListenUDP(network string, laddr string, fwmark int) (conn *net.UDPConn, err error, serr error)

+ func ParseFlagsForError(flags int) error