experiments

Documentation

Index

• Constants
• func GetServiceForExperiment(experiment *v1alpha1.Experiment, svc *corev1.Service, ...) error
• type Controller
  • func NewController(cfg ControllerConfig) *Controller
  • func (ec *Controller) Run(ctx context.Context, threadiness int) error
• type ControllerConfig

Constants

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

Functions

func GetServiceForExperiment

func GetServiceForExperiment(experiment *v1alpha1.Experiment, svc *corev1.Service, templateToService map[string]*corev1.Service) error

Types

type Controller

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

Controller is the controller implementation for Experiment resources

func NewController

func NewController(cfg ControllerConfig) *Controller

NewController returns a new experiment controller

func (*Controller) Run

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

Run starts the controller threads

type ControllerConfig

type ControllerConfig struct {
	KubeClientSet                   kubernetes.Interface
	ArgoProjClientset               clientset.Interface
	ReplicaSetInformer              appsinformers.ReplicaSetInformer
	ExperimentsInformer             informers.ExperimentInformer
	AnalysisRunInformer             informers.AnalysisRunInformer
	AnalysisTemplateInformer        informers.AnalysisTemplateInformer
	ClusterAnalysisTemplateInformer informers.ClusterAnalysisTemplateInformer
	ServiceInformer                 informersv1.ServiceInformer
	ResyncPeriod                    time.Duration
	RolloutWorkQueue                workqueue.RateLimitingInterface
	ExperimentWorkQueue             workqueue.RateLimitingInterface
	MetricsServer                   *metrics.MetricsServer
	Recorder                        record.EventRecorder
}

ControllerConfig describes the data required to instantiate a new analysis controller