Versions in this module Expand all Collapse all v1 v1.11.0 Apr 19, 2022 v1.10.0 Mar 8, 2022 Changes in this version + const ATYPDomain + const ATYPIPv4 + const ATYPIPv6 + const AgentPodName + const CmdConnect + const DefaultMethod + const LabelKubeedge + const Success + const Version + var DefaultResponse = []byte + func NewDefaultKubeProxyConfiguration(bindAddress string) *proxyconfigapi.KubeProxyConfiguration type EdgeProxy + ProxyServer *ProxyServer + Socks5Proxy *Socks5Proxy + type ProxyServer struct + Client clientset.Interface + ConfigSyncPeriod time.Duration + IptInterface utiliptables.Interface + IstioClient istioclientset.Interface + Proxier proxy.Provider + ProxyMode string + UseEndpointSlices bool + func (s *ProxyServer) CleanupAndExit() error + func (s *ProxyServer) Run() error + type Request struct + AddressType byte + Command byte + DstAddr string + DstPort int32 + Rsv byte + Version byte + type Socks5Proxy struct + NodeName string + SocksHandle *SocksHandle + TCPProxy *protocol.TCPProxy + func NewSocks5Proxy(ip net.IP, port int, NodeName string, kubeClient kubernetes.Interface) (socks5Proxy *Socks5Proxy, err error) + func (s *Socks5Proxy) HandleSocksProxy(conn net.Conn) + func (s *Socks5Proxy) Start() + type SocksHandle struct + Request *Request + func (s *SocksHandle) NewRequest(conn net.Conn) (err error) + func (s *SocksHandle) ParsingConnect(conn net.Conn) (err error) v1.9.0 Dec 3, 2021 Changes in this version + const None v1.8.0 Aug 30, 2021 Changes in this version + const SoOriginalDst + func Register(c *config.EdgeProxyConfig, ifm *informers.Manager) error + type EdgeProxy struct + Config *config.EdgeProxyConfig + Proxier *Proxier + TCPProxy *protocol.TCPProxy + func (proxy *EdgeProxy) Enable() bool + func (proxy *EdgeProxy) Group() string + func (proxy *EdgeProxy) Name() string + func (proxy *EdgeProxy) Run() + func (proxy *EdgeProxy) Start() + type Proxier struct + func NewProxier(subnet string, protoProxies []protocol.ProtoProxy, ...) (proxier *Proxier, err error) + func (proxier *Proxier) CleanResidue() + func (proxier *Proxier) EnsureRules() + func (proxier *Proxier) FlushRules() + func (proxier *Proxier) InitRules() (err error) + func (proxier *Proxier) Start()
Go to main page