Documentation ¶
Overview ¶
Copyright 2018 Microsoft. All rights reserved. MIT License
Package npm Copyright 2018 Microsoft. All rights reserved. MIT License
Copyright 2018 Microsoft. All rights reserved. MIT License
Copyright 2018 Microsoft. All rights reserved. MIT License
Copyright 2018 Microsoft. All rights reserved. MIT License
Copyright 2018 Microsoft. All rights reserved. MIT License
Index ¶
- func GetAIMetadata() string
- func GetOperatorAndLabel(label string) (string, string)
- func GetOperatorsAndLabels(labelsWithOps []string) ([]string, []string)
- func HashSelector(selector *metav1.LabelSelector) string
- func ParseLabel(label string) (string, bool)
- type NetworkPolicyManager
- func (npMgr *NetworkPolicyManager) AddNamespace(nsObj *corev1.Namespace) error
- func (npMgr *NetworkPolicyManager) AddNetworkPolicy(npObj *networkingv1.NetworkPolicy) error
- func (npMgr *NetworkPolicyManager) AddPod(podObj *corev1.Pod) error
- func (npMgr *NetworkPolicyManager) DeleteNamespace(nsObj *corev1.Namespace) error
- func (npMgr *NetworkPolicyManager) DeleteNetworkPolicy(npObj *networkingv1.NetworkPolicy) error
- func (npMgr *NetworkPolicyManager) DeletePod(podObj *corev1.Pod) error
- func (npMgr *NetworkPolicyManager) GetAppVersion() string
- func (npMgr *NetworkPolicyManager) GetClusterState() telemetry.ClusterState
- func (npMgr *NetworkPolicyManager) InitAllNsList() error
- func (npMgr *NetworkPolicyManager) SendClusterMetrics()
- func (npMgr *NetworkPolicyManager) Start(stopCh <-chan struct{}) error
- func (npMgr *NetworkPolicyManager) UninitAllNsList() error
- func (npMgr *NetworkPolicyManager) UpdateNamespace(oldNsObj *corev1.Namespace, newNsObj *corev1.Namespace) error
- func (npMgr *NetworkPolicyManager) UpdateNetworkPolicy(oldNpObj *networkingv1.NetworkPolicy, newNpObj *networkingv1.NetworkPolicy) error
- func (npMgr *NetworkPolicyManager) UpdatePod(oldPodObj, newPodObj *corev1.Pod) error
- type ReqHeap
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetOperatorAndLabel ¶ added in v1.0.27
GetOperatorAndLabel returns the operator associated with the label and the label without operator.
func GetOperatorsAndLabels ¶ added in v1.0.27
GetOperatorsAndLabels returns the operators along with the associated labels.
func HashSelector ¶ added in v1.0.27
func HashSelector(selector *metav1.LabelSelector) string
HashSelector returns the hash value of the selector.
func ParseLabel ¶ added in v1.0.27
ParseLabel takes a Azure-NPM processed label then returns if it's referring to complement set, and if so, returns the original set as well.
Types ¶
type NetworkPolicyManager ¶
type NetworkPolicyManager struct { sync.Mutex TelemetryEnabled bool // contains filtered or unexported fields }
NetworkPolicyManager contains informers for pod, namespace and networkpolicy.
func NewNetworkPolicyManager ¶
func NewNetworkPolicyManager(clientset *kubernetes.Clientset, informerFactory informers.SharedInformerFactory, npmVersion string) *NetworkPolicyManager
NewNetworkPolicyManager creates a NetworkPolicyManager
func (*NetworkPolicyManager) AddNamespace ¶ added in v1.0.9
func (npMgr *NetworkPolicyManager) AddNamespace(nsObj *corev1.Namespace) error
AddNamespace handles adding namespace to ipset.
func (*NetworkPolicyManager) AddNetworkPolicy ¶ added in v1.0.9
func (npMgr *NetworkPolicyManager) AddNetworkPolicy(npObj *networkingv1.NetworkPolicy) error
AddNetworkPolicy handles adding network policy to iptables.
func (*NetworkPolicyManager) AddPod ¶ added in v1.0.9
func (npMgr *NetworkPolicyManager) AddPod(podObj *corev1.Pod) error
AddPod handles adding pod ip to its label's ipset.
func (*NetworkPolicyManager) DeleteNamespace ¶ added in v1.0.9
func (npMgr *NetworkPolicyManager) DeleteNamespace(nsObj *corev1.Namespace) error
DeleteNamespace handles deleting namespace from ipset.
func (*NetworkPolicyManager) DeleteNetworkPolicy ¶ added in v1.0.9
func (npMgr *NetworkPolicyManager) DeleteNetworkPolicy(npObj *networkingv1.NetworkPolicy) error
DeleteNetworkPolicy handles deleting network policy from iptables.
func (*NetworkPolicyManager) DeletePod ¶ added in v1.0.9
func (npMgr *NetworkPolicyManager) DeletePod(podObj *corev1.Pod) error
DeletePod handles deleting pod from its label's ipset.
func (*NetworkPolicyManager) GetAppVersion ¶
func (npMgr *NetworkPolicyManager) GetAppVersion() string
GetAppVersion returns network policy manager app version
func (*NetworkPolicyManager) GetClusterState ¶ added in v1.0.9
func (npMgr *NetworkPolicyManager) GetClusterState() telemetry.ClusterState
GetClusterState returns current cluster state.
func (*NetworkPolicyManager) InitAllNsList ¶ added in v1.0.9
func (npMgr *NetworkPolicyManager) InitAllNsList() error
InitAllNsList syncs all-namespace ipset list.
func (*NetworkPolicyManager) SendClusterMetrics ¶ added in v1.1.8
func (npMgr *NetworkPolicyManager) SendClusterMetrics()
SendClusterMetrics :- send NPM cluster metrics using AppInsights
func (*NetworkPolicyManager) Start ¶
func (npMgr *NetworkPolicyManager) Start(stopCh <-chan struct{}) error
Start starts shared informers and waits for the shared informer cache to sync.
func (*NetworkPolicyManager) UninitAllNsList ¶ added in v1.0.9
func (npMgr *NetworkPolicyManager) UninitAllNsList() error
UninitAllNsList cleans all-namespace ipset list.
func (*NetworkPolicyManager) UpdateNamespace ¶ added in v1.0.9
func (npMgr *NetworkPolicyManager) UpdateNamespace(oldNsObj *corev1.Namespace, newNsObj *corev1.Namespace) error
UpdateNamespace handles updating namespace in ipset.
func (*NetworkPolicyManager) UpdateNetworkPolicy ¶ added in v1.0.9
func (npMgr *NetworkPolicyManager) UpdateNetworkPolicy(oldNpObj *networkingv1.NetworkPolicy, newNpObj *networkingv1.NetworkPolicy) error
UpdateNetworkPolicy handles updateing network policy in iptables.
type ReqHeap ¶ added in v1.0.27
type ReqHeap []metav1.LabelSelectorRequirement
An ReqHeap is a min-heap of labelSelectorRequirements.