controller

Documentation

Index

• Constants
• 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) GenVpcLoadBalancer(vpcKey string) *VpcLoadBalancer
  • func (c *Controller) InitDefaultVpc() error
  • func (c *Controller) InitIPAM() error
  • func (c *Controller) InitOVN() error
  • func (c *Controller) RemoveRedundantChassis(node *v1.Node) error
  • func (c *Controller) Run(stopCh <-chan struct{})
• type VpcLoadBalancer

Constants

const (
	NAT_GW_INIT             = "init"
	NAT_GW_FLOATING_IP_SYNC = "floating-ip-sync"
	NAT_GW_EIP_ADD          = "eip-add"
	NAT_GW_EIP_DEL          = "eip-del"
	NAT_GW_SNAT_SYNC        = "snat-sync"
	NAT_GW_DNAT_SYNC        = "dnat-sync"
	NAT_GW_SUBNET_ROUTE_ADD = "subnet-route-add"
	NAT_GW_SUBNET_ROUTE_DEL = "subnet-route-del"
)

Functions

func InitClientGoMetrics

func InitClientGoMetrics()

func InitWorkQueueMetrics

func InitWorkQueueMetrics()

Types

type Configuration

type Configuration struct {
	BindAddress     string
	OvnNbAddr       string
	OvnSbAddr       string
	OvnTimeout      int
	KubeConfigFile  string
	KubeRestConfig  *rest.Config
	KubeClient      kubernetes.Interface
	KubeOvnClient   clientset.Interface
	AttachNetClient attacnetclientset.Interface
	KubevirtClient  kubecli.KubevirtClient

	DefaultLogicalSwitch string
	DefaultCIDR          string
	DefaultGateway       string
	DefaultExcludeIps    string

	ClusterRouter     string
	NodeSwitch        string
	NodeSwitchCIDR    string
	NodeSwitchGateway string

	ClusterTcpLoadBalancer        string
	ClusterUdpLoadBalancer        string
	ClusterTcpSessionLoadBalancer string
	ClusterUdpSessionLoadBalancer string

	PodName      string
	PodNamespace string
	PodNicType   string

	WorkerNum   int
	PprofPort   int
	EnablePprof bool

	NetworkType          string
	DefaultProviderName  string
	DefaultHostInterface string
	DefaultVlanName      string
	DefaultVlanID        int

	EnableLb          bool
	EnableNP          bool
	EnableEipSnat     bool
	EnableExternalVpc bool
	EnableEcmp        bool
	EnableKeepVmIP    bool
}

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) GenVpcLoadBalancer

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

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) RemoveRedundantChassis

func (c *Controller) RemoveRedundantChassis(node *v1.Node) 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.

type VpcLoadBalancer

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