Documentation ¶
Index ¶
- Constants
- func FindLoadConfig(endpointName string, exp *windtunnelv1alpha1.Experiment) *windtunnelv1alpha1.LoadPatternConfig
- func GetLoadPatternNamespace(exp *windtunnelv1alpha1.Experiment, ref *corev1.ObjectReference) string
- func SetProtocol(exp *windtunnelv1alpha1.Experiment, pipeline *windtunnelv1alpha1.Pipeline)
- type CostExporterReconciler
- type DataSetReconciler
- type ExperimentReconciler
- func (r *ExperimentReconciler) CheckFinished(ctx context.Context, exp *windtunnelv1alpha1.Experiment) error
- func (r *ExperimentReconciler) CopyConfigMap(ctx context.Context, dataset *windtunnelv1alpha1.DataSet, ...) error
- func (r *ExperimentReconciler) CreateConfigMap(ctx context.Context, exp *windtunnelv1alpha1.Experiment, ...) error
- func (r *ExperimentReconciler) CreateConfigMapWithDataSet(ctx context.Context, exp *windtunnelv1alpha1.Experiment, ...) error
- func (r *ExperimentReconciler) CreateK6(ctx context.Context, exp *windtunnelv1alpha1.Experiment, endpointName string) error
- func (r *ExperimentReconciler) CreateK6WithDataSet(ctx context.Context, exp *windtunnelv1alpha1.Experiment, ...) error
- func (r *ExperimentReconciler) CreateTestRun(ctx context.Context, exp *windtunnelv1alpha1.Experiment, ...) error
- func (r *ExperimentReconciler) CreateTestRunWithDataSet(ctx context.Context, exp *windtunnelv1alpha1.Experiment, ...) error
- func (r *ExperimentReconciler) CreateTestRunWithOutDataSet(ctx context.Context, exp *windtunnelv1alpha1.Experiment, ...) error
- func (r *ExperimentReconciler) InitializeExp(ctx context.Context, exp *windtunnelv1alpha1.Experiment, ...) error
- func (r *ExperimentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *ExperimentReconciler) SetDuration(ctx context.Context, exp *windtunnelv1alpha1.Experiment) error
- func (r *ExperimentReconciler) SetupWithManager(mgr ctrl.Manager) error
- func (r *ExperimentReconciler) UpdatePipeline(ctx context.Context, pipeline *windtunnelv1alpha1.Pipeline, ...) error
- type ExperimentTags
- type PipelineReconciler
- func (r *PipelineReconciler) CreateService(ctx context.Context, pipeline *windtunnelv1alpha1.Pipeline) error
- func (r *PipelineReconciler) HealthCheck(ctx context.Context, pipeline *windtunnelv1alpha1.Pipeline) error
- func (r *PipelineReconciler) Initialize(ctx context.Context, pipeline *windtunnelv1alpha1.Pipeline) error
- func (r *PipelineReconciler) InitializeExp(ctx context.Context, pipeline *windtunnelv1alpha1.Pipeline) error
- func (r *PipelineReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *PipelineReconciler) SetupWithManager(mgr ctrl.Manager) error
- func (r *PipelineReconciler) UpdateStatus(ctx context.Context, pipeline *windtunnelv1alpha1.Pipeline, ...) error
- type PlantDCoreReconciler
- type ReconcilerResult
- type Tag
Constants ¶
const ( CREATING = "Creating" GENERATING = "Generating" RUNNING = "Running" FAILED = "Failed" SUCCESS = "Success" UNKNOWN = "Unknown" )
const ( ExperimentPending string = "Pending" // experiment object has been created but no pipeline has been selected/attached ExperimentInitializing string = "Initializing" // experiment is initializing after pipeline is selected ExperimentWaitingForPipelineReady string = "WaitingForPipelineReady" // experiment is waiting for pipeline to pass health checks ExperimentReady string = "Ready" // experiment is ready to be run on the selected pipeline ExperimentRunning string = "Running" // experiment is running ExperimentFinished string = "Finished" // experiment has finished running; i.e. the k6 load generator has finished sending data )
const ( ResourcePending = "Pending" // Resource created or updated, and have no replica numbers ResourceNotReady = "Not Ready" // Resource pending, not all replicas are ready ResourceReady = "Ready" // Resource ready, all replicas are ready )
Enums of resource status
Variables ¶
This section is empty.
Functions ¶
func FindLoadConfig ¶
func FindLoadConfig(endpointName string, exp *windtunnelv1alpha1.Experiment) *windtunnelv1alpha1.LoadPatternConfig
func GetLoadPatternNamespace ¶
func GetLoadPatternNamespace(exp *windtunnelv1alpha1.Experiment, ref *corev1.ObjectReference) string
func SetProtocol ¶
func SetProtocol(exp *windtunnelv1alpha1.Experiment, pipeline *windtunnelv1alpha1.Pipeline)
Types ¶
type CostExporterReconciler ¶
CostExporterReconciler reconciles a CostExporter object
func (*CostExporterReconciler) Reconcile ¶
func (r *CostExporterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.15.0/pkg/reconcile
func (*CostExporterReconciler) SetupWithManager ¶
func (r *CostExporterReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type DataSetReconciler ¶
DataSetReconciler reconciles a DataSet object
func (*DataSetReconciler) Reconcile ¶
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.15.0/pkg/reconcile
func (*DataSetReconciler) SetupWithManager ¶
func (r *DataSetReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type ExperimentReconciler ¶
ExperimentReconciler reconciles a Experiment object
func (*ExperimentReconciler) CheckFinished ¶
func (r *ExperimentReconciler) CheckFinished(ctx context.Context, exp *windtunnelv1alpha1.Experiment) error
Check if the test run is finished
func (*ExperimentReconciler) CopyConfigMap ¶ added in v1.2.0
func (r *ExperimentReconciler) CopyConfigMap(ctx context.Context, dataset *windtunnelv1alpha1.DataSet, configMap *corev1.ConfigMap, exp *windtunnelv1alpha1.Experiment) error
func (*ExperimentReconciler) CreateConfigMap ¶
func (r *ExperimentReconciler) CreateConfigMap(ctx context.Context, exp *windtunnelv1alpha1.Experiment, endpoint *windtunnelv1alpha1.Endpoint, load *windtunnelv1alpha1.LoadPattern) error
func (*ExperimentReconciler) CreateConfigMapWithDataSet ¶
func (r *ExperimentReconciler) CreateConfigMapWithDataSet(ctx context.Context, exp *windtunnelv1alpha1.Experiment, endpoint *windtunnelv1alpha1.Endpoint, load *windtunnelv1alpha1.LoadPattern, dataset *windtunnelv1alpha1.DataSet) error
func (*ExperimentReconciler) CreateK6 ¶
func (r *ExperimentReconciler) CreateK6(ctx context.Context, exp *windtunnelv1alpha1.Experiment, endpointName string) error
func (*ExperimentReconciler) CreateK6WithDataSet ¶
func (r *ExperimentReconciler) CreateK6WithDataSet(ctx context.Context, exp *windtunnelv1alpha1.Experiment, dataset *windtunnelv1alpha1.DataSet, endpointName string) error
func (*ExperimentReconciler) CreateTestRun ¶
func (r *ExperimentReconciler) CreateTestRun(ctx context.Context, exp *windtunnelv1alpha1.Experiment, pipeline *windtunnelv1alpha1.Pipeline) error
func (*ExperimentReconciler) CreateTestRunWithDataSet ¶
func (r *ExperimentReconciler) CreateTestRunWithDataSet(ctx context.Context, exp *windtunnelv1alpha1.Experiment, endpoint *windtunnelv1alpha1.Endpoint) error
func (*ExperimentReconciler) CreateTestRunWithOutDataSet ¶
func (r *ExperimentReconciler) CreateTestRunWithOutDataSet(ctx context.Context, exp *windtunnelv1alpha1.Experiment, endpoint *windtunnelv1alpha1.Endpoint) error
func (*ExperimentReconciler) InitializeExp ¶
func (r *ExperimentReconciler) InitializeExp(ctx context.Context, exp *windtunnelv1alpha1.Experiment, pipeline *windtunnelv1alpha1.Pipeline) error
func (*ExperimentReconciler) Reconcile ¶
func (r *ExperimentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.15.0/pkg/reconcile
func (*ExperimentReconciler) SetDuration ¶
func (r *ExperimentReconciler) SetDuration(ctx context.Context, exp *windtunnelv1alpha1.Experiment) error
func (*ExperimentReconciler) SetupWithManager ¶
func (r *ExperimentReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
func (*ExperimentReconciler) UpdatePipeline ¶
func (r *ExperimentReconciler) UpdatePipeline(ctx context.Context, pipeline *windtunnelv1alpha1.Pipeline, expRef corev1.ObjectReference) error
type ExperimentTags ¶
type PipelineReconciler ¶
PipelineReconciler reconciles a Pipeline object
func (*PipelineReconciler) CreateService ¶
func (r *PipelineReconciler) CreateService(ctx context.Context, pipeline *windtunnelv1alpha1.Pipeline) error
Create externalName service and endpoint for pipeline endpoints and the metrics endpoint.
func (*PipelineReconciler) HealthCheck ¶
func (r *PipelineReconciler) HealthCheck(ctx context.Context, pipeline *windtunnelv1alpha1.Pipeline) error
func (*PipelineReconciler) Initialize ¶
func (r *PipelineReconciler) Initialize(ctx context.Context, pipeline *windtunnelv1alpha1.Pipeline) error
func (*PipelineReconciler) InitializeExp ¶
func (r *PipelineReconciler) InitializeExp(ctx context.Context, pipeline *windtunnelv1alpha1.Pipeline) error
func (*PipelineReconciler) Reconcile ¶
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.15.0/pkg/reconcile
func (*PipelineReconciler) SetupWithManager ¶
func (r *PipelineReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
func (*PipelineReconciler) UpdateStatus ¶
func (r *PipelineReconciler) UpdateStatus(ctx context.Context, pipeline *windtunnelv1alpha1.Pipeline, pipelineState string, statusCheck string) error
type PlantDCoreReconciler ¶
PlantDCoreReconciler reconciles a PlantDCore object
func (*PlantDCoreReconciler) Reconcile ¶
func (r *PlantDCoreReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the PlantDCore object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.
For more details, check Reconcile and its Result here:ec - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.15.0/pkg/reconcile
func (*PlantDCoreReconciler) SetupWithManager ¶
func (r *PlantDCoreReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type ReconcilerResult ¶ added in v1.3.0
type ReconcilerResult int8
ReconcilerResult is the type of reconciler result
const ( ReconcilerFailed ReconcilerResult = iota // Reconciliation failed ReconcilerOK // No operation required ReconcilerCreated // Resource created ReconcilerUpdated // Resource updated )
Enums of reconciliation results