analysis

Documentation

Index

• Constants
• type Controller
  • func NewController(cfg ControllerConfig) *Controller
  • func (c *Controller) Run(ctx context.Context, threadiness int) error
• type ControllerConfig

Constants

const (
	// DefaultMeasurementHistoryLimit is the default maximum number of measurements to retain per metric,
	// before trimming the list.
	DefaultMeasurementHistoryLimit = 10
	// DefaultErrorRetryInterval is the default interval to retry a measurement upon error, in the
	// event an interval was not specified
	DefaultErrorRetryInterval = 10 * time.Second
	// SuccessfulAssessmentRunTerminatedResult is used for logging purposes when the metrics evaluation
	// is successful and the run is terminated.
	SuccessfulAssessmentRunTerminatedResult = "Metric Assessment Result - Successful: Run Terminated"
)

Types

type Controller

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

Controller is the controller implementation for Analysis resources

func NewController

func NewController(cfg ControllerConfig) *Controller

NewController returns a new analysis controller

func (*Controller) Run

func (c *Controller) Run(ctx context.Context, threadiness int) error

type ControllerConfig

type ControllerConfig struct {
	KubeClientSet        kubernetes.Interface
	ArgoProjClientset    clientset.Interface
	AnalysisRunInformer  informers.AnalysisRunInformer
	JobInformer          batchinformers.JobInformer
	ResyncPeriod         time.Duration
	AnalysisRunWorkQueue workqueue.RateLimitingInterface
	MetricsServer        *metrics.MetricsServer
	Recorder             record.EventRecorder
}

ControllerConfig describes the data required to instantiate a new analysis controller