metricproviders

Documentation

Index

• Constants
• func GetAnalysisJobClientset(defaultClientset kubernetes.Interface) (kubernetes.Interface, bool, error)
• func GetAnalysisJobNamespace() string
• func Type(metric v1alpha1.Metric) string
• type ProviderFactory
  • func (f *ProviderFactory) NewProvider(logCtx log.Entry, metric v1alpha1.Metric) (metric.Provider, error)
• type ProviderFactoryFunc

Constants

const (
	InclusterKubeconfig      = "in-cluster"
	AnalysisJobKubeconfigEnv = "ARGO_ROLLOUTS_ANALYSIS_JOB_KUBECONFIG"
	AnalysisJobNamespaceEnv  = "ARGO_ROLLOUTS_ANALYSIS_JOB_NAMESPACE"
)

Functions

func GetAnalysisJobClientset

func GetAnalysisJobClientset(defaultClientset kubernetes.Interface) (kubernetes.Interface, bool, error)

GetAnalysisJobClientset returns kubernetes clientset for executing the analysis job metric, if the AnalysisJobKubeconfigEnv is set to InclusterKubeconfig, it will return the incluster client else if it's set to a kubeconfig file it will return the clientset corresponding to the kubeconfig file. If empty it returns the provided defaultClientset

func GetAnalysisJobNamespace

func GetAnalysisJobNamespace() string

func Type

func Type(metric v1alpha1.Metric) string

Types

type ProviderFactory

type ProviderFactory struct {
	KubeClient kubernetes.Interface
	JobLister  batchlisters.JobLister
}

func (*ProviderFactory) NewProvider

func (f *ProviderFactory) NewProvider(logCtx log.Entry, metric v1alpha1.Metric) (metric.Provider, error)

NewProvider creates the correct provider based on the provider type of the Metric

type ProviderFactoryFunc

type ProviderFactoryFunc func(logCtx log.Entry, metric v1alpha1.Metric) (metric.Provider, error)