rules

Nov 30, 2023

Changes in this version

+ func Allocation(rule interface{}, taskName string, ruleType string) (*kubeeyev1alpha2.JobRule, error)

+ func AllocationRule(rule interface{}, taskName string, allNode []corev1.Node, ctlOrTem string) ([]kubeeyev1alpha2.JobRule, error)

+ func RuleArrayDeduplication[T any](obj interface{}) []T

+ type ExecuteRule struct

+ KubeClient *kube.KubernetesClient

+ Task *kubeeyev1alpha2.InspectTask

+ func NewExecuteRuleOptions(clients *kube.KubernetesClient, Task *kubeeyev1alpha2.InspectTask) *ExecuteRule

+ func (e *ExecuteRule) CreateInspectRule(ctx context.Context, ruleGroup []kubeeyev1alpha2.JobRule) ([]kubeeyev1alpha2.JobRule, error)

+ func (e *ExecuteRule) GenerateJob(ctx context.Context, rulesSpec kubeeyev1alpha2.InspectRuleSpec) (jobs []kubeeyev1alpha2.JobRule)

+ func (e *ExecuteRule) GetRuleTotal() map[string]int

+ func (e *ExecuteRule) MergeRule(allRule []kubeeyev1alpha2.InspectRule) (kubeeyev1alpha2.InspectRuleSpec, error)

+ func (e *ExecuteRule) SetPrometheusEndpoint(allRule []kubeeyev1alpha2.InspectRule) []kubeeyev1alpha2.InspectRule

+ func (e *ExecuteRule) SetRuleSchedule(rules []kubeeyev1alpha2.InspectRule) (newRules []kubeeyev1alpha2.InspectRule)