controllers

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

Copyright 2018 Microsoft. All rights reserved. MIT License

Index

• func FlattenNameSpaceSelector(nsSelector *metav1.LabelSelector) []metav1.LabelSelector
• 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 IsSafeCleanUpAzureNpmChain
• type NamedPortOperation
• type NamespaceController
  • func NewNameSpaceController(nameSpaceInformer coreinformer.NamespaceInformer, ipsMgr *ipsm.IpsetManager, ...) *NamespaceController
  • func (nsc *NamespaceController) Run(stopCh <-chan struct{})
• type NetworkPolicyController
  • func NewNetworkPolicyController(npInformer networkinginformers.NetworkPolicyInformer, ...) *NetworkPolicyController
  • func (c *NetworkPolicyController) BootupDataplane() error
  • func (c *NetworkPolicyController) LengthOfRawNpMap() int
  • func (c *NetworkPolicyController) Run(stopCh <-chan struct{})
  • func (c *NetworkPolicyController) RunPeriodicTasks(stopCh <-chan struct{})
• type NpmNamespaceCache
  • func (n *NpmNamespaceCache) GetNsMap() map[string]*common.Namespace
  • func (n *NpmNamespaceCache) MarshalJSON() ([]byte, error)
• type PodController
  • func NewPodController(podInformer coreinformer.PodInformer, ipsMgr *ipsm.IpsetManager, ...) *PodController
  • func (c *PodController) LengthOfPodMap() int
  • func (c *PodController) MarshalJSON() ([]byte, error)
  • func (c *PodController) Run(stopCh <-chan struct{})
• 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 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 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 NamedPortOperation

type NamedPortOperation string

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

type NamespaceController

type NamespaceController struct {
	// contains filtered or unexported fields
}

func NewNameSpaceController

func NewNameSpaceController(nameSpaceInformer coreinformer.NamespaceInformer, ipsMgr *ipsm.IpsetManager, npmNamespaceCache *NpmNamespaceCache) *NamespaceController

func (*NamespaceController) Run

func (nsc *NamespaceController) Run(stopCh <-chan struct{})

type NetworkPolicyController

type NetworkPolicyController struct {
	// contains filtered or unexported fields
}

func NewNetworkPolicyController

func NewNetworkPolicyController(npInformer networkinginformers.NetworkPolicyInformer, ipsMgr *ipsm.IpsetManager, placeAzureChainFirst bool) *NetworkPolicyController

func (*NetworkPolicyController) BootupDataplane

func (c *NetworkPolicyController) BootupDataplane() error

BootupDataplane does all initialization tasks for data plane TODO(jungukcho) Need to refactor UninitNpmChains since it assumes it has already AZURE-NPM chains

func (*NetworkPolicyController) LengthOfRawNpMap

func (c *NetworkPolicyController) LengthOfRawNpMap() int

func (*NetworkPolicyController) Run

func (c *NetworkPolicyController) Run(stopCh <-chan struct{})

func (*NetworkPolicyController) RunPeriodicTasks

func (c *NetworkPolicyController) RunPeriodicTasks(stopCh <-chan struct{})

type NpmNamespaceCache

type NpmNamespaceCache struct {
	sync.RWMutex
	NsMap map[string]*common.Namespace // Key is ns-<nsname>
}

NpmNamespaceCache to store namespace struct in nameSpaceController.go. Since this cache is shared between podController and NameSpaceController, it has mutex for avoiding racing condition between them.

func (*NpmNamespaceCache) GetNsMap

func (n *NpmNamespaceCache) GetNsMap() map[string]*common.Namespace

func (*NpmNamespaceCache) MarshalJSON

func (n *NpmNamespaceCache) MarshalJSON() ([]byte, error)

type PodController

type PodController struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewPodController

func NewPodController(podInformer coreinformer.PodInformer, ipsMgr *ipsm.IpsetManager, npmNamespaceCache *NpmNamespaceCache) *PodController

func (*PodController) LengthOfPodMap

func (c *PodController) LengthOfPodMap() int

func (*PodController) MarshalJSON

func (c *PodController) MarshalJSON() ([]byte, error)

func (*PodController) Run

func (c *PodController) Run(stopCh <-chan struct{})

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)