egressservice

Documentation

Index

• Constants
• func GetEgressServiceAddrSetDbIDs(controller string) *libovsdbops.DbObjectIDs
• type Controller
  • func NewController(netInfo util.NetInfo, controllerName string, client kubernetes.Interface, ...) (*Controller, error)
  • func (c *Controller) Run(wg *sync.WaitGroup, threadiness int) error
• type CreateDefaultRouteToExternalFunc
• type DeleteLegacyDefaultNoRerouteNodePoliciesFunc
• type EnsureNoRerouteNodePoliciesFunc
• type InitClusterEgressPoliciesFunc

Constants

const EgressServiceServedPodsAddrSetName = "egresssvc-served-pods"

Functions

func GetEgressServiceAddrSetDbIDs

func GetEgressServiceAddrSetDbIDs(controller string) *libovsdbops.DbObjectIDs

Types

type Controller

type Controller struct {
	// network information
	util.NetInfo

	sync.Mutex
	// contains filtered or unexported fields
}

func NewController

func NewController(
	netInfo util.NetInfo,
	controllerName string,
	client kubernetes.Interface,
	nbClient libovsdbclient.Client,
	addressSetFactory addressset.AddressSetFactory,
	initClusterEgressPolicies InitClusterEgressPoliciesFunc,
	ensureNoRerouteNodePolicies EnsureNoRerouteNodePoliciesFunc,
	deleteLegacyDefaultNoRerouteNodePolicies DeleteLegacyDefaultNoRerouteNodePoliciesFunc,
	createDefaultRouteToExternalForIC CreateDefaultRouteToExternalFunc,
	stopCh <-chan struct{},
	esInformer egressserviceinformer.EgressServiceInformer,
	serviceInformer coreinformers.ServiceInformer,
	endpointSliceInformer discoveryinformers.EndpointSliceInformer,
	nodeInformer coreinformers.NodeInformer,
	zone string) (*Controller, error)

func (*Controller) Run

func (c *Controller) Run(wg *sync.WaitGroup, threadiness int) error

type CreateDefaultRouteToExternalFunc

type CreateDefaultRouteToExternalFunc func(nbClient libovsdbclient.Client, clusterRouter, gwRouterName string, clusterSubnets []config.CIDRNetworkEntry) error

type DeleteLegacyDefaultNoRerouteNodePoliciesFunc

type DeleteLegacyDefaultNoRerouteNodePoliciesFunc func(nbClient libovsdbclient.Client, clusterRouter, nodeName string) error

type EnsureNoRerouteNodePoliciesFunc

type EnsureNoRerouteNodePoliciesFunc func(client libovsdbclient.Client, addressSetFactory addressset.AddressSetFactory,
	networkName, controllerName, clusterRouter string, nodeLister corelisters.NodeLister, v4, v6 bool) error

type InitClusterEgressPoliciesFunc

type InitClusterEgressPoliciesFunc func(client libovsdbclient.Client, addressSetFactory addressset.AddressSetFactory,
	ni util.NetInfo, clusterSubnets []*net.IPNet, controllerName string) error