proxy

Documentation

Index

• func NewDualStackProxier(hostname string, informerFactory informers.SharedInformerFactory, ...) *metaProxierWrapper
• func NewProxier(hostname string, informerFactory informers.SharedInformerFactory, ...) *proxier
• type EndpointSliceCache
  • func NewEndpointSliceCache(hostname string, isIPv6Mode bool) *EndpointSliceCache
• type Proxier

Functions

func NewDualStackProxier

func NewDualStackProxier(
	hostname string, informerFactory informers.SharedInformerFactory, ofClient openflow.Client) *metaProxierWrapper

func NewProxier

func NewProxier(
	hostname string,
	informerFactory informers.SharedInformerFactory,
	ofClient openflow.Client,
	isIPv6 bool) *proxier

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.