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) InitDefaultVpc() error
  • func (c *Controller) InitIPAM() error
  • func (c *Controller) InitOVN() error
  • func (c *Controller) Run(stopCh <-chan struct{})

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

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

	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

	NetworkType          string
	DefaultProviderName  string
	DefaultHostInterface string
	DefaultVlanName      string
	DefaultVlanID        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) 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.