networkpolicyrecommendation

Documentation

Index

• Variables
• type NPRecommendationController
  • func NewNPRecommendationController(crdClient versioned.Interface, kubeClient kubernetes.Interface, ...) *NPRecommendationController
  • func (c *NPRecommendationController) CreateNetworkPolicyRecommendation(namespace string, ...) (*crdv1alpha1.NetworkPolicyRecommendation, error)
  • func (c *NPRecommendationController) DeleteNetworkPolicyRecommendation(namespace, name string) error
  • func (c *NPRecommendationController) GetNetworkPolicyRecommendation(namespace, name string) (*crdv1alpha1.NetworkPolicyRecommendation, error)
  • func (c *NPRecommendationController) IfNPRexists(namespace, id string) error
  • func (c *NPRecommendationController) ListNetworkPolicyRecommendation(namespace string) ([]*crdv1alpha1.NetworkPolicyRecommendation, error)
  • func (c *NPRecommendationController) Run(stopCh <-chan struct{})
• type NamespacedId

Variables

var (
	// Spark Application CRUD functions, for unit tests
	CreateSparkApplication   = controllerutil.CreateSparkApplication
	DeleteSparkApplication   = controllerutil.DeleteSparkApplication
	ListSparkApplication     = controllerutil.ListSparkApplicationWithLabel
	GetSparkApplication      = controllerutil.GetSparkApplication
	GetSparkMonitoringSvcDNS = controllerutil.GetSparkMonitoringSvcDNS
)

Types

type NPRecommendationController

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

func NewNPRecommendationController

func NewNPRecommendationController(
	crdClient versioned.Interface,
	kubeClient kubernetes.Interface,
	npRecommendationInformer crdv1a1informers.NetworkPolicyRecommendationInformer,
) *NPRecommendationController

func (*NPRecommendationController) CreateNetworkPolicyRecommendation

func (c *NPRecommendationController) CreateNetworkPolicyRecommendation(namespace string, networkPolicyRecommendation *crdv1alpha1.NetworkPolicyRecommendation) (*crdv1alpha1.NetworkPolicyRecommendation, error)

func (*NPRecommendationController) DeleteNetworkPolicyRecommendation

func (c *NPRecommendationController) DeleteNetworkPolicyRecommendation(namespace, name string) error

func (*NPRecommendationController) GetNetworkPolicyRecommendation

func (c *NPRecommendationController) GetNetworkPolicyRecommendation(namespace, name string) (*crdv1alpha1.NetworkPolicyRecommendation, error)

func (*NPRecommendationController) IfNPRexists

func (c *NPRecommendationController) IfNPRexists(namespace, id string) error

func (*NPRecommendationController) ListNetworkPolicyRecommendation

func (c *NPRecommendationController) ListNetworkPolicyRecommendation(namespace string) ([]*crdv1alpha1.NetworkPolicyRecommendation, error)

func (*NPRecommendationController) Run

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

Run will create defaultWorkers workers (go routines) which will process the Service events from the workqueue.

type NamespacedId

type NamespacedId struct {
	Namespace string
	Id        string
}