controller

Documentation

Index

• Constants
• Variables
• func InitClientGoMetrics()
• func InitWorkQueueMetrics()
• func NewSlrInfo(slr *kubeovnv1.SwitchLBRule) *slrInfo
• func PodNameToEipName(name, namespace string) string
• type Configuration
  • func ParseFlags() (*Configuration, error)
• type Controller
  • func NewController(config *Configuration) *Controller
  • func (c *Controller) CheckGatewayReady()
  • func (c *Controller) CheckNodePortGroup()
  • func (c *Controller) GenVpcLoadBalancer(vpcKey string) *VpcLoadBalancer
  • func (c *Controller) GetEip(eipName string) (*kubeovnv1.IptablesEIP, error)
  • func (c *Controller) GetGwBySubnet(name string) (string, string, error)
  • func (c *Controller) GetOvnEip(eipName string) (*kubeovnv1.OvnEip, error)
  • func (c *Controller) InitDefaultVpc() error
  • func (c *Controller) InitIPAM() error
  • func (c *Controller) InitOVN() error
  • func (c *Controller) RemoveOldChassisInSbDB(azName string) error
  • func (c *Controller) Run(ctx context.Context)
  • func (c *Controller) SynRouteToPolicy()
• type NamedPort
  • func NewNamedPort() *NamedPort
  • func (n *NamedPort) AddNamedPortByPod(pod *v1.Pod)
  • func (n *NamedPort) DeleteNamedPortByPod(pod *v1.Pod)
  • func (n *NamedPort) GetNamedPortByNs(namespace string) map[string]*util.NamedPortInfo
• type VpcLoadBalancer

Constants

const (
	INIT_ROUTE_TABLE = "init"
	POD_EIP_ADD      = "eip-add"
	POD_DNAT_ADD     = "dnat-add"
	ATTACHMENT_NAME  = "lb-svc-attachment"
	ATTACHMENT_NS    = "kube-system"
)

const (
	CorednsContainerName = "coredns"
	CorednsLabelKey      = "k8s-app"
	CorednsTemplateDep   = "coredns-template.yaml"
	InitRouteImage       = "kubeovn/vpc-nat-gateway:v1.11.10"
)

Variables

var (
	VpcNatCmVersion   = ""
	NAT_GW_CREATED_AT = ""
)

var (
	// external underlay vlan macvlan network attachment definition provider
	MACVLAN_NAD_PROVIDER = fmt.Sprintf("%s.%s", util.VpcExternalNet, ATTACHMENT_NS)
)

Functions

func InitClientGoMetrics

func InitClientGoMetrics()

func InitWorkQueueMetrics

func InitWorkQueueMetrics()

func NewSlrInfo

func NewSlrInfo(slr *kubeovnv1.SwitchLBRule) *slrInfo

func PodNameToEipName

func PodNameToEipName(name, namespace string) string

Types

type Configuration

type Configuration struct {
	BindAddress          string
	OvnNbAddr            string
	OvnSbAddr            string
	OvnTimeout           int
	CustCrdRetryMaxDelay int
	CustCrdRetryMinDelay int
	KubeConfigFile       string
	KubeRestConfig       *rest.Config

	KubeClient      kubernetes.Interface
	KubeOvnClient   clientset.Interface
	AttachNetClient attachnetclientset.Interface
	KubevirtClient  kubecli.KubevirtClient

	// with no timeout
	KubeFactoryClient    kubernetes.Interface
	KubeOvnFactoryClient clientset.Interface

	DefaultLogicalSwitch      string
	DefaultCIDR               string
	DefaultGateway            string
	DefaultExcludeIps         string
	DefaultGatewayCheck       bool
	DefaultLogicalGateway     bool
	DefaultU2OInterconnection bool

	ClusterRouter     string
	NodeSwitch        string
	NodeSwitchCIDR    string
	NodeSwitchGateway string

	ServiceClusterIPRange string

	ClusterTcpLoadBalancer         string
	ClusterUdpLoadBalancer         string
	ClusterSctpLoadBalancer        string
	ClusterTcpSessionLoadBalancer  string
	ClusterUdpSessionLoadBalancer  string
	ClusterSctpSessionLoadBalancer string

	PodName      string
	PodNamespace string
	PodNicType   string

	PodDefaultFipType string

	WorkerNum       int
	PprofPort       int
	EnablePprof     bool
	NodePgProbeTime int

	NetworkType             string
	DefaultProviderName     string
	DefaultHostInterface    string
	DefaultExchangeLinkName bool
	DefaultVlanName         string
	DefaultVlanID           int
	LsDnatModDlDst          bool

	EnableLb          bool
	EnableNP          bool
	EnableEipSnat     bool
	EnableExternalVpc bool
	EnableEcmp        bool
	EnableKeepVmIP    bool
	EnableLbSvc       bool
	EnableMetrics     bool

	ExternalGatewaySwitch   string
	ExternalGatewayConfigNS string
	ExternalGatewayNet      string
	ExternalGatewayVlanID   int

	GCInterval      int
	InspectInterval int
}

Configuration is the controller conf

func ParseFlags

func ParseFlags() (*Configuration, error)

ParseFlags parses cmd args then init kubeclient and conf TODO: validate configuration

type Controller

type Controller struct {
	UpdateSwitchLBRuleQueue workqueue.RateLimitingInterface
	// contains filtered or unexported fields
}

Controller is kube-ovn main controller that watch ns/pod/node/svc/ep and operate ovn

func NewController

func NewController(config *Configuration) *Controller

NewController returns a new ovn controller

func (*Controller) CheckGatewayReady

func (c *Controller) CheckGatewayReady()

func (*Controller) CheckNodePortGroup

func (c *Controller) CheckNodePortGroup()

func (*Controller) GenVpcLoadBalancer

func (c *Controller) GenVpcLoadBalancer(vpcKey string) *VpcLoadBalancer

func (*Controller) GetEip

func (c *Controller) GetEip(eipName string) (*kubeovnv1.IptablesEIP, error)

func (*Controller) GetGwBySubnet

func (c *Controller) GetGwBySubnet(name string) (string, string, error)

func (*Controller) GetOvnEip

func (c *Controller) GetOvnEip(eipName string) (*kubeovnv1.OvnEip, error)

func (*Controller) InitDefaultVpc

func (c *Controller) InitDefaultVpc() error

func (*Controller) InitIPAM

func (c *Controller) InitIPAM() error

func (*Controller) InitOVN

func (c *Controller) InitOVN() error

func (*Controller) RemoveOldChassisInSbDB

func (c *Controller) RemoveOldChassisInSbDB(azName string) error

func (*Controller) Run

func (c *Controller) Run(ctx context.Context)

Run will set up the event handlers for types we are interested in, as well as syncing informer caches and starting workers. It will block until stopCh is closed, at which point it will shutdown the workqueue and wait for workers to finish processing their current work items.

func (*Controller) SynRouteToPolicy

func (c *Controller) SynRouteToPolicy()

type NamedPort

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

func NewNamedPort

func NewNamedPort() *NamedPort

func (*NamedPort) AddNamedPortByPod

func (n *NamedPort) AddNamedPortByPod(pod *v1.Pod)

func (*NamedPort) DeleteNamedPortByPod

func (n *NamedPort) DeleteNamedPortByPod(pod *v1.Pod)

func (*NamedPort) GetNamedPortByNs

func (n *NamedPort) GetNamedPortByNs(namespace string) map[string]*util.NamedPortInfo

type VpcLoadBalancer

type VpcLoadBalancer struct {
	TcpLoadBalancer      string
	TcpSessLoadBalancer  string
	UdpLoadBalancer      string
	UdpSessLoadBalancer  string
	SctpLoadBalancer     string
	SctpSessLoadBalancer string
}