npm

Documentation

Overview

Copyright 2018 Microsoft. All rights reserved. MIT License

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

Index

• func FlattenNameSpaceSelector(nsSelector *metav1.LabelSelector) []metav1.LabelSelector
• func GetAIMetadata() string
• func GetOperatorAndLabel(label string) (string, string)
• func GetOperatorsAndLabels(labelsWithOps []string) ([]string, []string)
• func HashSelector(selector *metav1.LabelSelector) string
• func NewNameSpaceController(nameSpaceInformer coreinformer.NamespaceInformer, ...) *nameSpaceController
• func NewNetworkPolicyController(npInformer networkinginformers.NetworkPolicyInformer, ...) *networkPolicyController
• func NewPodController(podInformer coreinformer.PodInformer, clientset kubernetes.Interface, ...) *podController
• func ParseLabel(label string) (string, bool)
• type IsSafeCleanUpAzureNpmChain
• type LabelAppendOperation
• type NamedPortOperation
• type Namespace
• type NetworkPolicyManager
  • func NewNetworkPolicyManager(clientset *kubernetes.Clientset, ...) *NetworkPolicyManager
  • func (npMgr *NetworkPolicyManager) GetAppVersion() string
  • func (npMgr *NetworkPolicyManager) GetClusterState() telemetry.ClusterState
  • func (npMgr *NetworkPolicyManager) SendClusterMetrics()
  • func (npMgr *NetworkPolicyManager) Start(stopCh <-chan struct{}) error
• type NpmPod
• type ReqHeap
  • func (h ReqHeap) Len() int
  • func (h ReqHeap) Less(i, j int) bool
  • func (h *ReqHeap) Pop() interface{}
  • func (h *ReqHeap) Push(x interface{})
  • func (h ReqHeap) Swap(i, j int)

Functions

func FlattenNameSpaceSelector

func FlattenNameSpaceSelector(nsSelector *metav1.LabelSelector) []metav1.LabelSelector

flattenNameSpaceSelector will help flatten multiple NameSpace selector match Expressions values into multiple label selectors helping with the OR condition.

func GetAIMetadata

func GetAIMetadata() string

GetAIMetadata returns ai metadata number

func GetOperatorAndLabel

func GetOperatorAndLabel(label string) (string, string)

GetOperatorAndLabel returns the operator associated with the label and the label without operator.

func GetOperatorsAndLabels

func GetOperatorsAndLabels(labelsWithOps []string) ([]string, []string)

GetOperatorsAndLabels returns the operators along with the associated labels.

func HashSelector

func HashSelector(selector *metav1.LabelSelector) string

HashSelector returns the hash value of the selector.

func NewNameSpaceController

func NewNameSpaceController(nameSpaceInformer coreinformer.NamespaceInformer, clientset kubernetes.Interface, npMgr *NetworkPolicyManager) *nameSpaceController

func NewNetworkPolicyController

func NewNetworkPolicyController(npInformer networkinginformers.NetworkPolicyInformer, clientset kubernetes.Interface, npMgr *NetworkPolicyManager) *networkPolicyController

func NewPodController

func NewPodController(podInformer coreinformer.PodInformer, clientset kubernetes.Interface, npMgr *NetworkPolicyManager) *podController

func ParseLabel

func ParseLabel(label string) (string, bool)

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 IsSafeCleanUpAzureNpmChain

type IsSafeCleanUpAzureNpmChain bool

IsSafeCleanUpAzureNpmChain is used to indicate whether default Azure NPM chain can be safely deleted or not.

const (
	SafeToCleanUpAzureNpmChain IsSafeCleanUpAzureNpmChain = true
)

type LabelAppendOperation

type LabelAppendOperation bool

const (
	ClearExistingLabels    LabelAppendOperation = true
	AppendToExistingLabels LabelAppendOperation = false
)

type NamedPortOperation

type NamedPortOperation string

NamedPortOperation decides opeartion (e.g., delete or add) for named port ipset in manageNamedPortIpsets

const (
	DeleteNamedPortIpsets NamedPortOperation = "del"
	AddNamedPortIpsets    NamedPortOperation = "add"
)

type Namespace

type Namespace struct {
	LabelsMap map[string]string // NameSpace labels
	SetMap    map[string]string
	IpsMgr    *ipsm.IpsetManager
	// contains filtered or unexported fields
}

type NetworkPolicyManager

type NetworkPolicyManager struct {
	sync.Mutex

	Exec utilexec.Interface

	NodeName       string
	NsMap          map[string]*Namespace                  // Key is ns-<nsname>
	PodMap         map[string]*NpmPod                     // Key is <nsname>/<podname>
	RawNpMap       map[string]*networkingv1.NetworkPolicy // Key is <nsname>/<policyname>
	ProcessedNpMap map[string]*networkingv1.NetworkPolicy // Key is <nsname>/<podSelectorHash>

	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, exec utilexec.Interface, npmVersion string) *NetworkPolicyManager

NewNetworkPolicyManager creates a NetworkPolicyManager

func (*NetworkPolicyManager) GetAppVersion

func (npMgr *NetworkPolicyManager) GetAppVersion() string

GetAppVersion returns network policy manager app version

func (*NetworkPolicyManager) GetClusterState

func (npMgr *NetworkPolicyManager) GetClusterState() telemetry.ClusterState

GetClusterState returns current cluster state.

func (*NetworkPolicyManager) SendClusterMetrics

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.

type NpmPod

type NpmPod struct {
	Name           string
	Namespace      string
	PodIP          string
	Labels         map[string]string
	ContainerPorts []corev1.ContainerPort
	Phase          corev1.PodPhase
}

type ReqHeap

type ReqHeap []metav1.LabelSelectorRequirement

An ReqHeap is a min-heap of labelSelectorRequirements.

func (ReqHeap) Len

func (h ReqHeap) Len() int

func (ReqHeap) Less

func (h ReqHeap) Less(i, j int) bool

func (*ReqHeap) Pop

func (h *ReqHeap) Pop() interface{}

func (*ReqHeap) Push

func (h *ReqHeap) Push(x interface{})

func (ReqHeap) Swap

func (h ReqHeap) Swap(i, j int)