networkpolicy

Documentation

Index

• type NetworkPolicyController
  • func NewNetworkPolicyController(kubeClient clientset.Interface, podInformer coreinformers.PodInformer, ...) *NetworkPolicyController
  • func (n *NetworkPolicyController) GetAddressGroupNum() int
  • func (n *NetworkPolicyController) GetAppliedToGroupNum() int
  • func (n *NetworkPolicyController) GetConnectedAgentNum() int
  • func (n *NetworkPolicyController) GetNetworkPolicyNum() int
  • func (n *NetworkPolicyController) Run(stopCh <-chan struct{})

Types

type NetworkPolicyController

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

NetworkPolicyController is responsible for synchronizing the Namespaces and Pods affected by a Network Policy.

func NewNetworkPolicyController

func NewNetworkPolicyController(kubeClient clientset.Interface,
	podInformer coreinformers.PodInformer,
	namespaceInformer coreinformers.NamespaceInformer,
	networkPolicyInformer networkinginformers.NetworkPolicyInformer,
	addressGroupStore storage.Interface,
	appliedToGroupStore storage.Interface,
	internalNetworkPolicyStore storage.Interface) *NetworkPolicyController

NewNetworkPolicyController returns a new *NetworkPolicyController.

func (*NetworkPolicyController) GetAddressGroupNum

func (n *NetworkPolicyController) GetAddressGroupNum() int

func (*NetworkPolicyController) GetAppliedToGroupNum

func (n *NetworkPolicyController) GetAppliedToGroupNum() int

func (*NetworkPolicyController) GetConnectedAgentNum

func (n *NetworkPolicyController) GetConnectedAgentNum() int

GetConnectedAgentNum gets the number of Agents which are connected to this Controller. Since Agent will watch all the three stores (internalNetworkPolicyStore, appliedToGroupStore, addressGroupStore), the number of watchers of one of these three stores is equal to the number of connected Agents. Here, we uses the number of watchers of internalNetworkPolicyStore to represent the number of connected Agents.

func (*NetworkPolicyController) GetNetworkPolicyNum

func (n *NetworkPolicyController) GetNetworkPolicyNum() int

func (*NetworkPolicyController) Run

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

Run begins watching and syncing of a NetworkPolicyController.