netapi

package

Go to main page

Versions in this module

v0

v0.3.5

May 1, 2024

Changes in this version

+ func DialHappyEyeballs(ctx context.Context, addr Address) (net.Conn, error)

+ type Accepter interface

+ AcceptPacket func() (*Packet, error)

+ AcceptStream func() (*StreamMeta, error)

type Address

+ func ParseDomainPort(network statistic.Type, addr string, port Port) (ad Address)

+ func ParseIPAddrPort(net statistic.Type, ip net.IP, port int) Address

+ PreferIPv4 func(b bool)

+ type ChannelServer struct

+ func NewChannelServer() *ChannelServer

+ func (s *ChannelServer) AcceptPacket() (*Packet, error)

+ func (s *ChannelServer) AcceptStream() (*StreamMeta, error)

+ func (s *ChannelServer) Close() error

+ func (s *ChannelServer) Context() context.Context

+ func (s *ChannelServer) SendPacket(packet *Packet) error

+ func (s *ChannelServer) SendStream(stream *StreamMeta) error

+ type DNSServer interface

+ Do func(context.Context, *pool.Bytes, func([]byte) error) error

+ HandleTCP func(context.Context, net.Conn) error

+ HandleUDP func(context.Context, net.PacketConn) error

type DomainAddr

+ func (d DomainAddr) PreferIPv4(b bool)

+ type IPAddr struct

+ func (d *IPAddr) AddrPort(context.Context) Result[netip.AddrPort]

+ func (d *IPAddr) Hostname() string

+ func (d *IPAddr) IP(context.Context) (net.IP, error)

+ func (d *IPAddr) IPs(context.Context) ([]net.IP, error)

+ func (d *IPAddr) IsFqdn() bool

+ func (d *IPAddr) OverrideHostname(s string) Address

+ func (d *IPAddr) OverridePort(p Port) Address

+ func (d *IPAddr) Port() Port

+ func (d *IPAddr) String() string

+ func (d *IPAddr) TCPAddr(context.Context) Result[*net.TCPAddr]

+ func (d *IPAddr) Type() Type

+ func (d *IPAddr) UDPAddr(context.Context) Result[*net.UDPAddr]

+ func (d IPAddr) Network() string

+ func (d IPAddr) NetworkType() statistic.Type

+ func (d IPAddr) PreferIPv4(b bool)

+ func (d IPAddr) PreferIPv6(b bool)

+ func (d IPAddr) Resolver() Resolver

+ func (d IPAddr) SetResolver(resolver Resolver)

+ func (d IPAddr) SetSrc(src AddressSrc)

type IPAddrPort

+ func (d IPAddrPort) PreferIPv4(b bool)

+ type ListenerPatch struct

+ func PatchStream(lis net.Listener, inbound Listener) *ListenerPatch

+ func (w *ListenerPatch) Close() error

+ func (w *ListenerPatch) Stream(ctx context.Context) (net.Listener, error)

type LookupIPOption

+ A bool

+ AAAA bool

+ type ProcessDumper interface

+ ProcessName func(network string, src, dst Address) (string, error)

type Resolver

+ var InternetResolver Resolver = NewSystemResolver("8.8.8.8:53", "1.1.1.1:53", "223.5.5.5:53", "114.114.114.114:53")

v0.3.4

Mar 11, 2024

Changes in this version

+ var EmptyStore = &emptyStore

type Address

+ IPs func(context.Context) ([]net.IP, error)

+ IsFqdn func() bool

+ SetResolver func(_ Resolver)

+ SetSrc func(AddressSrc)

+ type AddressSrc int32

+ const AddressSrcDNS

+ const AddressSrcEmpty

+ type ChannelProtocolServer struct

+ func NewChannelProtocolServer() *ChannelProtocolServer

+ func (s *ChannelProtocolServer) AcceptPacket() (*Packet, error)

+ func (s *ChannelProtocolServer) AcceptStream() (*StreamMeta, error)

+ func (s *ChannelProtocolServer) Close() error

+ func (s *ChannelProtocolServer) Context() context.Context

+ func (s *ChannelProtocolServer) NewPacket(packet *Packet) bool

+ func (s *ChannelProtocolServer) NewStream(stream *StreamMeta) bool

type DomainAddr

+ func (d *DomainAddr) IPs(ctx context.Context) ([]net.IP, error)

+ func (d *DomainAddr) IsFqdn() bool

+ func (d DomainAddr) SetResolver(resolver Resolver)

+ func (d DomainAddr) SetSrc(src AddressSrc)

type IPAddrPort

+ func (d *IPAddrPort) IPs(context.Context) ([]net.IP, error)

+ func (d *IPAddrPort) IsFqdn() bool

+ func (d IPAddrPort) SetResolver(resolver Resolver)

+ func (d IPAddrPort) SetSrc(src AddressSrc)

+ type LookupIPOption struct

+ OnlyAAAA bool

+ type Result struct

+ Err error

+ V T

+ func NewErrResult[T any](err error) Result[T]

+ func NewResult[T any](v T) Result[T]

+ type SystemResolver struct

+ DisableIPv6 bool

+ func NewSystemResolver(ipv6 bool) *SystemResolver

+ func (d *SystemResolver) Close() error

+ func (d *SystemResolver) LookupIP(ctx context.Context, domain string, opts ...func(*LookupIPOption)) ([]net.IP, error)

+ func (d *SystemResolver) Raw(context.Context, dnsmessage.Question) (dnsmessage.Message, error)

type Type

+ const FQDN

v0.3.3

Jan 27, 2024

Changes in this version

+ func MergeBufioReaderConn(c net.Conn, r *bufio.Reader) (net.Conn, error)

type Address

+ func ReadFrom(pc net.PacketConn) (*pool.Bytes, Address, error)

+ type DNSErrCode struct

+ func NewDNSErrCode(code dnsmessage.RCode) *DNSErrCode

+ func (d *DNSErrCode) As(err any) bool

+ func (d *DNSErrCode) Code() dnsmessage.RCode

+ func (d DNSErrCode) Error() string

+ type DropResolver struct

+ func (e DropResolver) Close() error

+ func (e DropResolver) LookupIP(_ context.Context, domain string) ([]net.IP, error)

+ func (e DropResolver) Raw(_ context.Context, req dnsmessage.Question) (dnsmessage.Message, error)

+ type EmptyPacketListener struct

+ func (EmptyPacketListener) Packet(context.Context) (net.PacketConn, error)

+ func (e *EmptyPacketListener) Stream(ctx context.Context) (net.Listener, error)

+ type Listener interface

+ Packet func(context.Context) (net.PacketConn, error)

+ Stream func(context.Context) (net.Listener, error)

+ func NewEmptyPacketListener(lis net.Listener) Listener

+ type ProtocolServer interface

+ AcceptPacket func() (*Packet, error)

+ AcceptStream func() (*StreamMeta, error)

+ type Reader struct

+ func NewReader(r io.Reader) *Reader

+ func (r *Reader) ReadByte() (byte, error)

+ func (r *Reader) ReadBytes(n int) ([]byte, error)

+ type WrapListener struct

+ func ListenWrap(lis net.Listener, inbound Listener) *WrapListener

+ func (w *WrapListener) Close() error

+ func (w *WrapListener) Stream(ctx context.Context) (net.Listener, error)

+ type WriteBack func(b []byte, addr net.Addr) (int, error)

+ type Writer struct

+ func NewWriter(w io.Writer) *Writer

+ func (w *Writer) WriteByte(b byte) error

+ func (w *Writer) WriteString(b string) (int, error)

v0.3.2

Dec 21, 2023

Changes in this version

+ var ErrBlocked = errors.New("BLOCK")

+ func GetDefault[T any](ctx context.Context, k any, Default T) T

+ func Get[T any](ctx context.Context, k any) (t T, _ bool)

+ func NewBlockError(network statistic.Type, hostname string) error

+ func NewMultipleReaderConn(c net.Conn, r io.Reader) *multipleReaderConn

+ func NewPrefixBytesConn(c net.Conn, prefix ...[]byte) net.Conn

+ func NewStore(ctx context.Context) context.Context

+ func PaseNetwork(s string) statistic.Type

+ type Address interface

+ AddrPort func(context.Context) (netip.AddrPort, error)

+ Hostname func() string

+ IP func(context.Context) (net.IP, error)

+ NetworkType func() statistic.Type

+ OverrideHostname func(string) Address

+ OverridePort func(Port) Address

+ Port func() Port

+ PreferIPv6 func(b bool)

+ TCPAddr func(context.Context) (*net.TCPAddr, error)

+ Type func() Type

+ UDPAddr func(context.Context) (*net.UDPAddr, error)

+ WithResolver func(_ Resolver, canCover bool) bool

+ var EmptyAddr Address = &emptyAddr{}

+ func ParseAddrPort(net statistic.Type, addrPort netip.AddrPort) Address

+ func ParseAddress(network statistic.Type, addr string) (ad Address, _ error)

+ func ParseAddressPort(network statistic.Type, addr string, port Port) (ad Address)

+ func ParseIPAddr(ad *net.IPAddr) Address

+ func ParseSysAddr(ad net.Addr) (Address, error)

+ func ParseTCPAddress(ad *net.TCPAddr) Address

+ func ParseUDPAddr(ad *net.UDPAddr) Address

+ func ParseUnixAddr(ad *net.UnixAddr) Address

+ type ChannelListener struct

+ func NewChannelListener(addr net.Addr) *ChannelListener

+ func (c *ChannelListener) Accept() (net.Conn, error)

+ func (c *ChannelListener) Addr() net.Addr

+ func (c *ChannelListener) Close() error

+ func (c *ChannelListener) NewConn(conn net.Conn)

+ type CurrentKey struct

+ type DNSHandler interface

+ Do func(context.Context, *pool.Bytes, func([]byte) error) error

+ HandleTCP func(context.Context, net.Conn) error

+ HandleUDP func(context.Context, net.PacketConn) error

+ var EmptyDNSServer DNSHandler = &emptyHandler{}

+ type DestinationKey struct

+ func (DestinationKey) String() string

+ type DomainAddr struct

+ func (d *DomainAddr) AddrPort(ctx context.Context) (netip.AddrPort, error)

+ func (d *DomainAddr) Hostname() string

+ func (d *DomainAddr) IP(ctx context.Context) (net.IP, error)

+ func (d *DomainAddr) OverrideHostname(s string) Address

+ func (d *DomainAddr) OverridePort(p Port) Address

+ func (d *DomainAddr) Port() Port

+ func (d *DomainAddr) String() string

+ func (d *DomainAddr) TCPAddr(ctx context.Context) (*net.TCPAddr, error)

+ func (d *DomainAddr) Type() Type

+ func (d *DomainAddr) UDPAddr(ctx context.Context) (*net.UDPAddr, error)

+ func (d DomainAddr) Network() string

+ func (d DomainAddr) NetworkType() statistic.Type

+ func (d DomainAddr) PreferIPv6(b bool)

+ func (d DomainAddr) Resolver() Resolver

+ func (d DomainAddr) WithResolver(resolver Resolver, canCover bool) bool

+ type DynamicProxy struct

+ func NewDynamicProxy(p Proxy) *DynamicProxy

+ func (d *DynamicProxy) Conn(ctx context.Context, a Address) (net.Conn, error)

+ func (d *DynamicProxy) Dispatch(ctx context.Context, a Address) (Address, error)

+ func (d *DynamicProxy) PacketConn(ctx context.Context, a Address) (net.PacketConn, error)

+ func (d *DynamicProxy) Set(p Proxy)

+ type EmptyDispatch struct

+ func (EmptyDispatch) Dispatch(_ context.Context, a Address) (Address, error)

+ type ErrorResolver func(domain string) error

+ func (e ErrorResolver) Close() error

+ func (e ErrorResolver) LookupIP(_ context.Context, domain string) ([]net.IP, error)

+ func (e ErrorResolver) Raw(_ context.Context, req dnsmessage.Question) (dnsmessage.Message, error)

+ type FakeIPKey struct

+ func (FakeIPKey) String() string

+ type ForceFakeIP struct

+ type Handler interface

+ type IPAddrPort struct

+ func (d *IPAddrPort) AddrPort(context.Context) (netip.AddrPort, error)

+ func (d *IPAddrPort) Hostname() string

+ func (d *IPAddrPort) IP(context.Context) (net.IP, error)

+ func (d *IPAddrPort) OverrideHostname(s string) Address

+ func (d *IPAddrPort) OverridePort(p Port) Address

+ func (d *IPAddrPort) Port() Port

+ func (d *IPAddrPort) String() string

+ func (d *IPAddrPort) TCPAddr(context.Context) (*net.TCPAddr, error)

+ func (d *IPAddrPort) Type() Type

+ func (d *IPAddrPort) UDPAddr(context.Context) (*net.UDPAddr, error)

+ func (d IPAddrPort) Network() string

+ func (d IPAddrPort) NetworkType() statistic.Type

+ func (d IPAddrPort) PreferIPv6(b bool)

+ func (d IPAddrPort) Resolver() Resolver

+ func (d IPAddrPort) WithResolver(resolver Resolver, canCover bool) bool

+ type InboundKey struct

+ func (InboundKey) String() string

+ type LogConn struct

+ func (l *LogConn) Read(b []byte) (int, error)

+ func (l *LogConn) SetDeadline(t time.Time) error

+ func (l *LogConn) SetReadDeadline(t time.Time) error

+ func (l *LogConn) SetWriteDeadline(t time.Time) error

+ func (l *LogConn) Write(b []byte) (int, error)

+ type Packet struct

+ Dst Address

+ Payload *pool.Bytes

+ Src net.Addr

+ WriteBack func(b []byte, addr net.Addr) (int, error)

+ type PacketHandler interface

+ Packet func(ctx context.Context, pack *Packet)

+ type PacketProxy interface

+ PacketConn func(context.Context, Address) (net.PacketConn, error)

+ type Port interface

+ Port func() uint16

+ String func() string

+ var EmptyPort Port = PortUint16(0)

+ func ParsePortStr(p string) (Port, error)

+ func ParsePort[T constraints.Integer](p T) Port

+ type PortUint16 uint16

+ func (p PortUint16) Port() uint16

+ func (p PortUint16) String() string

+ type PreferIPv6 struct

+ type Proxy interface

+ Dispatch func(context.Context, Address) (Address, error)

+ func NewErrProxy(err error) Proxy

+ func NewWrapStoreProxy(p Proxy) Proxy

+ type Resolver interface

+ LookupIP func(ctx context.Context, domain string) ([]net.IP, error)

+ Raw func(ctx context.Context, req dnsmessage.Question) (dnsmessage.Message, error)

+ var Bootstrap Resolver = &System{}

+ type Server interface

+ type SourceKey struct

+ func (SourceKey) String() string

+ type Store interface

+ Add func(k, v any) Store

+ Get func(k any) (any, bool)

+ Map func() map[any]any

+ Range func(func(k, v any) bool)

+ func StoreFromContext(ctx context.Context) Store

+ type StreamHandler interface

+ Stream func(ctx context.Context, _ *StreamMeta)

+ type StreamMeta struct

+ Address Address

+ Destination net.Addr

+ Inbound net.Addr

+ Source net.Addr

+ Src net.Conn

+ type StreamProxy interface

+ Conn func(context.Context, Address) (net.Conn, error)

+ type System struct

+ DisableIPv6 bool

+ func (d *System) Close() error

+ func (d *System) LookupIP(ctx context.Context, domain string) ([]net.IP, error)

+ func (d *System) Raw(context.Context, dnsmessage.Question) (dnsmessage.Message, error)

+ type Type uint8

+ const DOMAIN

+ const EMPTY

+ const IP

+ const UNIX

+ func (t Type) String() string

v0.3.1-rc.12

Nov 9, 2023

v0.3.1-rc.11

Sep 9, 2023

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