pnet

package
v0.4.135 Latest Latest
Warning

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

 Go to latest Published: Dec 3, 2023 License: ISC Imports: 21 Imported by: 0

Documentation

Overview

Package pnet provides IP-related functions with few dependencies beyond the net package

Index

Constants

View Source 
const (
	HardwareAddrMac48  = 6
	HardwareAddrEui64  = 8
	HardwareAddrInfini = 20
)
View Source 
const (
	NetworkTCP  = "tcp"
	NetworkTCP4 = "tcp4" // net network tcp ipv4
	NetworkTCP6 = "tcp6"
)
View Source 
const (
	TransportTCP = iota + 1
	TransportUDP
	TransportIP
	TransportUnix
)
View Source 
const Do46 = true
View Source 
const (
	TCPNetwork = "tcp"
)
View Source 
const (
	UseInterfaceNameCache = true
)

Variables

View Source 
var DefaultRouteIPv4 = netip.MustParsePrefix("0.0.0.0/0")

DefaultRouteIPv4 is the default route “0/0” for IPv4

View Source 
var DefaultRouteIPv6 = netip.MustParsePrefix("::/0")

DefaultRouteIPv6 is the default route “::/0” for IPv6

View Source 
var ErrNoSuchInterface = func() (err error) {
	for _, e := net.InterfaceByName("a b"); e != nil; e = errors.Unwrap(e) {
		err = e
	}
	if err == nil {
		panic(perrors.NewPF("failed to obtain NoSuchInterface from InterfaceByName"))
	}
	return
}()

ErrNoSuchInterface is the value net.errNoSuchInterface

Usage: 

if errors.Is(err, pnet.ErrNoSuchInterface) { …
View Source 
var HardwareAddrLengths = []int{HardwareAddrMac48, HardwareAddrEui64, HardwareAddrInfini}
View Source 
var HardwareAddrLengthsWithZero = append([]int{0}, HardwareAddrLengths...)
View Source 
var IPv4DefaultNetwork = netip.MustParsePrefix("0.0.0.0/0")
View Source 
var IPv4VpnPrefix = netip.MustParsePrefix("0.0.0.0/1")
View Source 
var IPv6DefaultNetwork = netip.MustParsePrefix("::/0")
View Source 
var IPv6VpnPrefix = netip.MustParsePrefix("::/3")
View Source 
var VPNRoute0IPv4 = netip.MustParsePrefix("0.0.0.0/1")

VPNRoute0IPv4 is overriding VPN route “0/1” for IPv4

View Source 
var VPNRoute128IPv4 = netip.MustParsePrefix("128.0.0.0/1")

VPNRoute128IPv4 is overriding VPN route “128/1” for IPv4

View Source 
var VPNRouteIPv6 = netip.MustParsePrefix("::/3")

VPNRouteIPv6 is overriding VPN route “::/3” for IPv6

Functions

func Addr46 added in v0.4.112 

func Addr46(addr netip.Addr) (addr46 netip.Addr)

Addr46 convert 4in6 to 4 for consistent IPv4/IPv6

func AddrPortToTCPAddr added in v0.4.87 

func AddrPortToTCPAddr(addrPort netip.AddrPort) (addrInterface net.Addr)

AddrPortToTCPAddr: Network() "tcp"

func AddrPortToUDPAddr added in v0.4.87 

func AddrPortToUDPAddr(addrPort netip.AddrPort) (addrInterface net.Addr)

AddrPortToUDPAddr: Network() "udp"

func AddrPortToUDPAddr2 added in v0.4.91 

func AddrPortToUDPAddr2(addrPort netip.AddrPort) (addr *net.UDPAddr)

func AddrSlicetoPrefix added in v0.4.112 

func AddrSlicetoPrefix(addrs []net.Addr, do46 bool) (prefixes []netip.Prefix, err error)

AddrSlicetoPrefix returns a netip.Prefix slice from an Addr slice

  • net.Interface.Addrs returns []net.Addr which is really []*net.IPNet
  • IPNet is cidr not address: netip.Prefix

func AddrToIPAddr added in v0.4.87 

func AddrToIPAddr(addr netip.Addr) (addrInterface net.Addr)

AddrToIPAddr: Network() "ip", no port number

func CachedName added in v0.4.88 

func CachedName(ifIndex IfIndex) (name string)

func CheckRedirect 

func CheckRedirect(req *http.Request, via []*http.Request) (err error)

func DumpHardwareAddr added in v0.4.86 

func DumpHardwareAddr(a net.HardwareAddr) (s string)

func EnsureZone added in v0.4.86 

func EnsureZone(addr netip.Addr, ifName string, ifIndex IfIndex, acceptNumeric ...bool) (addr2 netip.Addr, didChange, isNumeric bool, err error)

EnsureZone adds IPv6 zone as applicable

  • only non-global IPv6 should have zone
  • if acceptNumeric true no index to interface-name translation attempts take place. otherwise interface-name zone is preferred
  • a non-numeric zone is attempted from: addr, ifName
  • number cinversion to interfa e is attempted: addr, ifIndex
  • acceptNumeric true leaves an existing numeric zone

func Get 

func Get(requestURL string, tlsConfig *tls.Config, ctx context.Context) (resp *http.Response, err error)

func HardwareAddrInterface added in v0.4.87 

func HardwareAddrInterface(a net.HardwareAddr) (netInterface *net.Interface, isErrNoSuchInterface bool, err error)

func IPAddr 

func IPAddr(IP net.IP, index IfIndex, zone string) (ipa *net.IPAddr, err error)

IPAddr returns IPAddr from IP and IfIndex to IPAddr

func IPNetString 

func IPNetString(ipNet net.IPNet) (s string)

IPNetString is abbreviated form 0/0

func IPNetToPrefix added in v0.4.86 

func IPNetToPrefix(netIPNet *net.IPNet, noIs4In6Translation ...bool) (prefix netip.Prefix, err error)

IPNetToPrefix returns the netip.Prefix that corresponds to older type net.IPNet

  • net.IPNet input is "1.2.3.4/24" or "fe80::1/64"
  • returned netip.Prefix values are valid
  • returned IPv6 addresses has blank Zone

func InterfaceAddrs added in v0.4.87 

func InterfaceAddrs(netInterface *net.Interface) (i4, i6 []netip.Prefix, err error)

InterfaceAddrs gets Addresses for interface

  • netInterface.Name is interface name "eth0"
  • netInterface.Addr() returns assigned IP addresses

func InterfaceFromAddr added in v0.4.88 

func InterfaceFromAddr(addr netip.Addr) (netInterface *net.Interface, prefix netip.Prefix, isNoSuchInterface bool, err error)

InterfaceFromAddr finds network interface and prefix for addr

  • returns interface and prefix or error
  • first uses Zone, then scans all interfaces for prefixes
  • addr must be valid

func InterfacePrefix added in v0.4.88 

func InterfacePrefix(netInterface *net.Interface, addr netip.Addr) (prefix netip.Prefix, err error)

InterfacePrefix returns the network prefix assigned to netInterface that contains addr

  • if addr is not part of any prefix, returned prefix is invalid

func Interfaces added in v0.4.87 

func Interfaces() (interfaces []net.Interface, err error)

func InvertMask 

func InvertMask(IPMask net.IPMask) (out net.IPMask)

InvertMask inverts the bits of a mask the mask for 1.2.3.4/24 is normally ffffff00 or []byte{255, 255, 255, 0}

func IsBroadcast 

func IsBroadcast(addr netip.Addr, IPMask net.IPMask) (isBroadcast bool)

IsBroadcast determines whether addr is the last address for Mask

  • the last address is typically broadcast
  • for 1.2.3.4/24 the network address 1.2.3.255 returns true

func IsDirect 

func IsDirect(route netip.Prefix) bool

IsDirect determines if the route is direct

  • a direct route has mask 32 or 128 bit length /32 /128

func IsErrClosed added in v0.4.26 

func IsErrClosed(err error) (isErrNetClosing bool)

IsErrClosed returns true if err is when waiting for accept and the socket is closed

  • can be used with net.Conn.Accept

func IsHardwareAddrLength added in v0.4.28 

func IsHardwareAddrLength(byts []byte) (isHardwareAddrLength bool)

func IsIPv4 

func IsIPv4(ip net.IP) (isIPv4 bool)

IsIPv4 determines if net.IP value is IPv4

func IsIPv6 

func IsIPv6(ip net.IP) (isIPv6 bool)

IsIPv6 determines if net.IP value is IPv6

func IsNetwork 

func IsNetwork(IP net.IP, IPMask net.IPMask) (isNetwork bool)

IsNetwork determines if IP is the network address (all zeros) for this Mask for 1.2.3.4/24 the network address 1.2.3.0 returns true

func IsNonGlobalIPv6 added in v0.4.86 

func IsNonGlobalIPv6(addr netip.Addr) (needsZone bool)

IsNonGlobalIPv6 returns if addr is an IPv6 address that should have zone

func IsNzIP 

func IsNzIP(ip net.IP) bool

IsNzIP is ip set and not zero

func IsZeros 

func IsZeros(p net.IP) bool

IsZeros determines if every byte of the IP address is zero

func MaskToBits added in v0.4.86 

func MaskToBits(byts []byte) (bits int, err error)

MaskToBits returns number of leading 1-bits in byts

  • convert from net.IPMask to netip.Prefix

func NameCache added in v0.4.87 

func NameCache() (m map[IfIndex]string)

func NetworkPrefixBitCount added in v0.4.29 

func NetworkPrefixBitCount(byts []byte) (bits int)

func NewTLSConfig 

func NewTLSConfig(cert *x509.Certificate) (tlsConfig *tls.Config)

func NewTransport 

func NewTransport(tlsConfig *tls.Config) (httpTransport *http.Transport)

func Prefix46 added in v0.4.112 

func Prefix46(prefix netip.Prefix) (prefix46 netip.Prefix)

func SetTestMap added in v0.4.90 

func SetTestMap(testMap map[IfIndex]string, disableUpdate bool) (oldMap map[IfIndex]string)

func SplitAddrPort added in v0.4.87 

func SplitAddrPort(addrPort netip.AddrPort) (IP net.IP, port int, zone string)

func UpdateNameCache added in v0.4.87 

func UpdateNameCache() (err error)

func Zone added in v0.4.86 

func Zone(addr netip.Addr) (zone string, znum int, hasZone, isNumeric bool)

Zone examines the zone included in addr

  • no zone: hasZone, isNumeric false
  • numeric zone "1": hasZone true, isNumeric false
  • interface-name zone "eth0": hasZone, isNumeric true

Types

type Action added in v0.4.86 

type Action uint8

Action describes the message action 

const (
	AddRoute        Action = iota + 1 // AddRoute describes a new route added to the routing table
	DeleteRoute                       // DeleteRoute describes a deleted route
	RouteReport                       // RouteReport describes an existing route
	Partition                         // Partition describes an existing route that may be overridden
	AddHost                           // AddHost is a host added to the routing table
	DeleteHost                        // DeleteHost is a deleted host
	HostReport                        // HostReport is an existing host
	IfAddAddr                         // IfAddAddr Add address to interface
	IfDeleteAddr                      // IfDeleteAddr Delete address from interface
	IfStatus                          // network-interface upDownStatus or down string
	AddMulticast                      // AddMulticast annouces a multicast address
	DeleteMulticast                   // DeleteMulticast annouces a multicast address disappearing
)

func (Action) Description added in v0.4.88 

func (a Action) Description() (s string)

func (Action) IsValid added in v0.4.90 

func (a Action) IsValid() (isValid bool)

func (Action) String added in v0.4.86 

func (a Action) String() (s string)

type Callback 

type Callback func(msg Message)

Callback allows for processing of routing message,eg. populating a map

type Destination 

type Destination struct {
	netip.Prefix
}

Destination represents a selector for routing, ie. an IPv4 or IPv6 address with zone and prefix. go1.18 introduced netip.Prefix for this purpose see Linux: ip route add. [ root PREFIX ] [ match PREFIX ] [ exact PREFIX ] [ table TABLE_ID ] [ vrf NAME ] [ proto RTPROTO ] [ type TYPE ] [ scope SCOPE ] contains IP, Zone and Mask

func NewDestination 

func NewDestination(prefix netip.Prefix) (d *Destination)

NewDestination instantiates Destination. addr is IPv4 address or IPv6 address with Zone. prefix is number of bits actually used 0…32 for IPv4, 0…128 for IPv6

func (Destination) IsDefaultRoute added in v0.4.83 

func (d Destination) IsDefaultRoute() (isDefault bool)

IsDefaultRoute returns whether Destination is a default route:

  • IPv4: 0/0 or 0.0.0.0/0
  • IPv6: ::

func (Destination) IsValid added in v0.4.86 

func (d Destination) IsValid() (err error)

func (Destination) Key 

func (d Destination) Key() (key netip.Prefix)

Key is a string suitable as a key in a map

func (Destination) String 

func (d Destination) String() (s string)

"1.2.3.4/24" or "2000::/3" - abbreviate IPv4: "127.0.0.0/8" → "127/8" - IPv4 default route: "0.0.0.0/0" → "0/0"

  • IPv6 default route stays "::/0"

type HandlerFunc 

type HandlerFunc func(http.ResponseWriter, *http.Request)

type Http 

type Http struct {
	Network string // "tcp", "tcp4", "tcp6", "unix" or "unixpacket"
	http.Server
	ListenInvoked atomic.Bool
	ReadyWg       sync.WaitGroup
	ErrCh         chan<- error
	ErrChMutex    sync.Mutex
	ErrChClosed   atomic.Bool
	net.Addr      // interface
	IsListening   atomic.Bool
	IsShutdown    atomic.Bool
}

func NewHttp 

func NewHttp(host, network string) (hp *Http)

NewHttp creates http server host is host:port, default ":http"

func (*Http) CloseErr 

func (hp *Http) CloseErr()

func (*Http) HandleFunc 

func (hp *Http) HandleFunc(pattern string, handler HandlerFunc)

func (*Http) Listen 

func (hp *Http) Listen() (errCh <-chan error)

func (*Http) Listener 

func (hp *Http) Listener() (listener net.Listener, err error)

func (*Http) SendErr 

func (hp *Http) SendErr(err error)

func (*Http) Shutdown 

func (hp *Http) Shutdown()

func (*Http) SubListen 

func (hp *Http) SubListen() (errCh <-chan error)

func (*Http) WaitForUp 

func (hp *Http) WaitForUp() (isUp bool, addr net.Addr)

type HttpClient 

type HttpClient struct {
	http.Client
}

func NewHttpClient 

func NewHttpClient(tlsConfig *tls.Config) (httpClient *HttpClient)

func (*HttpClient) Get 

func (ct *HttpClient) Get(requestURL string, ctx context.Context) (resp *http.Response, err error)

type Https 

type Https struct {
	Http
	Cert    parl.CertificateDer
	Private crypto.Signer
}

func NewHttps 

func NewHttps(host, network string, certDER parl.CertificateDer, signer crypto.Signer) (hp *Https)

func (*Https) Listen 

func (hp *Https) Listen() (errCh <-chan error)

func (*Https) TLS 

func (hp *Https) TLS() (tlsListener net.Listener, err error)

type IfIndex 

type IfIndex uint32

IfIndex is a dynamic reference to a network interface on Linux systems

func NewIfIndex added in v0.4.28 

func NewIfIndex(index uint32) (ifIndex IfIndex)

func NewIfIndexInt added in v0.4.86 

func NewIfIndexInt(value int) (ifIndex IfIndex, err error)

func (IfIndex) Interface 

func (ifIndex IfIndex) Interface() (netInterface *net.Interface, isErrNoSuchInterface bool, err error)

Interface gets net.Interface for ifIndex

  • netInterface.Name is interface name "eth0"
  • netInterface.Addr() returns assigned IP addresses

func (IfIndex) InterfaceAddrs added in v0.4.86 

func (ifIndex IfIndex) InterfaceAddrs(useNameCache ...NameCacher) (name string, i4, i6 []netip.Prefix, err error)

InterfaceAddrs gets Addresses for interface

  • netInterface.Name is interface name "eth0"
  • netInterface.Addr() returns assigned IP addresses

func (IfIndex) InterfaceIndex added in v0.4.28 

func (ifIndex IfIndex) InterfaceIndex() (interfaceIndex int)

Interface gets net.Interface for ifIndex

  • InterfaceIndex is unique for promting methods

func (IfIndex) IsValid added in v0.4.28 

func (ifIndex IfIndex) IsValid() (isValid bool)

IsValid determines if interface index value is set, ie. > 0

func (IfIndex) String added in v0.4.28 

func (ifIndex IfIndex) String() (s string)

"#13"

func (IfIndex) Zone 

func (ifIndex IfIndex) Zone() (zone string, isNumeric bool, err error)

Zone gets net.IPAddr.Zone string for ifIndex

  • if an interfa ce name can be ontained, that is the zone
  • otherwise a numeric zone is used
  • if ifIndex is invalid, empty string

type InterfaceCache added in v0.4.87 

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

InterfaceCache is a cache mapping per-boot stable network interface index #1 to name "lo0". Thread-Safe

func NewInterfaceCache added in v0.4.87 

func NewInterfaceCache() (interfaceCache *InterfaceCache)

NewInterfaceCache returns a cache mapiing network-interfac eindex to name. Thread-Safe

func (*InterfaceCache) CachedName added in v0.4.87 

func (i *InterfaceCache) CachedName(ifIndex IfIndex, noUpdate ...NameCacher) (name string, err error)

CachedName retrieves a name by index with optional cache update. Thread-Safe

  • default is to update
  • unknown index returns empty string

func (*InterfaceCache) CachedNameNoUpdate added in v0.4.87 

func (i *InterfaceCache) CachedNameNoUpdate(ifIndex IfIndex) (name string)

CachedNameNoUpdate retrieves a name by index with no cache update. Thread-Safe

func (*InterfaceCache) Init added in v0.4.87 

func (i *InterfaceCache) Init() (i0 *InterfaceCache)

Init loads the cache, an opeation that may fail. Funtional chaining. Thread-Safe

func (*InterfaceCache) Map added in v0.4.87 

func (i *InterfaceCache) Map() (m map[IfIndex]string)

Map returns a copy of the current cache. Thread-Safe

func (*InterfaceCache) SetMap added in v0.4.90 

func (i *InterfaceCache) SetMap(newMap map[IfIndex]string) (oldMap map[IfIndex]string)

Map replaces the cache. Thread-Safe

  • do not read from or write to newMap after SetMap

func (*InterfaceCache) Update added in v0.4.87 

func (i *InterfaceCache) Update() (m map[IfIndex]string, err error)

Update updates the cache by reading all system interfaces. Thread-Safe

type LinkAddr 

type LinkAddr struct {
	IfIndex                 // 0 is none
	Name             string // "" none
	net.HardwareAddr        // []byte
}

LinkAddr contains an Ethernet mac address, its interface name and interface index

func NewLinkAddr 

func NewLinkAddr(index IfIndex, name string) (linkAddr *LinkAddr)

NewLinkAddr instantiates LinkAddr

func (*LinkAddr) Dump added in v0.4.86 

func (a *LinkAddr) Dump() (s string)

func (*LinkAddr) Interface added in v0.4.87 

func (a *LinkAddr) Interface() (netInterface *net.Interface, isNoSuchInterface bool, err error)

Interface returns net.Interface associated with LinkAddr

  • order is index, name, mac
  • if LinkAddr is zero-value, nil is returned

func (*LinkAddr) IsComplete added in v0.4.90 

func (a *LinkAddr) IsComplete() (isComplete bool)

func (*LinkAddr) IsValid added in v0.4.86 

func (a *LinkAddr) IsValid() (isValid bool)

func (*LinkAddr) IsZeroValue added in v0.4.86 

func (a *LinkAddr) IsZeroValue() (isZeroValue bool)

func (*LinkAddr) NonZero added in v0.4.86 

func (a *LinkAddr) NonZero() (s string)

"#13_en5_00:00:5e:00:53:01"

  • zero-values are skipped
  • zero-value: "zero-value"

func (*LinkAddr) OneString 

func (a *LinkAddr) OneString() string

OneString picks the most meaningful value

  • interface name or hardware address or #interface index or "0"

func (*LinkAddr) SetHw added in v0.4.86 

func (a *LinkAddr) SetHw(hw net.HardwareAddr) (err error)

func (*LinkAddr) SetName added in v0.4.90 

func (a *LinkAddr) SetName(name string)

func (*LinkAddr) String 

func (a *LinkAddr) String() (s string)

"en8(28)00:11:22:33:44:55:66"

func (*LinkAddr) UpdateFrom added in v0.4.90 

func (a *LinkAddr) UpdateFrom(b *LinkAddr) (isComplete bool)

func (*LinkAddr) UpdateName 

func (a *LinkAddr) UpdateName() (linkAddr *LinkAddr, err error)

UpdateName attempts to populate interface name if not already present

func (*LinkAddr) ZoneID 

func (a *LinkAddr) ZoneID() string

ZoneID is the IPv6 ZoneID for this interface

type Message 

type Message interface {
	Action() (action Action)
	Dump() (dump string)
	fmt.Stringer
}

Message is a portable routing message emitted by the netlink socket or obtain via sysctl

type NameCacher added in v0.4.90 

type NameCacher uint8

NameCacher contaisn instructions for interface-name cache read: NoCache Update NoUpdate 

const (
	NoCache  NameCacher = iota // name cache should not be used in the api call
	Update                     // use name cache and update the cache first
	NoUpdate                   // use name cache without update. Mechanic for ongoing name cache update is required
)

type Network added in v0.4.94 

type Network string

func (Network) IsValid added in v0.4.94 

func (t Network) IsValid() (isValid bool)

func (Network) String added in v0.4.94 

func (t Network) String() (s string)

type NextHop 

type NextHop struct {
	/*
		if NextHop is an address on the local host or on a local subnet,
		Gateway is nil
		LinkAddr describes the local interface
		Src is the address on that local interface

		If Nexthop is remote, beyond any local subnet,
		Gateway is an IP on a local subnet
		LinkAddr describes the local interface for that subnet
		Src is the address on that local interface
	*/
	Gateway  netip.Addr
	LinkAddr            // LinkAddr is the hosts’s network interface where to send packets
	Src      netip.Addr // the source ip to use for originating packets on LinkAddr
	// contains filtered or unexported fields
}

NextHop describes a route target

func NewNextHop 

func NewNextHop(gateway netip.Addr, linkAddr *LinkAddr, src netip.Addr) (nextHop *NextHop)

NewNextHop assembles a route destination

func NewNextHop2 

func NewNextHop2(index IfIndex, gateway netip.Addr, src netip.Addr) (next *NextHop, err error)

NewNextHop2 assembles a route destination based on IfIndex

func NewNextHop3 added in v0.4.90 

func NewNextHop3(gateway netip.Addr, linkAddr *LinkAddr, src netip.Addr, nIPv4, nIPv6 int) (nextHop *NextHop)

func NewNextHopCounts added in v0.4.28 

func NewNextHopCounts(gateway netip.Addr, linkAddr *LinkAddr, src netip.Addr,
	useNameCache ...NameCacher,
) (nextHop *NextHop, err error)

NewNextHopCounts returns NextHop with current IP address counts

  • if input LinkAddr does not have interface name, interface name is added to output nextHop
  • 6in4 are converted to IPv4

func (*NextHop) Dump added in v0.4.86 

func (n *NextHop) Dump() (s string)

func (*NextHop) HasGateway 

func (n *NextHop) HasGateway() bool

HasGateway determines if next hop uses a remote gateway

func (*NextHop) HasSrc 

func (n *NextHop) HasSrc() bool

HasSrc determines if next hop has src specified

func (*NextHop) IsZeroValue added in v0.4.86 

func (n *NextHop) IsZeroValue() (isZeroValue bool)

func (*NextHop) Name added in v0.4.87 

func (n *NextHop) Name(useNameCache ...NameCacher) (name string, err error)

Name returns nextHop interface name

  • name can be returned empty
  • name of Linkaddr, then interface from index, name, mac

func (*NextHop) String 

func (n *NextHop) String() (s string)

func (*NextHop) Target 

func (n *NextHop) Target() (gateway netip.Addr, s string)

Target describes the destination for this next hop

  • gateway is invalid for local network targets or gateway unspecified address "0.0.0.0"
  • s is:
  • empty string for nil NextHop
  • network interface name mac index or 0 for gateway missing, invalid or unspecified
  • otherwise gateway ip, interface description and source IP or source cidr

type Route 

type Route struct {
	Destination
	NextHop
}

Route describes a routing table route with destination and next hop

func NewRoute 

func NewRoute(d *Destination, nextHop *NextHop) *Route

NewRoute instantiates Route

func (*Route) Dump added in v0.4.86 

func (r *Route) Dump() (s string)

func (*Route) String added in v0.4.28 

func (r *Route) String() (s string)

type SocketListener added in v0.4.94 

type SocketListener[C net.Conn] struct {
	// contains filtered or unexported fields
}

TCPListener embeds net.TCPListener

  • panic-handled connection threads
  • Ch: real-time error channel or collecting errors after close: Err
  • WaitCh: idempotent waitable thread-terminating Close
  • C is net.Conn, *net.TCPConn, …

func NewSocketListener added in v0.4.94 

func NewSocketListener[C net.Conn](
	listener net.Listener,
	network Network,
	transport SocketTransport,
) (socket *SocketListener[C])

NewSocketListener returns object for receiving IPv4 tcp connections

  • handler must invoke net.Conn.Close

func (*SocketListener[C]) AcceptConnections added in v0.4.94 

func (s *SocketListener[C]) AcceptConnections(handler func(C))

AcceptConnections is a blocking function handling inbound connections

  • AcceptConnections can only be invoked once
  • accept of connections continues until Close is invoked
  • handler must invoke net.Conn.Close

func (*SocketListener[C]) AddrPort added in v0.4.94 

func (s *SocketListener[C]) AddrPort() (addrPort netip.AddrPort, err error)

func (*SocketListener[C]) Ch added in v0.4.94 

func (s *SocketListener[C]) Ch() (ch <-chan error)

Ch returns a real-time error channel

  • unread errors can also be collected using [TCPListener.Err]

func (*SocketListener[C]) Close added in v0.4.94 

func (s *SocketListener[C]) Close() (err error)

func (*SocketListener[C]) Err added in v0.4.94 

func (s *SocketListener[C]) Err(errp *error)

Err returns all unread errors

  • errors can also be read using [TCPListener.Ch]

func (*SocketListener[C]) IsAccept added in v0.4.94 

func (s *SocketListener[C]) IsAccept() (isAcceptThread bool)

IsAccept indicates whether the listener is functional and accepting incoming connections

func (*SocketListener[C]) Listen added in v0.4.94 

func (s *SocketListener[C]) Listen(socketString string) (err error)

Listen binds listening to a near socket

  • socketString is host:port "1.2.3.4:80" "wikipedia.com:443" "/some/unix/socket"
  • — for TCP UDP IP host must resolve to an assigned near IP address
  • — — if host is blank, it is for localhost
  • — — to avoid DNS resolution host should be blank or literal IP address "1.2.3.4:0"
  • — for TCP UDP port must be literal port number 0…65534 where 0 means a temporary port
  • Listen can be repeatedly invoked until it succeeds

func (*SocketListener[C]) WaitCh added in v0.4.94 

func (s *SocketListener[C]) WaitCh() (closeWait chan struct{})

WaitCh returns a channel that closes when [] completes

  • ListenTCP4.Close needs to have been invoked for the channel to close

type SocketTransport added in v0.4.94 

type SocketTransport uint8

func (SocketTransport) IsValid added in v0.4.94 

func (t SocketTransport) IsValid() (isValid bool)

func (SocketTransport) String added in v0.4.94 

func (t SocketTransport) String() (s string)

type TCPListener added in v0.4.62 

type TCPListener struct {
	*net.TCPListener             // the TCP IPv4 or IPv6 listening socket promoting TCP-specific methods
	SocketListener[*net.TCPConn] // connection-handler argument is *net.TCPConn
}

TCPListener embeds net.TCPListener

  • panic-handled connection threads receiving *net.TCPConn
  • Ch: real-time error channel or
  • Err: collecting errors after close
  • idempotent panic-free awaitable Close
  • WaitCh: channel closing on Close complete

func NewTCPListener added in v0.4.94 

func NewTCPListener(network ...Network) (socket *TCPListener)

NewTCPListener returns object for receiving IPv4 tcp connections

func (*TCPListener) Close added in v0.4.93 

func (s *TCPListener) Close() (err error)

- idempotent panic-free awaitable Close

type Tcp 

type Tcp struct {
	net.Addr // interface
	http.ServeMux
	http.Server
	// contains filtered or unexported fields
}

type UDP 

type UDP struct {
	Network        string
	F              UDPFunc
	MaxSize        int
	net.UDPAddr    // struct IP Port Zone
	ListenInvoked  atomic.Bool
	StartingListen sync.WaitGroup
	ErrCh          chan<- error
	IsListening    atomic.Bool
	NetUDPConn     *net.UDPConn

	Addr       net.Addr
	IsShutdown atomic.Bool
	// contains filtered or unexported fields
}

func NewUDP 

func NewUDP(network, address string, udpFunc UDPFunc, maxSize int) (udp *UDP)

NewUDP network: "udp" "udp4" "udp6" address: "host:port"

func (*UDP) Listen 

func (udp *UDP) Listen() (errCh <-chan error)

func (*UDP) Shutdown 

func (udp *UDP) Shutdown()

func (*UDP) WaitForUp 

func (udp *UDP) WaitForUp() (isUp bool, addr net.Addr)

type UDPFunc 

type UDPFunc func(b []byte, oob []byte, flags int, addr *net.UDPAddr)

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.