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.Interface, ...) *NetworkPolicyManager
  • func (npMgr *NetworkPolicyManager) Encode(writer io.Writer) error
  • func (npMgr *NetworkPolicyManager) GetAppVersion() string
  • func (npMgr *NetworkPolicyManager) GetClusterState() telemetry.ClusterState
  • func (npMgr *NetworkPolicyManager) SendClusterMetrics()
  • func (npMgr *NetworkPolicyManager) Start(stopCh <-chan struct{}) error
• type NetworkPolicyManagerEncoder
• 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,
	ipsMgr *ipsm.IpsetManager, npmNamespaceCache *npmNamespaceCache) *nameSpaceController

func NewNetworkPolicyController

func NewNetworkPolicyController(npInformer networkinginformers.NetworkPolicyInformer,
	clientset kubernetes.Interface, ipsMgr *ipsm.IpsetManager) *networkPolicyController

func NewPodController

func NewPodController(podInformer coreinformer.PodInformer, clientset kubernetes.Interface,
	ipsMgr *ipsm.IpsetManager, npmNamespaceCache *npmNamespaceCache) *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.

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

type Namespace

type Namespace struct {
	LabelsMap map[string]string // NameSpace labels
	// contains filtered or unexported fields
}

type NetworkPolicyManager

type NetworkPolicyManager struct {
	NodeName string

	TelemetryEnabled bool
	// contains filtered or unexported fields
}

NetworkPolicyManager contains informers for pod, namespace and networkpolicy.

func NewNetworkPolicyManager

func NewNetworkPolicyManager(clientset kubernetes.Interface, informerFactory informers.SharedInformerFactory,
	exec utilexec.Interface, npmVersion string, k8sServerVersion *version.Info) *NetworkPolicyManager

NewNetworkPolicyManager creates a NetworkPolicyManager

func (*NetworkPolicyManager) Encode

func (npMgr *NetworkPolicyManager) Encode(writer io.Writer) error

Encode returns all information of pod, namespace, ipsm map information. TODO(jungukcho): While this approach is beneficial to hold separate lock instead of global lock, it has strict ordering limitation between encoding and decoding. Will find flexible way by maintaining performance benefit.

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 TODO(jungukcho): need to move codes into metrics packages

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 NetworkPolicyManagerEncoder

type NetworkPolicyManagerEncoder interface {
	Encode(writer io.Writer) error
}

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)