provider

Documentation

Index

• func NewProvider(client dynamic.Interface, mapper apimeta.RESTMapper, ...) provider.MetricsProvider
• type KedaProvider
  • func (p *KedaProvider) GetExternalMetric(namespace string, metricSelector labels.Selector, ...) (*external_metrics.ExternalMetricValueList, error)
  • func (p *KedaProvider) GetMetricByName(name types.NamespacedName, info provider.CustomMetricInfo) (*custom_metrics.MetricValue, error)
  • func (p *KedaProvider) GetMetricBySelector(namespace string, selector labels.Selector, info provider.CustomMetricInfo) (*custom_metrics.MetricValueList, error)
  • func (p *KedaProvider) ListAllExternalMetrics() []provider.ExternalMetricInfo
  • func (p *KedaProvider) ListAllMetrics() []provider.CustomMetricInfo

Functions

func NewProvider

func NewProvider(client dynamic.Interface, mapper apimeta.RESTMapper, handler *handler.ScaleHandler) provider.MetricsProvider

NewProvider returns an instance of KedaProvider

Types

type KedaProvider

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

func (*KedaProvider) GetExternalMetric

func (p *KedaProvider) GetExternalMetric(namespace string, metricSelector labels.Selector, info provider.ExternalMetricInfo) (*external_metrics.ExternalMetricValueList, error)

GetExternalMetric retrieves metrics from the scalers Metric is normally identified by a name and a set of labels/tags. It is up to a specific implementation how to translate metricSelector to a filter for metric values. Namespace can be used by the implementation for metric identification, access control or ignored.

func (*KedaProvider) GetMetricByName

func (p *KedaProvider) GetMetricByName(name types.NamespacedName, info provider.CustomMetricInfo) (*custom_metrics.MetricValue, error)

GetMetricByName fetches a particular metric for a particular object. The namespace will be empty if the metric is root-scoped.

func (*KedaProvider) GetMetricBySelector

func (p *KedaProvider) GetMetricBySelector(namespace string, selector labels.Selector, info provider.CustomMetricInfo) (*custom_metrics.MetricValueList, error)

GetMetricBySelector fetches a particular metric for a set of objects matching the given label selector. The namespace will be empty if the metric is root-scoped.

func (*KedaProvider) ListAllExternalMetrics

func (p *KedaProvider) ListAllExternalMetrics() []provider.ExternalMetricInfo

ListAllExternalMetrics returns the supported external metrics for this provider

func (*KedaProvider) ListAllMetrics

func (p *KedaProvider) ListAllMetrics() []provider.CustomMetricInfo

ListAllMetrics provides a list of all available metrics at the current time. Note that this is not allowed to return an error, so it is recommended that implementors cache and periodically update this list, instead of querying every time.