daemon

Documentation

Index

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

Constants

const (
	SubnetSet   = "subnets"
	LocalPodSet = "local-pod-ip-nat"
	IPSetPrefix = "ovn"
)

Functions

func InitMirror

func InitMirror(config *Configuration) error

func InitNodeGateway

func InitNodeGateway(config *Configuration) error

InitNodeGateway init ovn0

func RunServer

func RunServer(config *Configuration)

RunServer runs the cniserver

Types

type Configuration

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

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, informerFactory informers.SharedInformerFactory, kubeovnInformerFactory kubeovninformer.SharedInformerFactory) (*Controller, error)

NewController init a daemon controller

func (*Controller) Run

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

Run starts controller