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

Index

• type Cache
• type LabelAppendOperation
• type NamedPortOperation
• type Namespace
• type NamespaceController
  • func NewNamespaceController(nameSpaceInformer coreinformer.NamespaceInformer, ...) *NamespaceController
  • func (nsc *NamespaceController) Run(stopCh <-chan struct{})
• type NetworkPolicyController
  • func NewNetworkPolicyController(npInformer networkinginformers.NetworkPolicyInformer, ...) *NetworkPolicyController
  • func (c *NetworkPolicyController) LengthOfRawNpMap() int
  • func (c *NetworkPolicyController) Run(stopCh <-chan struct{})
• type NpmNamespaceCache
  • func (n *NpmNamespaceCache) MarshalJSON() ([]byte, error)
• type NpmPod
• type PodController
  • func NewPodController(podInformer coreinformer.PodInformer, dp dataplane.GenericDataplane, ...) *PodController
  • func (c *PodController) LengthOfPodMap() int
  • func (c *PodController) MarshalJSON() ([]byte, error)
  • func (c *PodController) Run(stopCh <-chan struct{})

Types

type Cache

type Cache struct {
	NodeName string
	NsMap    map[string]*Namespace
	PodMap   map[string]*NpmPod
	ListMap  map[string]*ipsm.Ipset
	SetMap   map[string]*ipsm.Ipset
}

type LabelAppendOperation

type LabelAppendOperation bool

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 NamespaceController

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

func NewNamespaceController

func NewNamespaceController(nameSpaceInformer coreinformer.NamespaceInformer, dp dataplane.GenericDataplane, 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, dp dataplane.GenericDataplane) *NetworkPolicyController

func (*NetworkPolicyController) LengthOfRawNpMap

func (c *NetworkPolicyController) LengthOfRawNpMap() int

func (*NetworkPolicyController) Run

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

type NpmNamespaceCache

type NpmNamespaceCache struct {
	sync.Mutex
	NsMap map[string]*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) MarshalJSON

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

type NpmPod

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

type PodController

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

func NewPodController

func NewPodController(podInformer coreinformer.PodInformer, dp dataplane.GenericDataplane, 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{})