Versions in this module Expand all Collapse all v0 v0.1.0 Oct 27, 2022 Changes in this version + type InterfaceInfo struct + DeviceID string + IPs []string + InterfaceName string + InterfaceType string + NetattachName string + func (info *InterfaceInfo) CheckPolicyNetwork(policyNetworks []string) bool + type NamespaceChangeTracker struct + func NewNamespaceChangeTracker() *NamespaceChangeTracker + func (nct *NamespaceChangeTracker) Update(previous, current *v1.Namespace) bool + type NamespaceConfig struct + func NewNamespaceConfig(nsInformer coreinformers.NamespaceInformer, resyncPeriod time.Duration) *NamespaceConfig + func (c *NamespaceConfig) RegisterEventHandler(handler NamespaceHandler) + func (c *NamespaceConfig) Run(stopCh <-chan struct{}) + type NamespaceHandler interface + OnNamespaceAdd func(ns *v1.Namespace) + OnNamespaceDelete func(ns *v1.Namespace) + OnNamespaceSynced func() + OnNamespaceUpdate func(oldNS, ns *v1.Namespace) + type NamespaceInfo struct + Labels map[string]string + Name string + type NamespaceMap map[string]NamespaceInfo + func (nm *NamespaceMap) GetNamespaceInfo(nsName string) (*NamespaceInfo, error) + func (nm *NamespaceMap) Update(changes *NamespaceChangeTracker) + type NetDefChangeTracker struct + func NewNetDefChangeTracker() *NetDefChangeTracker + func (ndt *NetDefChangeTracker) GetPluginType(name types.NamespacedName) string + func (ndt *NetDefChangeTracker) String() string + func (ndt *NetDefChangeTracker) Update(previous, current *netdefv1.NetworkAttachmentDefinition) bool + type NetDefConfig struct + func NewNetDefConfig(netdefInformer netdefinformerv1.NetworkAttachmentDefinitionInformer, ...) *NetDefConfig + func (c *NetDefConfig) RegisterEventHandler(handler NetDefHandler) + func (c *NetDefConfig) Run(stopCh <-chan struct{}) + type NetDefHandler interface + OnNetDefAdd func(net *netdefv1.NetworkAttachmentDefinition) + OnNetDefDelete func(net *netdefv1.NetworkAttachmentDefinition) + OnNetDefSynced func() + OnNetDefUpdate func(oldNet, net *netdefv1.NetworkAttachmentDefinition) + type NetDefInfo struct + Netdef *netdefv1.NetworkAttachmentDefinition + PluginType string + func (info *NetDefInfo) Name() string + type NetDefMap map[types.NamespacedName]NetDefInfo + func (n *NetDefMap) Update(changes *NetDefChangeTracker) + type NetworkPolicyConfig struct + func NewNetworkPolicyConfig(policyInformer multiinformerv1beta1.MultiNetworkPolicyInformer, ...) *NetworkPolicyConfig + func (c *NetworkPolicyConfig) RegisterEventHandler(handler NetworkPolicyHandler) + func (c *NetworkPolicyConfig) Run(stopCh <-chan struct{}) + type NetworkPolicyHandler interface + OnPolicyAdd func(policy *multiv1beta1.MultiNetworkPolicy) + OnPolicyDelete func(policy *multiv1beta1.MultiNetworkPolicy) + OnPolicySynced func() + OnPolicyUpdate func(oldPolicy, policy *multiv1beta1.MultiNetworkPolicy) + type PodChangeTracker struct + func NewPodChangeTracker(networkPlugins []string, ndt *NetDefChangeTracker) *PodChangeTracker + func (pct *PodChangeTracker) String() string + func (pct *PodChangeTracker) Update(previous, current *v1.Pod) bool + type PodConfig struct + func NewPodConfig(podInformer coreinformers.PodInformer, resyncPeriod time.Duration) *PodConfig + func (c *PodConfig) RegisterEventHandler(handler PodHandler) + func (c *PodConfig) Run(stopCh <-chan struct{}) + type PodHandler interface + OnPodAdd func(pod *v1.Pod) + OnPodDelete func(pod *v1.Pod) + OnPodSynced func() + OnPodUpdate func(oldPod, pod *v1.Pod) + type PodInfo struct + Interfaces []InterfaceInfo + Labels map[string]string + Name string + Namespace string + NetworkStatus []netdefv1.NetworkStatus + NodeName string + UID string + func (info *PodInfo) CheckPolicyNetwork(policyNetworks []string) bool + func (info *PodInfo) PolicyAppliesForPod(policy *multiv1beta1.MultiNetworkPolicy) (bool, error) + func (info *PodInfo) String() string + type PodMap map[types.NamespacedName]PodInfo + func (pm *PodMap) GetPodInfo(namespace, name string) (*PodInfo, error) + func (pm *PodMap) List() ([]PodInfo, error) + func (pm *PodMap) Update(changes *PodChangeTracker) + type PolicyChangeTracker struct + func NewPolicyChangeTracker() *PolicyChangeTracker + func (pct *PolicyChangeTracker) String() string + func (pct *PolicyChangeTracker) Update(previous, current *multiv1beta1.MultiNetworkPolicy) bool + type PolicyInfo struct + Policy *multiv1beta1.MultiNetworkPolicy + PolicyNetworks []string + func (info *PolicyInfo) AppliesForNetwork(networkName string) bool + func (info *PolicyInfo) Name() string + func (info *PolicyInfo) Namespace() string + type PolicyMap map[types.NamespacedName]PolicyInfo + func (pm *PolicyMap) Update(changes *PolicyChangeTracker)