netLayer

Dec 28, 2022

Changes in this version

+ const DefaultCommonReadTimeout

+ const DefaultDialTimeout

+ const DefaultUDP_fullcone_timeout

+ const DefaultUDP_timeout

+ var CommonReadTimeout = DefaultCommonReadTimeout

+ var GetSystemDNS = func() (result []string)

+ var GetSystemProxyState = func(isSocks5 bool) (ok, enabled bool, addr, port string)

+ var SetSystemDNS = func(dns string)

+ var ToggleSystemProxy = func(isSocks5 bool, addr, port string, enable bool)

+ func CanWEverSplice(writeConn io.Writer) (wCanSplice bool)

+ func GetDefaultHardwarePort() (string, error) — darwin/amd64

+ func GetDefaultNetworkAdapterName() string — windows/amd64

+ func GetDeviceNameIndex(idx int) string

+ func GetGateway() (ip net.IP, ifName string, err error) — linux/amd64

+ func GetGateway() (ip net.IP, index int, err error) — darwin/amd64

+ func GetGateway() (routerIP, selfIP string, err error) — windows/amd64

+ func GetGatewayDeviceName() (string, error) — darwin/amd64

+ func GetHardwarePortByInterfaceName(str string) string — darwin/amd64

+ func GetNetworkAdapterNameByIP(ip string) string — windows/amd64

+ func IsUnix(r any) *net.UnixConn

+ func NetworkHasNoPortField(s string) bool

+ func PersistRead(c net.Conn)

+ func PersistWrite(c net.Conn)

+ func PrintAllInterface(w io.Writer)

+ func ReturnSpliceRead(c net.Conn) (bool, *net.TCPConn, *net.UnixConn)

+ func SetCommonReadTimeout(c net.Conn) error

+ func SetCommonWriteTimeout(c net.Conn) error

type Addr

+ func (a *Addr) RawUrlString() string

+ type ChanCloseConn struct

+ CChan chan struct{}

+ func (c *ChanCloseConn) Close() error

+ type ConnList struct

+ func (cl *ConnList) CloseDelete(c net.Conn)

+ func (cl *ConnList) CloseDeleteAll()

+ func (cl *ConnList) Delete(c net.Conn)

+ func (cl *ConnList) Insert(c net.Conn)

type ConnWrapper

+ Upstream func() net.Conn

type DNSMachine

+ func (dm *DNSMachine) ListenUrl(addr string) error

+ func (dm *DNSMachine) ServeDNS(w dns.ResponseWriter, r *dns.Msg)

+ func (dm *DNSMachine) StartListen()

+ func (dm *DNSMachine) Stop()

type DnsConf

+ Listen string

type MsgConn

+ ReadMsg func() (data []byte, peer Addr, err error)

+ WriteMsg func(data []byte, peer Addr) error

type MsgConnForPacketConn

+ func (mc *MsgConnForPacketConn) ReadMsg() ([]byte, Addr, error)

+ func (mc *MsgConnForPacketConn) WriteMsg(p []byte, a Addr) error

+ type MsgConnNetAdapter struct

+ LA net.Addr

+ RA net.Addr

+ func (ma MsgConnNetAdapter) LocalAddr() net.Addr

+ func (ma MsgConnNetAdapter) Read(p []byte) (int, error)

+ func (ma MsgConnNetAdapter) RemoteAddr() net.Addr

+ func (ma MsgConnNetAdapter) Write(p []byte) (int, error)

+ type SpliceReader interface

+ CanSpliceRead func() (bool, *net.TCPConn, *net.UnixConn)

+ EverPossibleToSpliceRead func() bool

type Splicer

+ CanSpliceWrite func() (bool, *net.TCPConn)

+ EverPossibleToSpliceWrite func() bool

+ type TCPRequestInfo struct

+ Target Addr

type UDPConn

+ func (uc *UDPConn) WriteMsg(buf []byte, addr Addr) error

type UDPMsgConn

+ func (u *UDPMsgConn) ReadMsg() ([]byte, Addr, error)

+ func (u *UDPMsgConn) WriteMsg(bs []byte, raddr Addr) error

+ type UDPRequestInfo struct

+ Target Addr

+ type UniSourceMsgConnForPacketConn struct

+ Source Addr

+ func (mc *UniSourceMsgConnForPacketConn) Close() error

+ func (mc *UniSourceMsgConnForPacketConn) CloseConnWithRaddr(raddr Addr) error

+ func (mc *UniSourceMsgConnForPacketConn) Fullcone() bool

+ func (mc *UniSourceMsgConnForPacketConn) ReadMsg() ([]byte, Addr, error)

+ func (mc *UniSourceMsgConnForPacketConn) WriteMsg(p []byte, a Addr) error

type UniTargetMsgConn

+ func (u UniTargetMsgConn) ReadMsg() ([]byte, Addr, error)

+ func (u UniTargetMsgConn) WriteMsg(bs []byte, _ Addr) error

Dec 4, 2022

Changes in this version

+ const DefaultGeositeFolder

+ const Dual

+ const DualNetworkName

+ const IP

+ const MMDB_DownloadLink

+ const UnknownNetwork

+ var DialTimeout time.Duration = defaultDialTimeout

+ var GeositeFolder = DefaultGeositeFolder

+ var UDP_fullcone_timeout = time.Minute * 30

+ func CanRSplice(r io.Reader) bool

+ func CanWSplice(w io.Writer) bool

+ func CopyMsgFromP2C(p MsgProducer, c MsgConsumer, countPtr *uint64)

+ func HasGeositeFolder() bool

+ func IsTCP(r any) *net.TCPConn

+ func RandPortStr_safe(mustValid, isudp bool) string

+ func RelayMsg(rc, lc MsgHub, downloadByteCount, uploadByteCount *uint64) uint64

+ func StrToNetAddr(network, s string) (net.Addr, error)

type Addr

+ func (a *Addr) ToAddr() net.Addr

type DNSMachine

+ SpecialServerPolicy map[string]string

+ TTLStrategy uint64

type DnsConf

+ TTLStrategy uint64

type IOWrapper

+ Rejecter RejectConn

+ func (iw *IOWrapper) Reject()

+ func (iw *IOWrapper) RejectBehaviorDefined() bool

+ type IPRecord struct

+ IP net.IP

+ RecordTime time.Time

+ TTL uint32

+ type MsgConnForPacketConn struct

+ func (mc *MsgConnForPacketConn) Close() error

+ func (mc *MsgConnForPacketConn) CloseConnWithRaddr(raddr Addr) error

+ func (mc *MsgConnForPacketConn) Fullcone() bool

+ func (mc *MsgConnForPacketConn) ReadMsgFrom() ([]byte, Addr, error)

+ func (mc *MsgConnForPacketConn) WriteMsgTo(p []byte, a Addr) error

+ type MsgConsumer interface

+ ConsumeMsg func(msg []byte, from, to Addr) (err error)

+ type MsgHub interface

+ type MsgProducer interface

+ ProduceMsg func() (msg []byte, from, to Addr, err error)

+ type RejectConn interface

+ Reject func()

+ RejectBehaviorDefined func() bool

type RoutePolicy

+ func (rp *RoutePolicy) CalcuOutTag(td *TargetDescription) string

+ type TCPUDPAddr struct

+ func (tu *TCPUDPAddr) Network() string

+ func (tu *TCPUDPAddr) String() string

type UDPMsgConn

+ func (uc *UDPMsgConn) ReadFrom(p []byte) (n int, addr net.Addr, err error)

+ func (uc *UDPMsgConn) WriteTo(p []byte, raddr net.Addr) (n int, err error)

May 20, 2022

Changes in this version

+ var CustomDialerMap = make(map[string]func(address string, timeout time.Duration) (net.Conn, error))

+ var CustomListenerMap = make(map[string]func(address string) (net.Listener, error))

type Addr

+ func V2rayGetAddrFrom(buf utils.ByteReader) (addr Addr, err error)

type RoutePolicy

+ func (policy *RoutePolicy) LoadRulesForRoutePolicy(rules []*RuleConf)

May 12, 2022

Changes in this version

+ func PrepareInterfaces()

+ type ConnWrapper interface

+ GetRawConn func() net.Conn

type RouteSet

+ Users map[string]bool

type RuleConf

+ Users []string

type TargetDescription

+ InTag string

+ UserIdentityStr string

May 8, 2022

Changes in this version

+ func PersistConn(c net.Conn)

type RouteSet

+ func (sg *RouteSet) IsNoLimitForNetworkLayer() bool

May 6, 2022

Changes in this version

+ var ErrInvalidWrite = errors.New("readfrom, invalid write result")

+ func WritePROXYprotocol(xver int, wlc NetAddresser, wrc io.Writer) (n int, err error)

type Addr

+ func NewAddrFromTCPAddr(addr *net.TCPAddr) Addr

+ type EasyDeadline struct

+ func (ed *EasyDeadline) InitEasyDeadline()

+ func (ed *EasyDeadline) ReadTimeoutChan() chan struct{}

+ func (ed *EasyDeadline) SetDeadline(t time.Time) error

+ func (ed *EasyDeadline) SetReadDeadline(t time.Time) error

+ func (ed *EasyDeadline) SetWriteDeadline(t time.Time) error

+ func (ed *EasyDeadline) WriteTimeoutChan() chan struct{}

+ type EasyNetAddresser struct

+ LA net.Addr

+ RA net.Addr

+ func (iw *EasyNetAddresser) LocalAddr() net.Addr

+ func (iw *EasyNetAddresser) RemoteAddr() net.Addr

+ type IOWrapper struct

+ CloseChan chan struct{}

+ FirstWriteChan chan struct{}

+ func (iw *IOWrapper) Close() error

+ func (iw *IOWrapper) Read(p []byte) (int, error)

+ func (iw *IOWrapper) Write(p []byte) (int, error)

+ type NetAddresser interface

+ LocalAddr func() net.Addr

+ RemoteAddr func() net.Addr

+ type NetDeadliner interface

+ SetDeadline func(t time.Time) error

+ SetReadDeadline func(t time.Time) error

+ SetWriteDeadline func(t time.Time) error

Apr 29, 2022

Changes in this version

+ const AtypDomain

+ const AtypIP4

+ const AtypIP6

+ const DefaultReadvOption

+ const KCP

+ const MaxUDP_packetLen

+ const Quic

+ const Raw_socket

+ const ReadvSingleBufLen

+ const SystemCanSplice

+ const TCP

+ const UDP

+ const UNIX

+ var ErrMachineCantConnectToIpv6 = errors.New("ErrMachineCanConnectToIpv6")

+ var ErrRecursion = errors.New("multiple recursion not allowed")

+ var ErrTimeout = errors.New("timeout")

+ var GeoipFileName string

+ var GeositeListMap = make(map[string]*GeositeList)

+ var UDP_timeout = time.Minute * 3

+ var UseReadv bool

+ func ATypeToSocks5Standard(atype byte) byte

+ func CanSpliceDirectly(r any) bool

+ func CanSpliceEventually(r any) bool

+ func ClassicCopy(w io.Writer, r io.Reader) (written int64, err error)

+ func DNSQuery(domain string, dns_type uint16, conn *dns.Conn, theMux *sync.Mutex, ...) (net.IP, error)

+ func DialDnsAddr(addr *Addr) (conn net.Conn, err error)

+ func DownloadCommunity_DomainListFiles(proxyurl string)

+ func GetIP_ISO(ip net.IP) string

+ func GetIP_ISO_byReader(db *maxminddb.Reader, ip net.IP) string

+ func GetRandLocalAddr(mustValid, isudp bool) string

+ func GetRandLocalPrivateAddr(mustValid, isudp bool) string

+ func GetRawConn(reader io.Reader) syscall.RawConn

+ func HasEmbedGeoip() bool

+ func HasFullOrSubDomain(domain string, ds DomainHaser) bool

+ func HasIpv6Interface() bool

+ func IsBasicConn(r interface{}) bool

+ func IsConnGoodForReadv(c net.Conn) (r int, rawReadConn syscall.RawConn, mr utils.MultiReader)

+ func IsDomainInsideGeosite(geositeName string, domain string) bool

+ func IsStrUDP_network(s string) bool

+ func Is_DNSQuery_returnType_ReadErr(err error) bool

+ func Is_DNSQuery_returnType_ReadFatalErr(err error) bool

+ func ListenAndAccept(network, addr string, sockopt *Sockopt, acceptFunc func(net.Conn)) (listener net.Listener, err error)

+ func LoadGeositeFiles() (err error)

+ func LoadMaxmindGeoipFile(fn string)

+ func LoadRulesForRoutePolicy(rules []*RuleConf, policy *RoutePolicy)

+ func ParseStrToAddr(s string) (atyp byte, addr []byte, port_uint16 uint16, err error)

+ func Prepare()

+ func RandPort(mustValid, isudp bool) (p int)

+ func RandPortStr(mustValid, isudp bool) string

+ func RandPort_andStr(mustValid, isudp bool) (int, string)

+ func ReadBuffersFrom(c io.Reader, rawReadConn syscall.RawConn, mr utils.MultiReader) (buffers [][]byte, err error)

+ func Relay(realTargetAddr *Addr, rc, lc io.ReadWriteCloser, ...) int64

+ func RelayUDP(rc, lc MsgConn, downloadByteCount, uploadByteCount *uint64) uint64

+ func RelayUDP_separate(rc, lc MsgConn, firstAddr *Addr, downloadByteCount, uploadByteCount *uint64, ...) uint64

+ func SetSockOpt(fd int, sockopt *Sockopt, isudp bool, isipv6 bool)

+ func SetSockOptForListener(tcplistener ListenerWithFile, sockopt *Sockopt, isudp bool, isipv6 bool)

+ func StrToTransportProtocol(s string) uint16

+ func TryCopy(writeConn io.Writer, readConn io.Reader) (allnum int64, err error)

+ func TryCopyOnce(writeConn io.Writer, readConn io.Reader) (allnum int64, err error)

+ func TryReadFrom_withSplice(classicWriter io.Writer, maySpliceConn net.Conn, r io.Reader, ...) (written int64, err error)

+ func UDPAddr2AddrPort(ua *net.UDPAddr) netip.AddrPort

+ func UDPAddr_v4_to_Bytes(addr *net.UDPAddr) [6]byte

+ type Addr struct

+ IP net.IP

+ Name string

+ Network string

+ Port int

+ func NewAddr(addrStr string) (Addr, error)

+ func NewAddrByHostPort(hostPortStr string) (Addr, error)

+ func NewAddrByURL(addrStr string) (Addr, error)

+ func NewAddrFromAny(thing any) (addr Addr, err error)

+ func NewAddrFromUDPAddr(addr *net.UDPAddr) Addr

+ func (a *Addr) AddressBytes() (addr []byte, atyp byte)

+ func (a *Addr) Dial() (net.Conn, error)

+ func (a *Addr) GetHashable() (ha HashableAddr)

+ func (a *Addr) GetNetIPAddr() (na netip.Addr)

+ func (a *Addr) HostStr() string

+ func (a *Addr) IsEmpty() bool

+ func (a *Addr) IsIpv6() bool

+ func (a *Addr) IsUDP() bool

+ func (a *Addr) String() string

+ func (a *Addr) ToTCPAddr() *net.TCPAddr

+ func (a *Addr) ToUDPAddr() *net.UDPAddr

+ func (a *Addr) UrlString() string

+ func (a Addr) DialWithOpt(sockopt *Sockopt) (net.Conn, error)

+ func (a Addr) ListenUDP_withOpt(sockopt *Sockopt) (net.PacketConn, error)

+ type AddrData struct

+ Addr Addr

+ Data []byte

+ type ConnWithFile interface

+ File func() (f *os.File, err error)

+ type DNSMachine struct

+ SpecialIPPollicy map[string][]netip.Addr

+ SpecialServerPollicy map[string]string

+ TypeStrategy int64

+ func LoadDnsMachine(conf *DnsConf) *DNSMachine

+ func (dm *DNSMachine) AddNewServer(name string, addr *Addr) error

+ func (dm *DNSMachine) Query(domain string) (ip net.IP)

+ func (dm *DNSMachine) QueryType(domain string, dns_type uint16) (ip net.IP)

+ func (dm *DNSMachine) SetDefaultConn(c net.Conn, addr *Addr)

+ type DnsConf struct

+ Hosts map[string]any

+ Servers []any

+ Strategy int64

+ type DnsConn struct

+ Name string

+ func (c *DnsConn) Dial() error

+ type DomainHaser interface

+ HasDomain func(string) bool

+ type GeositeAttr struct

+ Key string

+ Value any

+ type GeositeDomain struct

+ Attrs []GeositeAttr

+ Type string

+ Value string

+ type GeositeList struct

+ Domains map[string]GeositeDomain

+ FullDomains map[string]GeositeDomain

+ Name string

+ RegexDomains []*regexp.Regexp

+ type GeositeRawList struct

+ Domains []GeositeDomain

+ Name string

+ func LoadGeositeFile(path string) (*GeositeRawList, error)

+ func ParseGeositeList(list *GeositeRawList, ref map[string]*GeositeRawList) (*GeositeRawList, error)

+ func (grl *GeositeRawList) ToGeositeList() (gl *GeositeList)

+ type HashableAddr struct

+ Name string

+ Network string

+ type ListenerWithFile interface

+ File func() (f *os.File, err error)

+ type MapDomainHaser map[string]bool

+ func (mdh MapDomainHaser) HasDomain(d string) bool

+ type MapGeositeDomainHaser map[string]GeositeDomain

+ func (mdh MapGeositeDomainHaser) HasDomain(d string) bool

+ type MsgConn interface

+ Close func() error

+ CloseConnWithRaddr func(raddr Addr) error

+ Fullcone func() bool

+ ReadMsgFrom func() ([]byte, Addr, error)

+ WriteMsgTo func([]byte, Addr) error

+ type PipeDeadline struct

+ func MakePipeDeadline() PipeDeadline

+ func (d *PipeDeadline) Set(t time.Time)

+ func (d *PipeDeadline) Wait() chan struct{}

+ type ReadWrapper struct

+ OptionalReader io.Reader

+ RemainFirstBufLen int

+ func (rw *ReadWrapper) Read(p []byte) (n int, err error)

+ func (rw *ReadWrapper) WriteBuffers(buffers [][]byte) (int64, error)

+ type RoutePolicy struct

+ List []*RouteSet

+ func NewRoutePolicy() *RoutePolicy

+ func (rp *RoutePolicy) AddRouteSet(rs *RouteSet)

+ func (rp *RoutePolicy) GetOutTag(td *TargetDescription) string

+ type RouteSet struct

+ AllowedTransportLayerProtocols uint16

+ Countries map[string]bool

+ Domains map[string]bool

+ Full map[string]bool

+ Geosites []string

+ IPs map[netip.Addr]bool

+ InTags map[string]bool

+ Match []string

+ NetRanger cidranger.Ranger

+ OutTag string

+ OutTags []string

+ Regex []*regexp.Regexp

+ func LoadRuleForRouteSet(rule *RuleConf) (rs *RouteSet)

+ func NewFullRouteSet() *RouteSet

+ func NewRouteSetForMyCountry(iso string) *RouteSet

+ func (sg *RouteSet) IsAddrIn(a Addr) bool

+ func (sg *RouteSet) IsAddrNetworkAllowed(a Addr) bool

+ func (sg *RouteSet) IsIn(td *TargetDescription) bool

+ func (sg *RouteSet) IsTCPAllowed() bool

+ func (sg *RouteSet) IsTransportProtocolAllowed(p uint16) bool

+ func (sg *RouteSet) IsUDPAllowed() bool

+ type RuleConf struct

+ Countries []string

+ DialTag any

+ Domains []string

+ IPs []string

+ InTags []string

+ Network []string

+ type Sockopt struct

+ Device string

+ Somark int

+ TProxy bool

+ type SpecialDnsServerConf struct

+ AddrUrlStr string

+ Domains []string

+ type Splicer interface

+ CanSplice func() (bool, net.Conn)

+ EverPossibleToSplice func() bool

+ type TargetDescription struct

+ Addr Addr

+ Tag string

+ type UDPAddrData struct

+ Addr net.UDPAddr

+ Data []byte

+ type UDPConn struct

+ func DialUDP(raddr *net.UDPAddr) (*UDPConn, error)

+ func NewUDPConn(raddr *net.UDPAddr, conn *net.UDPConn, isClient bool) *UDPConn

+ func (uc *UDPConn) Close() error

+ func (uc *UDPConn) CloseConnWithRaddr(_ Addr) error

+ func (uc *UDPConn) CloseMsgChan()

+ func (uc *UDPConn) GetReadChan() chan UDPAddrData

+ func (uc *UDPConn) LocalAddr() net.Addr

+ func (uc *UDPConn) Read(buf []byte) (n int, err error)

+ func (uc *UDPConn) ReadFrom(p []byte) (n int, addr net.Addr, err error)

+ func (uc *UDPConn) ReadMsg() (b []byte, err error)

+ func (uc *UDPConn) ReadMsgFrom() ([]byte, Addr, error)

+ func (uc *UDPConn) RemoteAddr() net.Addr

+ func (uc *UDPConn) RemoteUDPAddr() *net.UDPAddr

+ func (uc *UDPConn) SetDeadline(t time.Time) error

+ func (uc *UDPConn) SetReadDeadline(t time.Time) error

+ func (uc *UDPConn) SetWriteDeadline(t time.Time) error

+ func (uc *UDPConn) Write(buf []byte) (n int, err error)

+ func (uc *UDPConn) WriteMsgTo(buf []byte, addr Addr) error

+ func (uc *UDPConn) WriteTo(p []byte, _ net.Addr) (n int, err error)

+ type UDPListener struct

+ func NewUDPListener(laddr *net.UDPAddr) (*UDPListener, error)

+ func NewUDPListenerConn(conn *net.UDPConn) (*UDPListener, error)

+ func (ul *UDPListener) Accept() (net.Conn, error)

+ func (ul *UDPListener) Addr() net.Addr

+ func (ul *UDPListener) Close() error

+ func (ul *UDPListener) DeleteConn(addrport netip.AddrPort)

+ func (ul *UDPListener) NewConn(raddr *net.UDPAddr) *UDPConn

+ type UDPMsgConn struct

+ IsServer bool

+ func NewUDPMsgConn(laddr *net.UDPAddr, fullcone bool, isserver bool) (*UDPMsgConn, error)

+ func (u *UDPMsgConn) Close() error

+ func (u *UDPMsgConn) CloseConnWithRaddr(raddr Addr) error

+ func (u *UDPMsgConn) Fullcone() bool

+ func (u *UDPMsgConn) ReadMsgFrom() ([]byte, Addr, error)

+ func (u *UDPMsgConn) WriteMsgTo(bs []byte, raddr Addr) error

+ type UniTargetMsgConn struct

+ Target Addr

+ func (u UniTargetMsgConn) Close() error

+ func (u UniTargetMsgConn) CloseConnWithRaddr(raddr Addr) error

+ func (u UniTargetMsgConn) Fullcone() bool

+ func (u UniTargetMsgConn) ReadMsgFrom() ([]byte, Addr, error)

+ func (u UniTargetMsgConn) WriteMsgTo(bs []byte, _ Addr) error