Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitClusterRouter ¶
func InitClusterRouter(config *Configuration) error
InitClusterRouter init cluster router to connect different logical switches
func InitDefaultLogicalSwitch ¶
func InitDefaultLogicalSwitch(config *Configuration) error
InitDefaultLogicalSwitch int the default logical switch for ovn network
func InitLoadBalancer ¶
func InitLoadBalancer(config *Configuration) error
InitLoadBalancer init the default tcp and udp cluster loadbalancer
func InitNodeSwitch ¶
func InitNodeSwitch(config *Configuration) error
InitNodeSwitch init node switch to connect host and pod
Types ¶
type Configuration ¶
type Configuration struct { BindAddress string OvnNbSocket string OvnNbHost string OvnNbPort int KubeConfigFile string KubeClient kubernetes.Interface DefaultLogicalSwitch string DefaultCIDR string DefaultGateway string DefaultExcludeIps string ClusterRouter string NodeSwitch string NodeSwitchCIDR string NodeSwitchGateway string ClusterTcpLoadBalancer string ClusterUdpLoadBalancer string PodName string PodNamespace string WorkerNum 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) Run ¶
func (c *Controller) Run(stopCh <-chan struct{}) error
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.