analysis

Documentation

Index

• Constants
• type AnalysisController
  • func NewAnalysisController(kubeclientset kubernetes.Interface, argoProjClientset clientset.Interface, ...) *AnalysisController
  • func (c *AnalysisController) Run(threadiness int, stopCh <-chan struct{}) error

Constants

const (
	// DefaultMeasurementHistoryLimit is the default maximum number of measurements to retain per metric,
	// before trimming the list.
	DefaultMeasurementHistoryLimit = 10
	// DefaultConsecutiveErrorLimit is the default number times a metric can error in sequence before
	// erroring the entire metric.
	DefaultConsecutiveErrorLimit int32 = 4
	// DefaultErrorRetryInterval is the default interval to retry a measurement upon error, in the
	// event an interval was not specified
	DefaultErrorRetryInterval time.Duration = 10 * time.Second
)

const (
	EventReasonStatusFailed    = "Failed"
	EventReasonStatusCompleted = "Complete"
)

Event reasons for analysis events

Types

type AnalysisController

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

AnalysisController is the controller implementation for Analysis resources

func NewAnalysisController

func NewAnalysisController(
	kubeclientset kubernetes.Interface,
	argoProjClientset clientset.Interface,
	analysisRunInformer informers.AnalysisRunInformer,
	jobInformer batchinformers.JobInformer,
	resyncPeriod time.Duration,
	analysisRunWorkQueue workqueue.RateLimitingInterface,
	metricsServer *metrics.MetricsServer,
	recorder record.EventRecorder) *AnalysisController

NewAnalysisController returns a new analysis controller

func (*AnalysisController) Run

func (c *AnalysisController) Run(threadiness int, stopCh <-chan struct{}) error