types

package
v4.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 29, 2026 License: Apache-2.0 Imports: 17 Imported by: 19

Documentation

Overview

Package types contains common types in the multus.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CheckGatewayConfig 

func CheckGatewayConfig(delegates []*DelegateNetConf) error

CheckGatewayConfig check gatewayRequest and mark IsFilter{V4,V6}Gateway flag if gw filtering is required

func CheckSystemNamespaces 

func CheckSystemNamespaces(namespace string, systemNamespaces []string) bool

CheckSystemNamespaces checks whether given namespace is in systemNamespaces or not.

func ConvertNetworkConfigListToNetConfList added in v4.2.1 

func ConvertNetworkConfigListToNetConfList(ncList *libcni.NetworkConfigList) (*types.NetConfList, error)

ConvertNetworkConfigListToNetConfList converts a libcni.NetworkConfigList to a NetConfList

func CreateCNIRuntimeConf 

func CreateCNIRuntimeConf(args *skel.CmdArgs, k8sArgs *K8sArgs, ifName string, rc *RuntimeConfig, delegate *DelegateNetConf) (*libcni.RuntimeConf, string)

CreateCNIRuntimeConf create CNI RuntimeConf for a delegate. If delegate configuration exists, merge data with the runtime config.

func GetGatewayFromResult 

func GetGatewayFromResult(result *cni100.Result) []net.IP

GetGatewayFromResult retrieves gateway IP addresses from CNI result

func GetReadinessIndicatorFile added in v4.1.0 

func GetReadinessIndicatorFile(readinessIndicatorFileRaw string) error

GetReadinessIndicatorFile waits for readinessIndicatorFile

func LoadDelegateNetConfList 

func LoadDelegateNetConfList(bytes []byte, delegateConf *DelegateNetConf) error

LoadDelegateNetConfList reads DelegateNetConf from bytes

func ReadinessIndicatorExistsNow added in v4.1.0 

func ReadinessIndicatorExistsNow(readinessIndicatorFileRaw string) (bool, error)

ReadinessIndicatorExistsNow reports if the readiness indicator exists immediately.

func SortDeviceIDs added in v4.3.0 

func SortDeviceIDs(resourceMap map[string]*ResourceInfo)

SortDeviceIDs sorts DeviceIDs in each ResourceInfo in place so that device order is deterministic across GetPodResourceMap callers (e.g. Multus and OVN-Kubernetes).

Types

type BandwidthEntry 

type BandwidthEntry struct {
	IngressRate  int `json:"ingressRate"`
	IngressBurst int `json:"ingressBurst"`

	EgressRate  int `json:"egressRate"`
	EgressBurst int `json:"egressBurst"`
}

BandwidthEntry for CNI BandwidthEntry

type DelegateNetConf 

type DelegateNetConf struct {
	Conf                  types.NetConf
	ConfList              types.NetConfList
	CNINetworkConfigList  libcni.NetworkConfigList
	Name                  string
	IfnameRequest         string          `json:"ifnameRequest,omitempty"`
	MacRequest            string          `json:"macRequest,omitempty"`
	InfinibandGUIDRequest string          `json:"infinibandGUIDRequest,omitempty"`
	IPRequest             []string        `json:"ipRequest,omitempty"`
	PortMappingsRequest   []*PortMapEntry `json:"-"`
	BandwidthRequest      *BandwidthEntry `json:"-"`
	GatewayRequest        *[]net.IP       `json:"default-route,omitempty"`
	IsFilterV4Gateway     bool
	IsFilterV6Gateway     bool
	// MasterPlugin is only used internal housekeeping
	MasterPlugin bool `json:"-"`
	// Conflist plugin is only used internal housekeeping
	ConfListPlugin bool `json:"-"`
	// DeviceID is only used internal housekeeping
	DeviceID string `json:"deviceID,omitempty"`
	// ResourceName is only used internal housekeeping
	ResourceName string `json:"resourceName,omitempty"`

	// Raw JSON
	Bytes []byte
}

DelegateNetConf for net-attach-def for pod

func LoadDelegateNetConf 

func LoadDelegateNetConf(bytes []byte, netElement *NetworkSelectionElement, deviceID string, resourceName string) (*DelegateNetConf, error)

LoadDelegateNetConf converts raw CNI JSON into a DelegateNetConf structure

func LoadDelegateNetConfFromConfList added in v4.2.1 

func LoadDelegateNetConfFromConfList(confList *libcni.NetworkConfigList, netElement *NetworkSelectionElement, deviceID string, resourceName string) (*DelegateNetConf, error)

LoadDelegateNetConfFromConfList converts a libcni.NetworkConfigList into a DelegateNetConf structure

type K8sArgs 

type K8sArgs struct {
	types.CommonArgs
	IP                         net.IP
	K8S_POD_NAME               types.UnmarshallableString //revive:disable-line
	K8S_POD_NAMESPACE          types.UnmarshallableString //revive:disable-line
	K8S_POD_INFRA_CONTAINER_ID types.UnmarshallableString //revive:disable-line
	K8S_POD_UID                types.UnmarshallableString //revive:disable-line
}

K8sArgs is the valid CNI_ARGS used for Kubernetes

type NetConf 

type NetConf struct {
	types.NetConf

	// support chaining for master interface and IP decisions
	// occurring prior to running ipvlan plugin
	RawPrevResult *map[string]interface{} `json:"prevResult"`
	PrevResult    *cni100.Result          `json:"-"`

	ConfDir string `json:"confDir"`
	CNIDir  string `json:"cniDir"`
	BinDir  string `json:"binDir"`
	// RawDelegates is private to the NetConf class; use Delegates instead
	RawDelegates []map[string]interface{} `json:"delegates"`
	// These parameters are exclusive in one config file:
	//  - Delegates (directly add delegate CNI config into multus CNI config)
	//  - ClusterNetwork+DefaultNetworks  (add CNI config through CRD, directory or file)
	Delegates       []*DelegateNetConf  `json:"-"`
	ClusterNetwork  string              `json:"clusterNetwork"`
	DefaultNetworks []string            `json:"defaultNetworks"`
	Kubeconfig      string              `json:"kubeconfig"`
	LogFile         string              `json:"logFile"`
	LogLevel        string              `json:"logLevel"`
	LogToStderr     bool                `json:"logToStderr,omitempty"`
	LogOptions      *logging.LogOptions `json:"logOptions,omitempty"`
	RuntimeConfig   *RuntimeConfig      `json:"runtimeConfig,omitempty"`
	// Default network readiness options
	ReadinessIndicatorFile string `json:"readinessindicatorfile"`
	// Option to isolate the usage of CR's to the namespace in which a pod resides.
	NamespaceIsolation       bool     `json:"namespaceIsolation"`
	RawNonIsolatedNamespaces string   `json:"globalNamespaces"`
	NonIsolatedNamespaces    []string `json:"-"`
	AuxiliaryCNIChainName    string   `json:"auxiliaryCNIChainName,omitempty"`

	// Option to set system namespaces (to avoid to add defaultNetworks)
	SystemNamespaces []string `json:"systemNamespaces"`
	// Option to set the namespace that multus-cni uses (clusterNetwork/defaultNetworks)
	MultusNamespace string `json:"multusNamespace"`

	// Retry delegate DEL message to next when some error
	RetryDeleteOnError bool `json:"retryDeleteOnError"`
}

NetConf for cni config file written in json

func GetDefaultNetConf 

func GetDefaultNetConf() *NetConf

GetDefaultNetConf returns NetConf with default variables

func LoadNetConf 

func LoadNetConf(bytes []byte) (*NetConf, error)

LoadNetConf converts inputs (i.e. stdin) to NetConf

func (*NetConf) AddDelegates 

func (n *NetConf) AddDelegates(newDelegates []*DelegateNetConf) error

AddDelegates appends the new delegates to the delegates list

type NetworkSelectionElement 

type NetworkSelectionElement struct {
	// Name contains the name of the Network object this element selects
	Name string `json:"name"`
	// Namespace contains the optional namespace that the network referenced
	// by Name exists in
	Namespace string `json:"namespace,omitempty"`
	// IPRequest contains an optional requested IP address for this network
	// attachment
	IPRequest []string `json:"ips,omitempty"`
	// MacRequest contains an optional requested MAC address for this
	// network attachment
	MacRequest string `json:"mac,omitempty"`
	// InfinibandGUID request contains an optional requested Infiniband GUID address
	// for this network attachment
	InfinibandGUIDRequest string `json:"infiniband-guid,omitempty"`
	// InterfaceRequest contains an optional requested name for the
	// network interface this attachment will create in the container
	InterfaceRequest string `json:"interface,omitempty"`
	// DeprecatedInterfaceRequest is obsolated parameter at pre 3.2.
	// This will be removed in 4.0 release.
	DeprecatedInterfaceRequest string `json:"interfaceRequest,omitempty"`
	// PortMappingsRequest contains an optional requested port mapping
	// for the network
	PortMappingsRequest []*PortMapEntry `json:"portMappings,omitempty"`
	// BandwidthRequest contains an optional requested bandwidth for
	// the network
	BandwidthRequest *BandwidthEntry `json:"bandwidth,omitempty"`
	// DeviceID contains an optional requested deviceID the network
	DeviceID string `json:"deviceID,omitempty"`
	// CNIArgs contains additional CNI arguments for the network interface
	CNIArgs *map[string]interface{} `json:"cni-args"`
	// GatewayRequest contains default route IP address for the pod
	GatewayRequest *[]net.IP `json:"default-route,omitempty"`
}

NetworkSelectionElement represents one element of the JSON format Network Attachment Selection Annotation as described in section 4.1.2 of the CRD specification.

type PortMapEntry 

type PortMapEntry struct {
	HostPort      int    `json:"hostPort"`
	ContainerPort int    `json:"containerPort"`
	Protocol      string `json:"protocol,omitempty"`
	HostIP        string `json:"hostIP,omitempty"`
}

PortMapEntry for CNI PortMapEntry

type ResourceClient 

type ResourceClient interface {
	// GetPodResourceMap returns an instance of a map of Pod ResourceInfo given a (Pod name, namespace) tuple
	GetPodResourceMap(*v1.Pod) (map[string]*ResourceInfo, error)
}

ResourceClient provides a kubelet Pod resource handle

type ResourceInfo 

type ResourceInfo struct {
	Index     int
	DeviceIDs []string
}

ResourceInfo is struct to hold Pod device allocation information

type RuntimeConfig 

type RuntimeConfig struct {
	PortMaps          []*PortMapEntry `json:"portMappings,omitempty"`
	Bandwidth         *BandwidthEntry `json:"bandwidth,omitempty"`
	IPs               []string        `json:"ips,omitempty"`
	Mac               string          `json:"mac,omitempty"`
	InfinibandGUID    string          `json:"infinibandGUID,omitempty"`
	DeviceID          string          `json:"deviceID,omitempty"`
	CNIDeviceInfoFile string          `json:"CNIDeviceInfoFile,omitempty"`
}

RuntimeConfig specifies CNI RuntimeConfig

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.