controller

Documentation

Index

• func InitClusterRouter(config *Configuration) error
• func InitDefaultLogicalSwitch(config *Configuration) error
• func InitLoadBalancer(config *Configuration) error
• func InitNodeSwitch(config *Configuration) error
• type Configuration
  • func ParseFlags() (*Configuration, error)
• type Controller
  • func NewController(config *Configuration, informerFactory informers.SharedInformerFactory) *Controller
  • func (c *Controller) Run(stopCh <-chan struct{}) error

Functions

func InitClusterRouter

func InitClusterRouter(config *Configuration) error

func InitDefaultLogicalSwitch

func InitDefaultLogicalSwitch(config *Configuration) error

func InitLoadBalancer

func InitLoadBalancer(config *Configuration) error

func InitNodeSwitch

func InitNodeSwitch(config *Configuration) error

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
}

func ParseFlags

func ParseFlags() (*Configuration, error)

TODO: validate configuration

type Controller

type Controller struct {
	// contains filtered or unexported fields
}

func NewController

func NewController(
	config *Configuration,
	informerFactory informers.SharedInformerFactory) *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.