metricwebhook

Documentation

Index

• Constants
• func Add(mgr manager.Manager) error
• func NewReconcileMetricWebhook(mgr manager.Manager) (reconcile.Reconciler, error)
• type MetricMeasurementClient
  • func NewMetricValuesClient(metricsClient metricsclient.MetricsClient, k8sClient *k8s.Clientset) *MetricMeasurementClient
  • func (f *MetricMeasurementClient) GetCurrentPodAverageValue(name string, namespace string, labelSelector metav1.LabelSelector, ...) (averageValue resource.Quantity, time time.Time, err error)
  • func (f *MetricMeasurementClient) GetCurrentResourceAverageUtilization(name v1.ResourceName, namespace string, labelSelector metav1.LabelSelector, ...) (averageUtilization int32, averageValue resource.Quantity, time time.Time, ...)
  • func (f *MetricMeasurementClient) GetCurrentResourceAverageValue(name v1.ResourceName, namespace string, labelSelector metav1.LabelSelector, ...) (averageValue resource.Quantity, time time.Time, err error)
• type MetricNotificationClient
  • func NewDefaultMetricAlertClient() *MetricNotificationClient
  • func NewMetricAlertClient(httpClient *http.Client) *MetricNotificationClient
• type MetricWebhookReconciler
  • func (r *MetricWebhookReconciler) Reconcile(request reconcile.Request) (reconcile.Result, error)

Constants

const ControllerName = "metricwebhook-controller"

const ReconcilerName = "metricwebhook-reconciler"

Functions

func Add

func Add(mgr manager.Manager) error

Add creates a new MetricWebhook Controller and adds it to the Manager. It will start it when the Manager is started.

func NewReconcileMetricWebhook

func NewReconcileMetricWebhook(mgr manager.Manager) (reconcile.Reconciler, error)

Types

type MetricMeasurementClient

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

func NewMetricValuesClient

func NewMetricValuesClient(metricsClient metricsclient.MetricsClient, k8sClient *k8s.Clientset) *MetricMeasurementClient

func (*MetricMeasurementClient) GetCurrentPodAverageValue

func (f *MetricMeasurementClient) GetCurrentPodAverageValue(name string, namespace string, labelSelector metav1.LabelSelector, targetAverageValue resource.Quantity) (averageValue resource.Quantity, time time.Time, err error)

func (*MetricMeasurementClient) GetCurrentResourceAverageUtilization

func (f *MetricMeasurementClient) GetCurrentResourceAverageUtilization(name v1.ResourceName, namespace string, labelSelector metav1.LabelSelector, targetAverageUtilization int32) (averageUtilization int32, averageValue resource.Quantity, time time.Time, err error)

func (*MetricMeasurementClient) GetCurrentResourceAverageValue

func (f *MetricMeasurementClient) GetCurrentResourceAverageValue(name v1.ResourceName, namespace string, labelSelector metav1.LabelSelector, targetAverageValue resource.Quantity) (averageValue resource.Quantity, time time.Time, err error)

type MetricNotificationClient

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

func NewDefaultMetricAlertClient

func NewDefaultMetricAlertClient() *MetricNotificationClient

func NewMetricAlertClient

func NewMetricAlertClient(httpClient *http.Client) *MetricNotificationClient

type MetricWebhookReconciler

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

func (*MetricWebhookReconciler) Reconcile

func (r *MetricWebhookReconciler) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a MetricWebhook object and sends out metric notification based on the config defined in MetricWebhook.Spec and current metric measurements