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

Index

• type NamedPortOperation
• type NamespaceController
  • func NewNamespaceController(nameSpaceInformer coreinformer.NamespaceInformer, ...) *NamespaceController
  • func (n *NamespaceController) GetCache() map[string]*common.Namespace
  • func (nsc *NamespaceController) Run(stopCh <-chan struct{})
• type NetworkPolicyController
  • func NewNetworkPolicyController(npInformer networkinginformers.NetworkPolicyInformer, ...) *NetworkPolicyController
  • func (c *NetworkPolicyController) GetCache() map[string]*networkingv1.NetworkPolicySpec
  • func (c *NetworkPolicyController) LengthOfRawNpMap() int
  • func (c *NetworkPolicyController) Run(stopCh <-chan struct{})
• type NpmNamespaceCache
  • func (c *NpmNamespaceCache) GetCache() map[string]*common.Namespace
  • func (n *NpmNamespaceCache) MarshalJSON() ([]byte, error)
• 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 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, dp dataplane.GenericDataplane, npmNamespaceCache *NpmNamespaceCache) *NamespaceController

func (*NamespaceController) GetCache

func (n *NamespaceController) GetCache() map[string]*common.Namespace

func (*NamespaceController) Run

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

type NetworkPolicyController

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

func NewNetworkPolicyController

func NewNetworkPolicyController(npInformer networkinginformers.NetworkPolicyInformer, dp dataplane.GenericDataplane) *NetworkPolicyController

func (*NetworkPolicyController) GetCache

func (c *NetworkPolicyController) GetCache() map[string]*networkingv1.NetworkPolicySpec

func (*NetworkPolicyController) LengthOfRawNpMap

func (c *NetworkPolicyController) LengthOfRawNpMap() int

func (*NetworkPolicyController) Run

func (c *NetworkPolicyController) Run(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) GetCache

func (c *NpmNamespaceCache) GetCache() 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, 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{})