conn

package
v1.10.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 22, 2024 License: AGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const SYS_RECVMMSG = unix.SYS_RECVMMSG
View Source 
const SocketControlMessageBufferSize = unix.SizeofCmsghdr + (unix.SizeofInet6Pktinfo+unix.SizeofPtr-1) & ^(unix.SizeofPtr-1)

SocketControlMessageBufferSize specifies the buffer size for receiving socket control messages.

View Source 
const TransparentSocketControlMessageBufferSize = unix.SizeofCmsghdr + (unix.SizeofSockaddrInet6+unix.SizeofPtr-1) & ^(unix.SizeofPtr-1)

TransparentSocketControlMessageBufferSize specifies the buffer size for receiving IPV6_RECVORIGDSTADDR socket control messages.

Variables

View Source 
var (
	// DefaultTCPListenerSocketOptions is the default [ListenerSocketOptions] for TCP servers.
	DefaultTCPListenerSocketOptions = ListenerSocketOptions{
		TCPFastOpen: true,
	}

	// DefaultTCPListenConfig is the default [ListenConfig] for TCP listeners.
	DefaultTCPListenConfig = DefaultTCPListenerSocketOptions.ListenConfig()

	// DefaultUDPServerSocketOptions is the default [ListenerSocketOptions] for UDP servers.
	DefaultUDPServerSocketOptions = ListenerSocketOptions{
		PathMTUDiscovery:  true,
		ReceivePacketInfo: true,
	}

	// DefaultUDPServerListenConfig is the default [ListenConfig] for UDP servers.
	DefaultUDPServerListenConfig = DefaultUDPServerSocketOptions.ListenConfig()

	// DefaultUDPClientSocketOptions is the default [ListenerSocketOptions] for UDP clients.
	DefaultUDPClientSocketOptions = ListenerSocketOptions{
		PathMTUDiscovery: true,
	}

	// DefaultUDPClientListenConfig is the default [ListenConfig] for UDP clients.
	DefaultUDPClientListenConfig = DefaultUDPClientSocketOptions.ListenConfig()
)
View Source 
var (
	// DefaultTCPDialerSocketOptions is the default [DialerSocketOptions] for TCP clients.
	DefaultTCPDialerSocketOptions = DialerSocketOptions{
		TCPFastOpen: true,
	}

	// DefaultTCPDialer is the default [Dialer] for TCP clients.
	DefaultTCPDialer = DefaultTCPDialerSocketOptions.Dialer()
)
View Source 
var (
	ErrMessageTruncated        = errors.New("the packet is larger than the supplied buffer")
	ErrControlMessageTruncated = errors.New("the control message is larger than the supplied buffer")
)
View Source 
var ALongTimeAgo = time.Unix(0, 0)

ALongTimeAgo is a non-zero time, far in the past, used for immediate deadlines.

Functions

func AddrPortMappedEqual added in v1.1.0 

func AddrPortMappedEqual(l, r netip.AddrPort) bool

AddrPortMappedEqual returns whether the two addresses point to the same endpoint. An IPv4 address and an IPv4-mapped IPv6 address pointing to the same endpoint are considered equal. For example, 1.1.1.1:53 and [::ffff:1.1.1.1]:53 are considered equal.

func AddrPortToSockaddr 

func AddrPortToSockaddr(addrPort netip.AddrPort) (name *byte, namelen uint32)

func AddrPortToSockaddrInet4 

func AddrPortToSockaddrInet4(addrPort netip.AddrPort) unix.RawSockaddrInet4

func AddrPortToSockaddrInet6 

func AddrPortToSockaddrInet6(addrPort netip.AddrPort) unix.RawSockaddrInet6

func AddrPortToSockaddrValue added in v1.3.0 

func AddrPortToSockaddrValue(addrPort netip.AddrPort) (rsa6 unix.RawSockaddrInet6, namelen uint32)

func AddrPortUnmappedToSockaddr added in v1.4.0 

func AddrPortUnmappedToSockaddr(addrPort netip.AddrPort) (name *byte, namelen uint32)

func NewRawUDPConn added in v1.7.0 

func NewRawUDPConn(udpConn *net.UDPConn) (rawUDPConn, error)

NewRawUDPConn wraps a net.UDPConn in a [rawUDPConn] for batch I/O.

func ParseFlagsForError 

func ParseFlagsForError(flags int) error

ParseFlagsForError parses the message flags returned by the ReadMsgUDPAddrPort method and returns an error if MSG_TRUNC is set, indicating that the returned packet was truncated.

The check is skipped on Windows, because an error (WSAEMSGSIZE) is also returned when MSG_PARTIAL is set.

func ParseOrigDstAddrCmsg added in v1.4.0 

func ParseOrigDstAddrCmsg(cmsg []byte) (netip.AddrPort, error)

func ParsePktinfoCmsg added in v1.3.0 

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

ParsePktinfoCmsg parses a single socket control message of type IP_PKTINFO or IPV6_PKTINFO, and returns the IP address and index of the network interface the packet was received from, or an error.

This function is only implemented for Linux, macOS and Windows. On other platforms, this is a no-op.

func ResolveIP added in v1.7.0 

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

ResolveIP resolves a domain name string into an IP address.

The network must be one of "ip", "ip4" or "ip6". String representations of IP addresses are not supported.

This function always returns the first IP address returned by the resolver, because the resolver takes care of sorting the IP addresses by address family availability and preference.

func SockaddrInet4ToAddrPort added in v1.4.0 

func SockaddrInet4ToAddrPort(sa *unix.RawSockaddrInet4) netip.AddrPort

func SockaddrInet6ToAddrPort added in v1.4.0 

func SockaddrInet6ToAddrPort(sa *unix.RawSockaddrInet6) netip.AddrPort

func SockaddrToAddrPort 

func SockaddrToAddrPort(name *byte, namelen uint32) (netip.AddrPort, error)

func SockaddrValueToAddrPort added in v1.3.0 

func SockaddrValueToAddrPort(rsa6 unix.RawSockaddrInet6, namelen uint32) (netip.AddrPort, error)

Types

type Addr added in v1.1.0 

type Addr struct {
	// contains filtered or unexported fields
}

Addr is the base address type used throughout the package.

An Addr is a port number combined with either an IP address or a domain name.

For space efficiency, the IP address and the domain string share the same space. The netip.Addr is stored in its original layout. The domain string's data pointer is stored in the ip.z field. Its length is stored at the beginning of the structure. This is essentially an unsafe "enum".

func AddrFromDomainPort added in v1.1.0 

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

AddrFromDomainPort returns an Addr from the provided domain name and port number.

func AddrFromHostPort added in v1.1.0 

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

AddrFromHostPort returns an Addr from the provided host string and port number. The host string may be a string representation of an IP address or a domain name.

func AddrFromIPPort added in v1.1.0 

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

AddrFromIPPort returns an Addr from the provided netip.AddrPort.

func MustAddrFromDomainPort added in v1.1.0 

func MustAddrFromDomainPort(domain string, port uint16) Addr

MustAddrFromDomainPort calls AddrFromDomainPort and panics on error.

func ParseAddr added in v1.1.0 

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

ParseAddr parses the provided string representation of an address and returns the parsed address or an error.

func (Addr) AppendTo added in v1.1.0 

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

AppendTo appends the string representation of the address to the provided buffer.

If the address is zero value, nothing is appended.

func (Addr) Domain added in v1.1.0 

func (a Addr) Domain() string

Domain returns the domain name.

If the address is an IP address or zero value, this method panics.

func (Addr) Equals added in v1.5.0 

func (a Addr) Equals(b Addr) bool

Equals returns whether two addresses are the same.

func (Addr) Host added in v1.1.0 

func (a Addr) Host() string

Host returns the string representation of the IP address or the domain name.

If the address is zero value, this method panics.

func (Addr) IP added in v1.1.0 

func (a Addr) IP() netip.Addr

IP returns the IP address.

If the address is a domain name or zero value, this method panics.

func (Addr) IPPort added in v1.1.0 

func (a Addr) IPPort() netip.AddrPort

IPPort returns a netip.AddrPort.

If the address is a domain name or zero value, this method panics.

func (Addr) IsDomain added in v1.5.0 

func (a Addr) IsDomain() bool

IsDomain returns whether the address is a domain name.

func (Addr) IsIP added in v1.1.0 

func (a Addr) IsIP() bool

IsIP returns whether the address is an IP address.

func (Addr) IsValid added in v1.5.0 

func (a Addr) IsValid() bool

IsValid returns whether the address is an initialized address (not a zero value).

func (Addr) MarshalText added in v1.1.0 

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

MarshalText implements the encoding.TextMarshaler MarshalText method.

func (Addr) Port added in v1.1.0 

func (a Addr) Port() uint16

Port returns the port number.

func (Addr) ResolveIP added in v1.1.0 

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

ResolveIP returns the IP address itself or the resolved IP address of the domain name.

The network is only used for domain name resolution and must be one of "ip", "ip4" or "ip6".

If the address is zero value, this method panics.

func (Addr) ResolveIPPort added in v1.1.0 

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

ResolveIPPort returns the IP address itself or the resolved IP address of the domain name and the port number as a netip.AddrPort.

The network is only used for domain name resolution and must be one of "ip", "ip4" or "ip6".

If the address is zero value, this method panics.

func (Addr) String added in v1.1.0 

func (a Addr) String() string

String returns the string representation of the address.

If the address is zero value, an empty string is returned.

func (*Addr) UnmarshalText added in v1.1.0 

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

UnmarshalText implements the encoding.TextUnmarshaler UnmarshalText method.

type Dialer added in v1.8.0 

type Dialer tfo.Dialer

Dialer is tfo.Dialer but provides a subjectively nicer API.

func (*Dialer) DialTCP added in v1.8.0 

func (d *Dialer) DialTCP(ctx context.Context, network, address string, b []byte) (*net.TCPConn, error)

DialTCP wraps tfo.Dialer.DialContext and returns a *net.TCPConn directly.

func (*Dialer) DialUDP added in v1.8.0 

func (d *Dialer) DialUDP(ctx context.Context, network, address string) (*net.UDPConn, error)

DialUDP wraps net.Dialer.DialContext and returns a *net.UDPConn directly.

type DialerCache added in v1.7.0 

type DialerCache map[DialerSocketOptions]Dialer

DialerCache is a map of DialerSocketOptions to Dialer.

func NewDialerCache added in v1.7.0 

func NewDialerCache() DialerCache

NewDialerCache creates a new cache for Dialer with a few default entries.

func (DialerCache) Get added in v1.7.0 

func (cache DialerCache) Get(dso DialerSocketOptions) (d Dialer)

Get returns a Dialer for the given DialerSocketOptions.

type DialerSocketOptions added in v1.7.0 

type DialerSocketOptions struct {
	// Fwmark sets the dialer's fwmark on Linux, or user cookie on FreeBSD.
	//
	// Available on Linux and FreeBSD.
	Fwmark int

	// TrafficClass sets the traffic class of the dialer.
	//
	// Available on most platforms except Windows.
	TrafficClass int

	// TCPFastOpen enables TCP Fast Open on the dialer.
	//
	// Available on Linux, macOS, FreeBSD, and Windows.
	TCPFastOpen bool

	// MultipathTCP enables multipath TCP on the dialer.
	//
	// Unlike Go std, we make MPTCP strictly opt-in.
	// That is, if this field is false, MPTCP will be explicitly disabled.
	// This ensures that if Go std suddenly decides to enable MPTCP by default,
	// existing configurations won't encounter issues due to missing features in the kernel MPTCP stack,
	// such as TCP keepalive (as of Linux 6.5), and failed connect attempts won't always be retried once.
	//
	// Available on platforms supported by Go std's MPTCP implementation.
	MultipathTCP bool
}

DialerSocketOptions contains dialer-specific socket options.

func (DialerSocketOptions) Dialer added in v1.7.0 

func (dso DialerSocketOptions) Dialer() Dialer

Dialer returns a Dialer with a control function that sets the socket options.

type ListenConfig added in v1.8.0 

type ListenConfig tfo.ListenConfig

ListenConfig is tfo.ListenConfig but provides a subjectively nicer API.

func (*ListenConfig) ListenTCP added in v1.8.0 

func (lc *ListenConfig) ListenTCP(ctx context.Context, network, address string) (*net.TCPListener, error)

ListenTCP wraps tfo.ListenConfig.Listen and returns a *net.TCPListener directly.

func (*ListenConfig) ListenUDP added in v1.8.0 

func (lc *ListenConfig) ListenUDP(ctx context.Context, network, address string) (*net.UDPConn, error)

ListenUDP wraps net.ListenConfig.ListenPacket and returns a *net.UDPConn directly.

func (*ListenConfig) ListenUDPRawConn added in v1.8.0 

func (lc *ListenConfig) ListenUDPRawConn(ctx context.Context, network, address string) (rawUDPConn, error)

ListenUDPRawConn is like [ListenUDP] but wraps the *net.UDPConn in a [rawUDPConn] for batch I/O.

type ListenConfigCache added in v1.7.0 

type ListenConfigCache map[ListenerSocketOptions]ListenConfig

ListenConfigCache is a map of ListenerSocketOptions to ListenConfig.

func NewListenConfigCache added in v1.7.0 

func NewListenConfigCache() ListenConfigCache

NewListenConfigCache creates a new cache for ListenConfig with a few default entries.

func (ListenConfigCache) Get added in v1.7.0 

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

Get returns a ListenConfig for the given ListenerSocketOptions.

type ListenerSocketOptions added in v1.7.0 

type ListenerSocketOptions struct {
	// Fwmark sets the listener's fwmark on Linux, or user cookie on FreeBSD.
	//
	// Available on Linux and FreeBSD.
	Fwmark int

	// TrafficClass sets the traffic class of the listener.
	//
	// Available on most platforms except Windows.
	TrafficClass int

	// ReusePort enables SO_REUSEPORT on the listener.
	//
	// Available on Linux and the BSDs.
	ReusePort bool

	// Transparent enables transparent proxy on the listener.
	//
	// Only available on Linux.
	Transparent bool

	// PathMTUDiscovery enables Path MTU Discovery on the listener.
	//
	// Available on Linux, macOS, FreeBSD, and Windows.
	PathMTUDiscovery bool

	// TCPFastOpen enables TCP Fast Open on the listener.
	//
	// Available on Linux, macOS, FreeBSD, and Windows.
	TCPFastOpen bool

	// MultipathTCP enables multipath TCP on the listener.
	//
	// Unlike Go std, we make MPTCP strictly opt-in.
	// That is, if this field is false, MPTCP will be explicitly disabled.
	// This ensures that if Go std suddenly decides to enable MPTCP by default,
	// existing configurations won't encounter issues due to missing features in the kernel MPTCP stack,
	// such as TCP keepalive (as of Linux 6.5), and failed connect attempts won't always be retried once.
	//
	// Available on platforms supported by Go std's MPTCP implementation.
	MultipathTCP bool

	// ReceivePacketInfo enables the reception of packet information control messages on the listener.
	//
	// Available on Linux, macOS, and Windows.
	ReceivePacketInfo bool

	// ReceiveOriginalDestAddr enables the reception of original destination address control messages on the listener.
	//
	// Only available on Linux.
	ReceiveOriginalDestAddr bool
}

ListenerSocketOptions contains listener-specific socket options.

func (ListenerSocketOptions) ListenConfig added in v1.7.0 

func (lso ListenerSocketOptions) ListenConfig() ListenConfig

ListenConfig returns a ListenConfig with a control function that sets the socket options.

type MmsgRConn added in v1.7.0 

type MmsgRConn struct {
	// contains filtered or unexported fields
}

MmsgRConn wraps a net.UDPConn and provides the [ReadMsgs] method for reading multiple messages in a single recvmmsg(2) system call.

MmsgRConn is not safe for concurrent use. Use the [RConn] method to create a new MmsgRConn instance for each goroutine.

func (MmsgRConn) RConn added in v1.7.0 

func (c MmsgRConn) RConn() *MmsgRConn

RConn returns a new MmsgRConn instance for batch reading.

func (*MmsgRConn) ReadMsgs added in v1.7.0 

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

ReadMsgs reads as many messages as possible into the given msgvec and returns the number of messages read or an error.

func (MmsgRConn) WConn added in v1.7.0 

func (c MmsgRConn) WConn() *MmsgWConn

WConn returns a new MmsgWConn instance for batch writing.

type MmsgWConn added in v1.7.0 

type MmsgWConn struct {
	// contains filtered or unexported fields
}

MmsgWConn wraps a net.UDPConn and provides the [WriteMsgs] method for writing multiple messages in a single sendmmsg(2) system call.

MmsgWConn is not safe for concurrent use. Use the [WConn] method to create a new MmsgWConn instance for each goroutine.

func (MmsgWConn) RConn added in v1.7.0 

func (c MmsgWConn) RConn() *MmsgRConn

RConn returns a new MmsgRConn instance for batch reading.

func (MmsgWConn) WConn added in v1.7.0 

func (c MmsgWConn) WConn() *MmsgWConn

WConn returns a new MmsgWConn instance for batch writing.

func (*MmsgWConn) WriteMsgs added in v1.7.0 

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

WriteMsgs writes all messages in the given msgvec and returns the last encountered error.

type Mmsghdr 

type Mmsghdr struct {
	Msghdr unix.Msghdr
	Msglen uint32
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.