experiments

Documentation

Index

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

Constants

const (
	CollisionCountPatch = `{
	"status" : {
		"templateStatuses" : %s
	}
}`
)

Types

type ExperimentController

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

ExperimentController is the controller implementation for Experiment resources

func NewExperimentController

func NewExperimentController(
	kubeclientset kubernetes.Interface,
	argoProjClientset clientset.Interface,
	replicaSetInformer appsinformers.ReplicaSetInformer,
	experimentsInformer informers.ExperimentInformer,
	analysisRunInformer informers.AnalysisRunInformer,
	analysisTemplateInformer informers.AnalysisTemplateInformer,
	resyncPeriod time.Duration,
	rolloutWorkQueue workqueue.RateLimitingInterface,
	experimentWorkQueue workqueue.RateLimitingInterface,
	metricsServer *metrics.MetricsServer,
	recorder record.EventRecorder) *ExperimentController

NewExperimentController returns a new experiment controller

func (*ExperimentController) Run

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