Documentation
¶
Index ¶
- func CheckAssertions(action *v1alpha1.Action, state lifecycle.Classifier) error
- func CheckDependencies(action *v1alpha1.Action, callIndex index) error
- func CheckJobRef(action *v1alpha1.Action, callIndex index) error
- func GetNextLogicalJob(timebase metav1.Time, all []v1alpha1.Action, gs lifecycle.ClassifierReader, ...) ([]v1alpha1.Action, time.Time)
- func NewController(mgr ctrl.Manager, logger logr.Logger) error
- func PrepareDependencyGraph(actionList []v1alpha1.Action) (index, error)
- func RandomFixedIndexes(start, end, count uint) []uint
- type Controller
- func (r *Controller) CheckTemplateRef(ctx context.Context, nm string, action *v1alpha1.Action) error
- func (r *Controller) ConnectToGrafana(ctx context.Context, cr *v1alpha1.TestPlan) error
- func (r *Controller) Finalize(obj client.Object) error
- func (r *Controller) Finalizer() string
- func (r *Controller) HasTelemetry(ctx context.Context, plan *v1alpha1.TestPlan) ([]string, error)
- func (r *Controller) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *Controller) Validate(ctx context.Context, plan *v1alpha1.TestPlan) error
- type SList
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckAssertions ¶
func CheckAssertions(action *v1alpha1.Action, state lifecycle.Classifier) error
func CheckDependencies ¶
func CheckJobRef ¶
func GetNextLogicalJob ¶
func GetNextLogicalJob(timebase metav1.Time, all []v1alpha1.Action, gs lifecycle.ClassifierReader, scheduled map[string]v1alpha1.ConditionalExpr) ([]v1alpha1.Action, time.Time)
GetNextLogicalJob returns a list of jobs that meet the logical and time constraints. That is, either the job has no dependencies, or the dependencies are met.
It is possible for the logical dependencies to be met, but the timeout not yet expired. If at least one action exists, when the workflow is updated it will trigger another reconciliation cycle. However, if there are no actions, the workflow will call the reconciliation cycle, and we will miss the next timeout. To handle this scenario, we have to requeue the request with the given duration. In this case, the given duration is the nearest expected timeout.
func PrepareDependencyGraph ¶
func RandomFixedIndexes ¶
RandomFixedIndexes returns the `count` random indexes between `start` and `end`. [start, end).
Types ¶
type Controller ¶
func (*Controller) CheckTemplateRef ¶
func (*Controller) ConnectToGrafana ¶
func (*Controller) Finalizer ¶
func (r *Controller) Finalizer() string
func (*Controller) HasTelemetry ¶
HasTelemetry iterates the referenced services (directly via Service or indirectly via Cluster) and list all telemetry dashboards that need to be imported
func (*Controller) Validate ¶
Validate validates the execution workflow. 1. Ensures that action names are qualified (since they are used as generators to jobs) 2. Ensures that there are no two actions with the same name. 3. Ensure that dependencies point to a valid action. 4. Ensure that macros point to a valid action.
Source Files