controller

Documentation

Index

• func InitClientGoMetrics()
• func InitWorkQueueMetrics()
• type Configuration
  • func ParseFlags() (*Configuration, error)
• type Controller
  • func NewController(config *Configuration) *Controller
  • func (c *Controller) CheckGatewayReady()
  • func (c *Controller) CheckNodePortGroup()
  • func (c *Controller) EnsureChassisConsistency(node *v1.Node) error
  • func (c *Controller) EnsureChassisOnlyForClusterNodes(node *v1.Node) error
  • func (c *Controller) GenVpcLoadBalancer(vpcKey string) *VpcLoadBalancer
  • func (c *Controller) GetEip(eipName string) (*kubeovnv1.IptablesEIP, error)
  • func (c *Controller) GetGw() (string, error)
  • func (c *Controller) InitDefaultVpc() error
  • func (c *Controller) InitIPAM() error
  • func (c *Controller) InitOVN() error
  • func (c *Controller) Run(stopCh <-chan struct{})
  • func (c *Controller) SynRouteToPolicy()
• type VpcLoadBalancer

Functions

func InitClientGoMetrics

func InitClientGoMetrics()

func InitWorkQueueMetrics

func InitWorkQueueMetrics()

Types

type Configuration

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

	KubeClient      kubernetes.Interface
	KubeOvnClient   clientset.Interface
	AttachNetClient attacnetclientset.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

	ClusterRouter     string
	NodeSwitch        string
	NodeSwitchCIDR    string
	NodeSwitchGateway string

	ServiceClusterIPRange string

	ClusterTcpLoadBalancer        string
	ClusterUdpLoadBalancer        string
	ClusterTcpSessionLoadBalancer string
	ClusterUdpSessionLoadBalancer string

	PodName      string
	PodNamespace string
	PodNicType   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

	ExternalGatewayConfigNS string
	ExternalGatewayNet      string
	ExternalGatewayVlanID   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 {
	// 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) EnsureChassisConsistency

func (c *Controller) EnsureChassisConsistency(node *v1.Node) error

func (*Controller) EnsureChassisOnlyForClusterNodes

func (c *Controller) EnsureChassisOnlyForClusterNodes(node *v1.Node) error

func (*Controller) GenVpcLoadBalancer

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

func (*Controller) GetEip

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

func (*Controller) GetGw

func (c *Controller) GetGw() (string, 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) Run

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

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 VpcLoadBalancer

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