daemon

Documentation

Index

• Constants
• func DeleteNamedNs(name string) error
• func GetDefaultRouteDst(protocol string) net.IPNet
• 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, stopCh <-chan struct{}, ...) (*Controller, error)
  • func (c *Controller) Run(stopCh <-chan struct{})
  • func (c *Controller) StartTProxyForwarding()
  • func (c *Controller) StartTProxyTCPPortProbe()
• type ControllerRuntime
• type NsHandle
  • func ClosedNs() NsHandle
  • func GetNs() (NsHandle, error)
  • func GetNsFromName(name string) (NsHandle, error)
  • func GetNsFromPath(path string) (NsHandle, error)
  • func GetNsFromThread(pid, tid int) (NsHandle, error)

Constants

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

const (
	NAT                        = util.NAT
	MANGLE                     = util.Mangle
	Prerouting                 = util.Prerouting
	Postrouting                = util.Postrouting
	Output                     = util.Output
	OvnPrerouting              = util.OvnPrerouting
	OvnPostrouting             = util.OvnPostrouting
	OvnOutput                  = util.OvnOutput
	OvnMasquerade              = util.OvnMasquerade
	OvnNatOutGoingPolicy       = util.OvnNatOutGoingPolicy
	OvnNatOutGoingPolicySubnet = util.OvnNatOutGoingPolicySubnet
)

const (
	OnOutGoingNatMark     = "0x90001/0x90001"
	OnOutGoingForwardMark = "0x90002/0x90002"
	TProxyOutputMark      = util.TProxyOutputMark
	TProxyOutputMask      = util.TProxyOutputMask
	TProxyPreroutingMark  = util.TProxyPreroutingMark
	TProxyPreroutingMask  = util.TProxyPreroutingMask
)

Functions

func DeleteNamedNs

func DeleteNamedNs(name string) error

DeleteNamed deletes a named network namespace ip netns del

func GetDefaultRouteDst

func GetDefaultRouteDst(protocol string) net.IPNet

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
	ClusterRouter             string
	NodeSwitch                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
	KubeletDir                string
	EnableVerboseConnCheck    bool
	TCPConnCheckPort          int
	UDPConnCheckPort          int
	EnableTProxy              bool
	OVSVsctlConcurrency       int32
	// 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, stopCh <-chan struct{}, podInformerFactory, 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

func (*Controller) StartTProxyForwarding

func (c *Controller) StartTProxyForwarding()

func (*Controller) StartTProxyTCPPortProbe

func (c *Controller) StartTProxyTCPPortProbe()

type ControllerRuntime

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

ControllerRuntime represents runtime specific controller members

type NsHandle

type NsHandle int

NsHandle is a handle to a network namespace. It can be cast directly to an int and used as a file descriptor.

func ClosedNs

func ClosedNs() NsHandle

None gets an empty (closed) NsHandle.

func GetNs

func GetNs() (NsHandle, error)

Get gets a handle to the current threads network namespace.

func GetNsFromName

func GetNsFromName(name string) (NsHandle, error)

GetFromName gets a handle to a named network namespace such as one created by `ip netns add`.

func GetNsFromPath

func GetNsFromPath(path string) (NsHandle, error)

GetFromPath gets a handle to a network namespace identified by the path

func GetNsFromThread

func GetNsFromThread(pid, tid int) (NsHandle, error)

GetFromThread gets a handle to the network namespace of a given pid and tid.