anomalydetector

Documentation

Index

• Variables
• type AnomalyDetectorController
  • func NewAnomalyDetectorController(crdClient versioned.Interface, kubeClient kubernetes.Interface, ...) *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) ListThroughputAnomalyDetector(namespace string) ([]*crdv1alpha1.ThroughputAnomalyDetector, error)
  • func (c *AnomalyDetectorController) Run(stopCh <-chan struct{})
• type NamespacedId

Variables

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

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) 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

type NamespacedId struct {
	Namespace string
	Id        string
}