provider

type DummyMetricQuery ¶

type DummyMetricQuery struct{}

func (d DummyMetricQuery) GetExternalMetric(_ context.Context, _ string, _ labels.Selector,
	_ provider.ExternalMetricInfo) (*external_metrics.ExternalMetricValueList, error)

func (d DummyMetricQuery) GetMetricByName(_ context.Context, _ types.NamespacedName,
	_ provider.CustomMetricInfo, _ labels.Selector) (*custom_metrics.MetricValue, error)

func (d DummyMetricQuery) GetMetricBySelector(_ context.Context, _ string, _ labels.Selector,
	_ provider.CustomMetricInfo, _ labels.Selector) (*custom_metrics.MetricValueList, error)

func (d DummyMetricQuery) ListAllExternalMetrics() []provider.ExternalMetricInfo

func (d DummyMetricQuery) ListAllMetrics() []provider.CustomMetricInfo

type MetricProvider ¶

type MetricProvider interface {
	provider.MetricsProvider
}

MetricProvider is a standard interface to query metric data; to simplify the implementation, MetricProvider use the standard kubernetes interface for custom-metrics and external-metrics; and provider.MetricsProvider may have different explanations for their parameters, we make the following appoints

- GetMetricByName --- if metric name is nominated, ignore the selector; --- otherwise, return all the metrics matched with the metric selector; --- in all cases, we should check whether the objects (that own this metric) is matched (with name) --- only returns the latest value

- GetMetricBySelector --- if metric name is nominated, ignore the selector; --- otherwise, return all the metrics matched with the metric selector; --- in all cases, we should check whether the objects (that own this metric) is matched (with label selector)

- GetExternalMetric --- if metric name is nominated, ignore the metric selector; --- otherwise, return all the metrics matched with the metric selector;

type MetricProviderImp ¶

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

func NewMetricProviderImp(ctx context.Context, baseCtx *katalyst_base.GenericContext, storeImp store.MetricStore) *MetricProviderImp

func (m *MetricProviderImp) GetExternalMetric(ctx context.Context, namespace string, metricSelector labels.Selector,
	info provider.ExternalMetricInfo) (*external_metrics.ExternalMetricValueList, error)

func (m *MetricProviderImp) GetMetricByName(ctx context.Context, namespacedName apitypes.NamespacedName,
	info provider.CustomMetricInfo, metricSelector labels.Selector) (*custom_metrics.MetricValue, error)

func (m *MetricProviderImp) GetMetricBySelector(ctx context.Context, namespace string, objSelector labels.Selector,
	info provider.CustomMetricInfo, metricSelector labels.Selector) (*custom_metrics.MetricValueList, error)

func (m *MetricProviderImp) ListAllExternalMetrics() []provider.ExternalMetricInfo

func (m *MetricProviderImp) ListAllMetrics() []provider.CustomMetricInfo