egress

Documentation

Index

• func NewEgressIPScheduler(cluster memberlist.Interface, egressInformer crdinformers.EgressInformer, ...) *egressIPScheduler
• type EgressController
  • func NewEgressController(ofClient openflow.Client, k8sClient kubernetes.Interface, ...) (*EgressController, error)
  • func (c *EgressController) GetEgress(ns, podName string) (string, string, error)
  • func (c *EgressController) GetEgressIPByMark(mark uint32) (string, error)
  • func (c *EgressController) Run(stopCh <-chan struct{})
• type EgressesByCreationTimestamp
  • func (o EgressesByCreationTimestamp) Len() int
  • func (o EgressesByCreationTimestamp) Less(i, j int) bool
  • func (o EgressesByCreationTimestamp) Swap(i, j int)

Functions

func NewEgressIPScheduler

func NewEgressIPScheduler(cluster memberlist.Interface, egressInformer crdinformers.EgressInformer, nodeInformer corev1informers.NodeInformer, maxEgressIPsPerNode int) *egressIPScheduler

Types

type EgressController

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

func NewEgressController

func NewEgressController(
	ofClient openflow.Client,
	k8sClient kubernetes.Interface,
	antreaClientGetter agent.AntreaClientProvider,
	crdClient clientsetversioned.Interface,
	ifaceStore interfacestore.InterfaceStore,
	routeClient route.Interface,
	nodeName string,
	nodeTransportInterface string,
	cluster memberlist.Interface,
	egressInformer crdinformers.EgressInformer,
	externalIPPoolInformer crdinformers.ExternalIPPoolInformer,
	nodeInformers coreinformers.NodeInformer,
	podUpdateSubscriber channel.Subscriber,
	serviceCIDRInterface servicecidr.Interface,
	maxEgressIPsPerNode int,
	trafficShapingEnabled bool,
	supportSeparateSubnet bool,
) (*EgressController, error)

func (*EgressController) GetEgress

func (c *EgressController) GetEgress(ns, podName string) (string, string, error)

GetEgress returns effective Egress and Egress IP applied on a Pod.

func (*EgressController) GetEgressIPByMark

func (c *EgressController) GetEgressIPByMark(mark uint32) (string, error)

GetEgressIPByMark returns the Egress IP associated with the snatMark.

func (*EgressController) Run

func (c *EgressController) Run(stopCh <-chan struct{})

Run will create defaultWorkers workers (go routines) which will process the Egress events from the workqueue.

type EgressesByCreationTimestamp

type EgressesByCreationTimestamp []*crdv1b1.Egress

EgressesByCreationTimestamp sorts a list of Egresses by creation timestamp.

func (EgressesByCreationTimestamp) Len

func (o EgressesByCreationTimestamp) Len() int

func (EgressesByCreationTimestamp) Less

func (o EgressesByCreationTimestamp) Less(i, j int) bool

func (EgressesByCreationTimestamp) Swap

func (o EgressesByCreationTimestamp) Swap(i, j int)