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(nicBridgeMappings map[string]string) (*Configuration, error)
• type Controller
  • func NewController(config *Configuration, podInformerFactory informers.SharedInformerFactory, ...) (*Controller, error)
  • func (c *Controller) Run(stopCh <-chan struct{})

Constants

const (
	ServiceSet   = "services"
	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 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
	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
	DefaultProviderName     string
	DefaultInterfaceName    string
	ExternalGatewayConfigNS string
	// contains filtered or unexported fields
}

Configuration is the daemon conf

func ParseFlags

func ParseFlags(nicBridgeMappings map[string]string) (*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