daemon

Documentation

Index

• Constants
• func InitMetrics()
• func InitMirror(config *Configuration) error
• func InitNodeGateway(config *Configuration) error
• func InitVlan(config *Configuration) error
• func RunServer(config *Configuration, controller *Controller)
• type Configuration
  • func ParseFlags() (*Configuration, error)
• type Controller
  • func NewController(config *Configuration, podInformerFactory informers.SharedInformerFactory, ...) (*Controller, error)
  • func (c *Controller) Run(stopCh <-chan struct{})

Constants

const (
	SubnetSet    = "subnets"
	SubnetNatSet = "subnets-nat"
	LocalPodSet  = "local-pod-ip-nat"
	OtherNodeSet = "other-node"
	IPSetPrefix  = "ovn"
)

Functions

func InitMetrics

func InitMetrics()

func InitMirror

func InitMirror(config *Configuration) error

func InitNodeGateway

func InitNodeGateway(config *Configuration) error

InitNodeGateway init ovn0

func InitVlan

func InitVlan(config *Configuration) error

func RunServer

func RunServer(config *Configuration, controller *Controller)

RunServer runs the cniserver

Types

type Configuration

type Configuration struct {
	Iface                 string
	MTU                   int
	MSS                   int
	EnableMirror          bool
	MirrorNic             string
	BindSocket            string
	OvsSocket             string
	KubeConfigFile        string
	KubeClient            kubernetes.Interface
	KubeOvnClient         clientset.Interface
	NodeName              string
	ServiceClusterIPRange string
	NodeLocalDNSIP        string
	EncapChecksum         bool
	PprofPort             int
	NetworkType           string
	DefaultProviderName   string
	DefaultInterfaceName  string
}

Configuration is the daemon conf

func ParseFlags

func ParseFlags() (*Configuration, error)

ParseFlags will parse cmd args then init kubeClient and configuration TODO: validate configuration

type Controller

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

Controller watch pod and namespace changes to update iptables, ipset and ovs qos

func NewController

func NewController(config *Configuration, podInformerFactory informers.SharedInformerFactory, nodeInformerFactory informers.SharedInformerFactory, kubeovnInformerFactory kubeovninformer.SharedInformerFactory) (*Controller, error)

NewController init a daemon controller

func (*Controller) Run

func (c *Controller) Run(stopCh <-chan struct{})

Run starts controller