agent

Documentation

Overview

Package agent contains the libraries that drive the antrea-agent binary. antrea-agent is responsible for the Pod networking and policy implementation on a Kubernetes Node.

Index

• func GetTransportIPNetDeviceByName(ifaceName string, ovsBridgeName string) (*net.IPNet, *net.IPNet, *net.Interface, error)
• func NewAntreaClientProvider(config config.ClientConnectionConfiguration, kubeClient kubernetes.Interface) *antreaClientProvider
• type AntreaClientProvider
• type Initializer
  • func NewInitializer(k8sClient clientset.Interface, crdClient versioned.Interface, ...) *Initializer
  • func (i *Initializer) ConnectUplinkToOVSBridge() error
  • func (i *Initializer) FlowRestoreComplete() error
  • func (i *Initializer) GetNodeConfig() *config.NodeConfig
  • func (i *Initializer) GetWireGuardClient() wireguard.Interface
  • func (i *Initializer) Initialize() error
  • func (i *Initializer) RestoreOVSBridge()

Functions

func GetTransportIPNetDeviceByName

func GetTransportIPNetDeviceByName(ifaceName string, ovsBridgeName string) (*net.IPNet, *net.IPNet, *net.Interface, error)

func NewAntreaClientProvider

func NewAntreaClientProvider(config config.ClientConnectionConfiguration, kubeClient kubernetes.Interface) *antreaClientProvider

Types

type AntreaClientProvider

type AntreaClientProvider interface {
	GetAntreaClient() (versioned.Interface, error)
}

AntreaClientProvider provides a method to get Antrea client.

type Initializer

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

Initializer knows how to setup host networking, OpenVSwitch, and Openflow.

func NewInitializer

func NewInitializer(
	k8sClient clientset.Interface,
	crdClient versioned.Interface,
	ovsBridgeClient ovsconfig.OVSBridgeClient,
	ovsCtlClient ovsctl.OVSCtlClient,
	ofClient openflow.Client,
	routeClient route.Interface,
	ifaceStore interfacestore.InterfaceStore,
	ovsBridge string,
	hostGateway string,
	mtu int,
	networkConfig *config.NetworkConfig,
	wireGuardConfig *config.WireGuardConfig,
	egressConfig *config.EgressConfig,
	serviceConfig *config.ServiceConfig,
	podNetworkWait *utilwait.Group,
	stopCh <-chan struct{},
	nodeType config.NodeType,
	externalNodeNamespace string,
	connectUplinkToBridge bool,
	enableL7NetworkPolicy bool,
) *Initializer

func (*Initializer) ConnectUplinkToOVSBridge

func (i *Initializer) ConnectUplinkToOVSBridge() error

func (*Initializer) FlowRestoreComplete

func (i *Initializer) FlowRestoreComplete() error

func (*Initializer) GetNodeConfig

func (i *Initializer) GetNodeConfig() *config.NodeConfig

GetNodeConfig returns the NodeConfig.

func (*Initializer) GetWireGuardClient

func (i *Initializer) GetWireGuardClient() wireguard.Interface

GetWireGuardClient returns the Wireguard client.

func (*Initializer) Initialize

func (i *Initializer) Initialize() error

Initialize sets up agent initial configurations.

func (*Initializer) RestoreOVSBridge

func (i *Initializer) RestoreOVSBridge()

RestoreOVSBridge returns immediately on Linux if connectUplinkToBridge is false. OVS is managed by Antrea in Linux, network config must be restored to uplink before Antrea Agent shutdown.