control

Dec 18, 2024

Changes in this version

+ type DnsForwarder interface

+ Close func() error

+ ForwardDNS func(ctx context.Context, data []byte) (*dnsmessage.Msg, error)

+ type DoH struct

+ func (d *DoH) Close() error

+ func (d *DoH) ForwardDNS(ctx context.Context, data []byte) (*dnsmessage.Msg, error)

+ type DoQ struct

+ func (d *DoQ) Close() error

+ func (d *DoQ) ForwardDNS(ctx context.Context, data []byte) (*dnsmessage.Msg, error)

+ type DoTCP struct

+ func (d *DoTCP) Close() error

+ func (d *DoTCP) ForwardDNS(ctx context.Context, data []byte) (*dnsmessage.Msg, error)

+ type DoTLS struct

+ func (d *DoTLS) Close() error

+ func (d *DoTLS) ForwardDNS(ctx context.Context, data []byte) (*dnsmessage.Msg, error)

+ type DoUDP struct

+ func (d *DoUDP) Close() error

+ func (d *DoUDP) ForwardDNS(ctx context.Context, data []byte) (*dnsmessage.Msg, error)

Oct 11, 2024

Changes in this version

+ func ParseGroupOverrideOption(group config.Group, global config.Global, log *logrus.Logger) (*dialer.GlobalOption, error)

Sep 27, 2024

Changes in this version

+ var ReemitWorkers *ants.Pool

Jun 16, 2024

Changes in this version

+ const UdpTaskQueueLength

+ var DefaultPacketSnifferSessionMgr = NewPacketSnifferPool()

+ var DefaultUdpTaskPool = NewUdpTaskPool()

type DialOption

+ SniffedDomain string

type DnsControllerOption

+ TimeoutExceedCallback func(dialArgument *dialArgument, err error)

type UdpEndpoint

+ DialTarget string

+ SniffedDomain string

type UdpEndpointPool

+ func (p *UdpEndpointPool) Get(lAddr netip.AddrPort) (udpEndpoint *UdpEndpoint, ok bool)

+ type UdpTask = func()

+ type UdpTaskPool struct

+ func NewUdpTaskPool() *UdpTaskPool

+ func (p *UdpTaskPool) EmitTask(key string, task UdpTask)

+ type UdpTaskQueue struct

+ func (q *UdpTaskQueue) Push(task UdpTask)

Jun 11, 2024

Changes in this version

type DaeNetns

+ func (ns *DaeNetns) Dae0() netlink.Link

+ func (ns *DaeNetns) Dae0Peer() netlink.Link

+ func (ns *DaeNetns) NetnsID() (int, error)

+ type SysctlKey string

+ func (k SysctlKey) Get() (value string, err error)

+ func (k SysctlKey) Set(value string, watch bool) (err error)

type SysctlManager

+ func (s *SysctlManager) Keyf(format string, a ...any) SysctlKey

Jan 23, 2024

Changes in this version

+ const HostVethName

+ const NsName

+ const NsVethName

+ const SysctlPrefixPath

+ func DeleteLink(name string) error

+ func DeleteNamedNetns(name string) error

+ func InitDaeNetns(log *logrus.Logger)

+ func InitSysctlManager(log *logrus.Logger) (err error)

type ControlPlane

+ func (c *ControlPlane) ActivateCheck()

+ type DaeNetns struct

+ func GetDaeNetns() *DaeNetns

+ func (ns *DaeNetns) Close() (err error)

+ func (ns *DaeNetns) Setup() (err error)

+ func (ns *DaeNetns) With(f func() error) (err error)

+ type SysctlManager struct

+ func NewSysctlManager(log *logrus.Logger) (*SysctlManager, error)

+ func (s *SysctlManager) Set(key string, value string, watch bool) (err error)

Jan 4, 2024

Changes in this version

+ func SetAcceptLocal(ifname, val string) error

Dec 26, 2023

Changes in this version

+ const AnyfromTimeout

+ const PacketSnifferTtl

+ var DefaultAnyfromPool = NewAnyfromPool()

+ var DefaultPacketSnifferPool = NewPacketSnifferPool()

+ var ErrUnsupportedQuestionType = fmt.Errorf("unsupported question type")

+ type Anyfrom struct

+ func (a *Anyfrom) ReadFrom(b []byte) (int, net.Addr, error)

+ func (a *Anyfrom) ReadFromUDP(b []byte) (n int, addr *net.UDPAddr, err error)

+ func (a *Anyfrom) ReadFromUDPAddrPort(b []byte) (n int, addr netip.AddrPort, err error)

+ func (a *Anyfrom) ReadMsgUDP(b []byte, oob []byte) (n int, oobn int, flags int, addr *net.UDPAddr, err error)

+ func (a *Anyfrom) ReadMsgUDPAddrPort(b []byte, oob []byte) (n int, oobn int, flags int, addr netip.AddrPort, err error)

+ func (a *Anyfrom) RefreshTtl()

+ func (a *Anyfrom) SupportGso(size int) bool

+ func (a *Anyfrom) SyscallConn() (syscall.RawConn, error)

+ func (a *Anyfrom) WriteMsgUDP(b []byte, oob []byte, addr *net.UDPAddr) (n int, oobn int, err error)

+ func (a *Anyfrom) WriteMsgUDPAddrPort(b []byte, oob []byte, addr netip.AddrPort) (n int, oobn int, err error)

+ func (a *Anyfrom) WriteTo(b []byte, addr net.Addr) (n int, err error)

+ func (a *Anyfrom) WriteToUDP(b []byte, addr *net.UDPAddr) (n int, err error)

+ func (a *Anyfrom) WriteToUDPAddrPort(b []byte, addr netip.AddrPort) (n int, err error)

+ type AnyfromPool struct

+ func NewAnyfromPool() *AnyfromPool

+ func (p *AnyfromPool) GetOrCreate(lAddr string, ttl time.Duration) (conn *Anyfrom, isNew bool, err error)

type ControlPlane

+ func (c *ControlPlane) AbortConnections() (err error)

+ type PacketSniffer struct

+ Mu sync.Mutex

+ type PacketSnifferKey struct

+ LAddr netip.AddrPort

+ RAddr netip.AddrPort

+ type PacketSnifferOptions struct

+ Ttl time.Duration

+ type PacketSnifferPool struct

+ func NewPacketSnifferPool() *PacketSnifferPool

+ func (p *PacketSnifferPool) Get(key PacketSnifferKey) *PacketSniffer

+ func (p *PacketSnifferPool) GetOrCreate(key PacketSnifferKey, createOption *PacketSnifferOptions) (qs *PacketSniffer, isNew bool)

+ func (p *PacketSnifferPool) Remove(key PacketSnifferKey, sniffer *PacketSniffer) (err error)

type RouteDialParam

+ Dscp uint8

type UdpEndpointPool

+ func (p *UdpEndpointPool) Exists(lAddr netip.AddrPort) (ok bool)

Jul 17, 2023

Changes in this version

+ type DialOption struct

+ Dialer *dialer.Dialer

+ Network string

+ Outbound *ob.DialerGroup

+ Target string

type DnsCache

+ OriginalDeadline time.Time

type DnsController

+ func (c *DnsController) NormalizeAndCacheDnsResp_(msg *dnsmessage.Msg) (err error)

type UdpEndpoint

+ Outbound *outbound.DialerGroup

type UdpEndpointOptions

+ GetDialOption func() (option *DialOption, err error)

Jul 9, 2023

Changes in this version

+ func QtypeToString(qtype uint16) string

type DnsCache

+ Answer []dnsmessage.RR

Jul 2, 2023

Changes in this version

+ func BpfMapBatchDelete(m *ebpf.Map, keys interface{}) (n int, err error)

+ func ParseFixedDomainTtl(ks []config.KeyableString) (map[string]int, error)

type ControlPlane

+ func (c *ControlPlane) RouteDialTcp(p *RouteDialParam) (conn netproxy.Conn, err error)

type DnsController

+ func (c *DnsController) UpdateDnsCacheDeadline(host string, dnsTyp string, answers []dnsmessage.Resource, deadline time.Time) (err error)

+ func (c *DnsController) UpdateDnsCacheTtl(host string, dnsTyp string, answers []dnsmessage.Resource, ttl int) (err error)

type DnsControllerOption

+ CacheRemoveCallback func(cache *DnsCache) (err error)

+ FixedDomainTtl map[string]int

+ type RouteDialParam struct

+ Dest netip.AddrPort

+ Domain string

+ Mac [6]uint8

+ Mark uint32

+ Outbound consts.OutboundIndex

+ ProcessName [16]uint8

+ Src netip.AddrPort

Apr 29, 2023

Changes in this version

+ var UnspecifiedAddressA = netip.MustParseAddr("0.0.0.0")

+ var UnspecifiedAddressAAAA = netip.MustParseAddr("::")

type DnsCache

+ func (c *DnsCache) IncludeAnyIp() bool

Apr 9, 2023

Changes in this version

type DnsController

+ func (c *DnsController) RemoveDnsRespCache(qname string, qtype dnsmessage.Type)

type DnsControllerOption

+ IpVersionPrefer int

+ type IpVersionPrefer int

+ const IpVersionPrefer_4

+ const IpVersionPrefer_6

+ const IpVersionPrefer_No

Mar 25, 2023

Changes in this version

+ const EthernetMtu

+ func SetForwarding(ifname string, val string)

+ func SetIpv4forward(val string) error

+ func SetSendRedirects(ifname string, val string)

Mar 22, 2023

Changes in this version

type ControlPlane

+ func (c *ControlPlane) CloneDnsCache() map[string]*DnsCache

Mar 14, 2023

Changes in this version

+ const DefaultNatTimeout

+ const DnsNatTimeout

+ const MaxDnsLookupDepth

+ const MaxRetry

+ const TcpSniffBufSize

+ var CheckBatchUpdateFeatureOnce sync.Once

+ var DefaultUdpEndpointPool = NewUdpEndpointPool()

+ var SimulateBatchUpdate bool

+ var SimulateBatchUpdateLpmTrie bool

+ var SuspectedRushAnswerError = fmt.Errorf("suspected DNS rush-answer")

+ var UnsupportedQuestionTypeError = fmt.Errorf("unsupported question type")

+ func BpfMapBatchUpdate(m *ebpf.Map, keys interface{}, values interface{}, opts *ebpf.BatchOptions) (n int, err error)

+ func CheckIpforward(ifname string) error

+ func CheckSendRedirects(ifname string) error

+ func ChooseNatTimeout(data []byte, sniffDns bool) (dmsg *dnsmessage.Message, timeout time.Duration)

+ func EnsureAdditionalOpt(dm *dnsmessage.Message, isReqAdd bool) (bool, error)

+ func FlipDnsQuestionCase(dm *dnsmessage.Message)

+ func FormatDnsRsc(ans []dnsmessage.Resource) string

+ func FormatL4Proto(l4proto uint8) string

+ func GenerateObjects(output string)

+ func Mac2String(mac []uint8) string

+ func MagicNetwork(network string, mark uint32) string

+ func ParseAddrHdr(data []byte) (hdr *bpfDstRoutingResult, dataOffset int, err error)

+ func ParsePortRange(b []byte) (portStart, portEnd uint16)

+ func ProcessName2String(pname []uint8) string

+ func RefineAddrPortToShow(addrPort netip.AddrPort) (srcToShow string)

+ func RefineSourceToShow(src netip.AddrPort, dst netip.Addr, lanWanFlag consts.LanWanFlag) (srcToShow string)

+ func RelayTCP(lConn, rConn netproxy.Conn) (err error)

+ func RetrieveOriginalDest(oob []byte) netip.AddrPort

+ type ControlPlane struct

+ func NewControlPlane(log *logrus.Logger, _bpf interface{}, tagToNodeList map[string][]string, ...) (*ControlPlane, error)

+ func (c *ControlPlane) ChooseDialTarget(outbound consts.OutboundIndex, dst netip.AddrPort, domain string) (dialTarget string, dialMode consts.DialMode)

+ func (c *ControlPlane) Close() (err error)

+ func (c *ControlPlane) EjectBpf() *bpfObjects

+ func (c *ControlPlane) InjectBpf(bpf *bpfObjects)

+ func (c *ControlPlane) ListenAndServe(readyChan chan<- bool, port uint16) (listener *Listener, err error)

+ func (c *ControlPlane) Route(src, dst netip.AddrPort, domain string, l4proto consts.L4ProtoType, ...) (outboundIndex consts.OutboundIndex, mark uint32, err error)

+ func (c *ControlPlane) Serve(readyChan chan<- bool, listener *Listener) (err error)

+ type DnsCache struct

+ Answers []dnsmessage.Resource

+ Deadline time.Time

+ DomainBitmap []uint32

+ func (c *DnsCache) FillInto(req *dnsmessage.Message)

+ func (c *DnsCache) IncludeIp(ip netip.Addr) bool

+ type DnsController struct

+ func NewDnsController(routing *dns.Dns, option *DnsControllerOption) (c *DnsController, err error)

+ func (c *DnsController) DnsRespHandler(data []byte, validateRushAns bool) (newMsg *dnsmessage.Message, err error)

+ func (c *DnsController) DnsRespHandlerFactory(validateRushAnsFunc func(from netip.AddrPort) bool) func(data []byte, from netip.AddrPort) (msg *dnsmessage.Message, err error)

+ func (c *DnsController) Handle_(dnsMessage *dnsmessage.Message, req *udpRequest) (err error)

+ func (c *DnsController) LookupDnsRespCache(domain string, t dnsmessage.Type) (cache *DnsCache)

+ func (c *DnsController) LookupDnsRespCache_(msg *dnsmessage.Message) (resp []byte)

+ func (c *DnsController) UpdateDnsCache(host string, typ dnsmessage.Type, answers []dnsmessage.Resource, ...) (err error)

+ type DnsControllerOption struct

+ BestDialerChooser func(req *udpRequest, upstream *dns.Upstream) (*dialArgument, error)

+ CacheAccessCallback func(cache *DnsCache) (err error)

+ Log *logrus.Logger

+ NewCache func(fqdn string, answers []dnsmessage.Resource, deadline time.Time) (cache *DnsCache, err error)

+ type Listener struct

+ func (l *Listener) Close() error

+ type ProgField struct

+ Ebpf string

+ Name string

+ type RoutingMatcher struct

+ func (m *RoutingMatcher) Match(sourceAddr []byte, destAddr []byte, sourcePort uint16, destPort uint16, ...) (outboundIndex consts.OutboundIndex, mark uint32, err error)

+ type RoutingMatcherBuilder struct

+ func NewRoutingMatcherBuilder(log *logrus.Logger, rules []*config_parser.RoutingRule, ...) (b *RoutingMatcherBuilder, err error)

+ func (b *RoutingMatcherBuilder) BuildKernspace(log *logrus.Logger) (err error)

+ func (b *RoutingMatcherBuilder) BuildUserspace(lpmArrayMap *ebpf.Map) (matcher *RoutingMatcher, err error)

+ type RscWrapper struct

+ Rsc dnsmessage.Resource

+ func (w RscWrapper) String() string

+ type UdpEndpoint struct

+ Dialer *dialer.Dialer

+ NatTimeout time.Duration

+ func (ue *UdpEndpoint) Close() error

+ func (ue *UdpEndpoint) WriteTo(b []byte, addr string) (int, error)

+ type UdpEndpointOptions struct

+ Dialer *dialer.Dialer

+ Handler UdpHandler

+ NatTimeout time.Duration

+ Network string

+ Target string

+ type UdpEndpointPool struct

+ func NewUdpEndpointPool() *UdpEndpointPool

+ func (p *UdpEndpointPool) GetOrCreate(lAddr netip.AddrPort, createOption *UdpEndpointOptions) (udpEndpoint *UdpEndpoint, isNew bool, err error)

+ func (p *UdpEndpointPool) Remove(lAddr netip.AddrPort, udpEndpoint *UdpEndpoint) (err error)

+ type UdpHandler func(data []byte, from netip.AddrPort) error

+ type WriteCloser interface

+ CloseWrite func() error