network

Aug 30, 2024

Changes in this version

type InterfaceGetter

+ GetNetworkInterfaceAddrs func(iface *net.Interface) ([]net.Addr, error)

Jul 2, 2024

Changes in this version

type IPAMAddResult

+ func (ipamAddResult IPAMAddResult) PrettyString() string

+ type InterfaceGetter interface

+ GetNetworkInterfaces func() ([]net.Interface, error)

type MockIpamInvoker

+ func NewCustomMockIpamInvoker(customReturn map[string]network.InterfaceInfo) *MockIpamInvoker

Dec 15, 2023

Changes in this version

+ func HandleIfCniUpdate(update func(*skel.CmdArgs) error) (bool, error)

+ func PrintCNIError(msg string)

+ func ReportPluginError(reportManager *telemetry.ReportManager, tb *telemetry.TelemetryBuffer, ...)

Nov 8, 2023

Changes in this version

+ type InterfaceInfo struct

Oct 7, 2021

Changes in this version

type MockMultitenancy

+ func (m *MockMultitenancy) GetContainerNetworkConfiguration(ctx context.Context, nwCfg *cni.NetworkConfig, podName string, ...) (*current.Result, *cns.GetNetworkContainerResponse, net.IPNet, error)

type Multitenancy

+ func (m *Multitenancy) GetContainerNetworkConfiguration(ctx context.Context, nwCfg *cni.NetworkConfig, podName string, ...) (*cniTypesCurr.Result, *cns.GetNetworkContainerResponse, net.IPNet, error)

type MultitenancyClient

+ GetContainerNetworkConfiguration func(ctx context.Context, nwCfg *cni.NetworkConfig, podName string, ...) (*cniTypesCurr.Result, *cns.GetNetworkContainerResponse, net.IPNet, error)

type NetPlugin

+ func (plugin *NetPlugin) GetMultiTenancyCNIResult(ctx context.Context, enableInfraVnet bool, nwCfg *cni.NetworkConfig, ...) (res *cniTypesCurr.Result, resp *cns.GetNetworkContainerResponse, ...)

Apr 14, 2021

Changes in this version

+ type ExecutionMode string

+ const Baremetal

+ const Default

Oct 1, 2020

Changes in this version

+ type IPv4ResultInfo struct

Oct 3, 2018

Changes in this version

+ func CleanupMultitenancyResources(enableInfraVnet bool, nwCfg *cni.NetworkConfig, ...)

+ func GetMultiTenancyCNIResult(enableInfraVnet bool, nwCfg *cni.NetworkConfig, plugin *netPlugin, ...) (*cniTypesCurr.Result, *cns.GetNetworkContainerResponse, net.IPNet, ...)

Jul 7, 2018

Changes in this version

+ func GetContainerNetworkConfiguration(multiTenancy bool, address string, podName string, podNamespace string) (*cniTypesCurr.Result, *cns.GetNetworkContainerResponse, net.IPNet, error)

+ func SetupRoutingForMultitenancy(nwCfg *cni.NetworkConfig, cnsNetworkConfig *cns.GetNetworkContainerResponse, ...)

Nov 20, 2023

Changes in this version

+ const CNI_ADD

+ const CNI_DEL

+ const CNI_UPDATE

+ const OpModeTransparent

+ func GetEndpointID(args *cniSkel.CmdArgs) string

+ func SetCustomDimensions(cniMetric *telemetry.AIMetric, nwCfg *cni.NetworkConfig, err error)

+ type AzureIPAMInvoker struct

+ func NewAzureIpamInvoker(plugin *NetPlugin, nwInfo *network.NetworkInfo) *AzureIPAMInvoker

+ func (invoker *AzureIPAMInvoker) Add(addConfig IPAMAddConfig) (IPAMAddResult, error)

+ func (invoker *AzureIPAMInvoker) Delete(address *net.IPNet, nwCfg *cni.NetworkConfig, _ *cniSkel.CmdArgs, ...) error

+ type AzureNetIOShim struct

+ func (a AzureNetIOShim) GetInterfaceSubnetWithSpecificIP(ipAddr string) *net.IPNet

+ type CNSIPAMInvoker struct

+ func NewCNSInvoker(podName, namespace string, cnsClient cnsclient, ...) *CNSIPAMInvoker

+ func (invoker *CNSIPAMInvoker) Add(addConfig IPAMAddConfig) (IPAMAddResult, error)

+ func (invoker *CNSIPAMInvoker) Delete(address *net.IPNet, nwCfg *cni.NetworkConfig, args *cniSkel.CmdArgs, ...) error

+ type IPAMAddConfig struct

+ type IPAMAddResult struct

+ type IPAMInvoker interface

+ Add func(IPAMAddConfig) (IPAMAddResult, error)

+ Delete func(address *net.IPNet, nwCfg *cni.NetworkConfig, args *cniSkel.CmdArgs, ...) error

+ type IPResultInfo struct

+ func (i IPResultInfo) MarshalLogObject(encoder zapcore.ObjectEncoder) error

+ type MockIpamInvoker struct

+ func NewMockIpamInvoker(ipv6, v4Fail, v6Fail, delegatedVMNIC, delegatedVMNICFail bool) *MockIpamInvoker

+ func (invoker *MockIpamInvoker) Add(opt IPAMAddConfig) (ipamAddResult IPAMAddResult, err error)

+ func (invoker *MockIpamInvoker) Delete(address *net.IPNet, nwCfg *cni.NetworkConfig, _ *skel.CmdArgs, ...) error

+ type MockMultitenancy struct

+ func NewMockMultitenancy(fail bool) *MockMultitenancy

+ func (m *MockMultitenancy) DetermineSnatFeatureOnHost(snatFile, nmAgentSupportedApisURL string) (snatDNS, snatHost bool, err error)

+ func (m *MockMultitenancy) GetAllNetworkContainers(ctx context.Context, nwCfg *cni.NetworkConfig, podName string, ...) ([]IPAMAddResult, error)

+ func (m *MockMultitenancy) GetNetworkContainer(ctx context.Context, nwCfg *cni.NetworkConfig, podName string, ...) (*cns.GetNetworkContainerResponse, net.IPNet, error)

+ func (m *MockMultitenancy) Init(cnsclient cnsclient, netnetioshim netioshim)

+ func (m *MockMultitenancy) SetupRoutingForMultitenancy(nwCfg *cni.NetworkConfig, cnsNetworkConfig *cns.GetNetworkContainerResponse, ...)

+ type Multitenancy struct

+ func (m *Multitenancy) DetermineSnatFeatureOnHost(snatFile, nmAgentSupportedApisURL string) (snatForDNS, snatOnHost bool, err error)

+ func (m *Multitenancy) GetAllNetworkContainers(ctx context.Context, nwCfg *cni.NetworkConfig, ...) ([]IPAMAddResult, error)

+ func (m *Multitenancy) Init(cnsclient cnsclient, netioshim netioshim)

+ func (m *Multitenancy) SetupRoutingForMultitenancy(nwCfg *cni.NetworkConfig, cnsNetworkConfig *cns.GetNetworkContainerResponse, ...)

+ type MultitenancyClient interface

+ DetermineSnatFeatureOnHost func(snatFile string, nmAgentSupportedApisURL string) (bool, bool, error)

+ GetAllNetworkContainers func(ctx context.Context, nwCfg *cni.NetworkConfig, podName string, ...) ([]IPAMAddResult, error)

+ Init func(cnsclient cnsclient, netioshim netioshim)

+ SetupRoutingForMultitenancy func(nwCfg *cni.NetworkConfig, cnsNetworkConfig *cns.GetNetworkContainerResponse, ...)

+ type NetPlugin struct

+ func NewPlugin(name string, config *common.PluginConfig, client NnsClient, ...) (*NetPlugin, error)

+ func (plugin *NetPlugin) Add(args *cniSkel.CmdArgs) error

+ func (plugin *NetPlugin) Delete(args *cniSkel.CmdArgs) error

+ func (plugin *NetPlugin) Get(args *cniSkel.CmdArgs) error

+ func (plugin *NetPlugin) GetAllEndpointState(networkid string) (*api.AzureCNIState, error)

+ func (plugin *NetPlugin) SetCNIReport(report *telemetry.CNIReport, tb *telemetry.TelemetryBuffer)

+ func (plugin *NetPlugin) Start(config *common.PluginConfig) error

+ func (plugin *NetPlugin) Stop()

+ func (plugin *NetPlugin) Update(args *cniSkel.CmdArgs) error

+ type NnsClient interface

+ AddContainerNetworking func(ctx context.Context, podName, nwNamespace string) (*nnscontracts.ConfigureContainerNetworkingResponse, error)

+ DeleteContainerNetworking func(ctx context.Context, podName, nwNamespace string) (*nnscontracts.ConfigureContainerNetworkingResponse, error)

+ type PolicyArgs struct