proxy

Documentation

Index

• func NewDualStackProxier(hostname string, k8sClient clientset.Interface, ...) (*metaProxierWrapper, error)
• func NewProxier(hostname string, k8sClient clientset.Interface, ...) (*proxier, error)
• type EndpointSliceCache
  • func NewEndpointSliceCache(hostname string, isIPv6Mode bool) *EndpointSliceCache
• type Proxier

Functions

func NewDualStackProxier

func NewDualStackProxier(
	hostname string,
	k8sClient clientset.Interface,
	informerFactory informers.SharedInformerFactory,
	ofClient openflow.Client,
	routeClient route.Interface,
	nodePortAddressesIPv4 []net.IP,
	nodePortAddressesIPv6 []net.IP,
	proxyAllEnabled bool,
	skipServices []string,
	proxyLoadBalancerIPs bool,
	v4groupCounter types.GroupCounter,
	v6groupCounter types.GroupCounter,
	nestedServiceSupport bool) (*metaProxierWrapper, error)

func NewProxier

func NewProxier(
	hostname string,
	k8sClient clientset.Interface,
	informerFactory informers.SharedInformerFactory,
	ofClient openflow.Client,
	isIPv6 bool,
	routeClient route.Interface,
	nodePortAddresses []net.IP,
	proxyAllEnabled bool,
	skipServices []string,
	proxyLoadBalancerIPs bool,
	groupCounter types.GroupCounter,
	supportNestedService bool) (*proxier, error)

Types

type EndpointSliceCache

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

EndpointSliceCache is used as a cache of EndpointSlice information.

func NewEndpointSliceCache

func NewEndpointSliceCache(hostname string, isIPv6Mode bool) *EndpointSliceCache

NewEndpointSliceCache initializes an EndpointSliceCache.

type Proxier

type Proxier interface {
	// GetProxyProvider returns the real proxy Provider.
	GetProxyProvider() k8sproxy.Provider
	// GetServiceFlowKeys returns the keys (match strings) of the cached OVS
	// flows and the OVS group IDs for a Service. False is returned if the
	// Service is not found.
	GetServiceFlowKeys(serviceName, namespace string) ([]string, []binding.GroupIDType, bool)
	// GetServiceByIP returns the ServicePortName struct for the given serviceString(ClusterIP:Port/Proto).
	// False is returned if the serviceString is not found in serviceStringMap.
	GetServiceByIP(serviceStr string) (k8sproxy.ServicePortName, bool)
}

Proxier wraps proxy.Provider and adds extra methods. It is introduced for extending the proxy.Provider implementations with extra methods, without modifying the proxy.Provider interface.