daemon

Documentation

Index

• Constants
• Variables
• func InitNodeGateway(config *Configuration) error
• func RunServer(config *Configuration)
• type CniServerHandler
• 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"
)

Variables

var RequestLogString = "[%s] Incoming %s %s %s request"

var ResponseLogString = "[%s] Outcoming response %s %s with %d status code in %vms"

Functions

func InitNodeGateway

func InitNodeGateway(config *Configuration) error

func RunServer

func RunServer(config *Configuration)

Types

type CniServerHandler

type CniServerHandler struct {
	Config     *Configuration
	KubeClient kubernetes.Interface
}

type Configuration

type Configuration struct {
	BindSocket            string
	OvsSocket             string
	KubeConfigFile        string
	KubeClient            kubernetes.Interface
	NodeName              string
	OvnNbHost             string
	OvnNbPort             int
	OvnSbHost             string
	OvnSbPort             int
	ClusterRouter         string
	NodeSwitch            string
	ServiceClusterIPRange string
}

func ParseFlags

func ParseFlags() (*Configuration, error)

TODO: validate configuration

type Controller

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

func NewController

func NewController(config *Configuration, informerFactory informers.SharedInformerFactory) (*Controller, error)

func (*Controller) Run

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