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) EnsureChassisConsistency(node *v1.Node) error
  • func (c *Controller) EnsureChassisOnlyForClusterNodes(node *v1.Node) error
  • 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) Run(stopCh <-chan struct{})
  • func (c *Controller) SynRouteToPolicy()
• 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

	// 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

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