Documentation
¶
Index ¶
- Variables
- type AnomalyDetectorController
- func (c *AnomalyDetectorController) CreateThroughputAnomalyDetector(namespace string, ...) (*crdv1alpha1.ThroughputAnomalyDetector, error)
- func (c *AnomalyDetectorController) DeleteThroughputAnomalyDetector(namespace, name string) error
- func (c *AnomalyDetectorController) GetThroughputAnomalyDetector(namespace, name string) (*crdv1alpha1.ThroughputAnomalyDetector, error)
- func (c *AnomalyDetectorController) IfTADexists(namespace, id string) error
- func (c *AnomalyDetectorController) ListThroughputAnomalyDetector(namespace string) ([]*crdv1alpha1.ThroughputAnomalyDetector, error)
- func (c *AnomalyDetectorController) Run(stopCh <-chan struct{})
- type NamespacedId
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // Spark Application CRUD functions, for unit tests CreateSparkApplication = controllerutil.CreateSparkApplication DeleteSparkApplication = controllerutil.DeleteSparkApplication GetSparkApplication = controllerutil.GetSparkApplication GetSparkMonitoringSvcDNS = controllerutil.GetSparkMonitoringSvcDNS )
Functions ¶
This section is empty.
Types ¶
type AnomalyDetectorController ¶
type AnomalyDetectorController struct {
// contains filtered or unexported fields
}
func NewAnomalyDetectorController ¶
func NewAnomalyDetectorController( crdClient versioned.Interface, kubeClient kubernetes.Interface, taDetectorInformer crdv1a1informers.ThroughputAnomalyDetectorInformer, ) *AnomalyDetectorController
func (*AnomalyDetectorController) CreateThroughputAnomalyDetector ¶
func (c *AnomalyDetectorController) CreateThroughputAnomalyDetector(namespace string, ThroughputAnomalyDetector *crdv1alpha1.ThroughputAnomalyDetector) (*crdv1alpha1.ThroughputAnomalyDetector, error)
func (*AnomalyDetectorController) DeleteThroughputAnomalyDetector ¶
func (c *AnomalyDetectorController) DeleteThroughputAnomalyDetector(namespace, name string) error
func (*AnomalyDetectorController) GetThroughputAnomalyDetector ¶
func (c *AnomalyDetectorController) GetThroughputAnomalyDetector(namespace, name string) (*crdv1alpha1.ThroughputAnomalyDetector, error)
func (*AnomalyDetectorController) IfTADexists ¶ added in v0.6.0
func (c *AnomalyDetectorController) IfTADexists(namespace, id string) error
func (*AnomalyDetectorController) ListThroughputAnomalyDetector ¶
func (c *AnomalyDetectorController) ListThroughputAnomalyDetector(namespace string) ([]*crdv1alpha1.ThroughputAnomalyDetector, error)
func (*AnomalyDetectorController) Run ¶
func (c *AnomalyDetectorController) Run(stopCh <-chan struct{})
Run will create defaultWorkers workers (go routines) which will process the Service events from the workqueue.
type NamespacedId ¶
Source Files
Click to show internal directories.
Click to hide internal directories.