Documentation ¶
Overview ¶
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 ¶
- 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) GetClusterState() telemetry.ClusterState
- func (npMgr *NetworkPolicyManager) InitAllNsList() error
- func (npMgr *NetworkPolicyManager) SendNpmTelemetry()
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶
func (npMgr *NetworkPolicyManager) AddNamespace(nsObj *corev1.Namespace) error
AddNamespace handles adding namespace to ipset.
func (*NetworkPolicyManager) AddNetworkPolicy ¶
func (npMgr *NetworkPolicyManager) AddNetworkPolicy(npObj *networkingv1.NetworkPolicy) error
AddNetworkPolicy handles adding network policy to iptables.
func (*NetworkPolicyManager) AddPod ¶
func (npMgr *NetworkPolicyManager) AddPod(podObj *corev1.Pod) error
AddPod handles adding pod ip to its label's ipset.
func (*NetworkPolicyManager) DeleteNamespace ¶
func (npMgr *NetworkPolicyManager) DeleteNamespace(nsObj *corev1.Namespace) error
DeleteNamespace handles deleting namespace from ipset.
func (*NetworkPolicyManager) DeleteNetworkPolicy ¶
func (npMgr *NetworkPolicyManager) DeleteNetworkPolicy(npObj *networkingv1.NetworkPolicy) error
DeleteNetworkPolicy handles deleting network policy from iptables.
func (*NetworkPolicyManager) DeletePod ¶
func (npMgr *NetworkPolicyManager) DeletePod(podObj *corev1.Pod) error
DeletePod handles deleting pod from its label's ipset.
func (*NetworkPolicyManager) GetClusterState ¶
func (npMgr *NetworkPolicyManager) GetClusterState() telemetry.ClusterState
GetClusterState returns current cluster state.
func (*NetworkPolicyManager) InitAllNsList ¶
func (npMgr *NetworkPolicyManager) InitAllNsList() error
InitAllNsList syncs all-namespace ipset list.
func (*NetworkPolicyManager) SendNpmTelemetry ¶ added in v1.0.23
func (npMgr *NetworkPolicyManager) SendNpmTelemetry()
SendNpmTelemetry updates the npm report then send it.
func (*NetworkPolicyManager) Start ¶ added in v1.0.19
func (npMgr *NetworkPolicyManager) Start(stopCh <-chan struct{}) error
Start starts shared informers and waits for the shared informer cache to sync.
func (*NetworkPolicyManager) UninitAllNsList ¶
func (npMgr *NetworkPolicyManager) UninitAllNsList() error
UninitAllNsList cleans all-namespace ipset list.
func (*NetworkPolicyManager) UpdateNamespace ¶
func (npMgr *NetworkPolicyManager) UpdateNamespace(oldNsObj *corev1.Namespace, newNsObj *corev1.Namespace) error
UpdateNamespace handles updating namespace in ipset.
func (*NetworkPolicyManager) UpdateNetworkPolicy ¶
func (npMgr *NetworkPolicyManager) UpdateNetworkPolicy(oldNpObj *networkingv1.NetworkPolicy, newNpObj *networkingv1.NetworkPolicy) error
UpdateNetworkPolicy handles updateing network policy in iptables.