daemon

Documentation

Index

• Constants
• func InitMetrics()
• func InitMirror(config *Configuration) error
• func InitNodeGateway(config *Configuration) error
• func InitOVSBridges() (map[string]string, error)
• func RunServer(config *Configuration, controller *Controller)
• type Configuration
  • func ParseFlags() *Configuration
  • func (config *Configuration) Init(nicBridgeMappings map[string]string) error
• type Controller
  • func NewController(config *Configuration, podInformerFactory informers.SharedInformerFactory, ...) (*Controller, error)
  • func (c *Controller) Run(stopCh <-chan struct{})
• type ControllerRuntime

Constants

const (
	ServiceSet             = "services"
	SubnetSet              = "subnets"
	SubnetNatSet           = "subnets-nat"
	SubnetDistributedGwSet = "subnets-distributed-gw"
	LocalPodSet            = "local-pod-ip-nat"
	OtherNodeSet           = "other-node"
	IPSetPrefix            = "ovn"
)

const (
	NAT            = "nat"
	MANGLE         = "mangle"
	Prerouting     = "PREROUTING"
	Postrouting    = "POSTROUTING"
	OvnPrerouting  = "OVN-PREROUTING"
	OvnPostrouting = "OVN-POSTROUTING"
	OvnMasquerade  = "OVN-MASQUERADE"
)

Functions

func InitMetrics

func InitMetrics()

func InitMirror

func InitMirror(config *Configuration) error

func InitNodeGateway

func InitNodeGateway(config *Configuration) error

InitNodeGateway init ovn0

func InitOVSBridges

func InitOVSBridges() (map[string]string, error)

InitOVSBridges initializes OVS bridges

func RunServer

func RunServer(config *Configuration, controller *Controller)

RunServer runs the cniserver

Types

type Configuration

type Configuration struct {
	Iface                     string
	DPDKTunnelIface           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
	EnablePprof               bool
	MacLearningFallback       bool
	PprofPort                 int
	NetworkType               string
	CniConfDir                string
	CniConfFile               string
	CniConfName               string
	DefaultProviderName       string
	DefaultInterfaceName      string
	ExternalGatewayConfigNS   string
	ExternalGatewaySwitch     string // provider network underlay vlan subnet
	EnableMetrics             bool
	EnableArpDetectIPConflict bool
	EnableVerboseConnCheck    bool
	TCPConnCheckPort          int
	UDPConnCheckPort          int
	KubeletDir                string
	// contains filtered or unexported fields
}

Configuration is the daemon conf

func ParseFlags

func ParseFlags() *Configuration

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

func (*Configuration) Init

func (config *Configuration) Init(nicBridgeMappings map[string]string) error

type Controller

type Controller struct {
	ControllerRuntime
	// 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

type ControllerRuntime

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

ControllerRuntime represents runtime specific controller members