rules

Documentation

Index

• 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
  • 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 map[string][]interface{}) (jobs []kubeeyev1alpha2.JobRule)
  • func (e *ExecuteRule) GetRuleTotal() map[string]int
  • func (e *ExecuteRule) MergeRule(allRule []kubeeyev1alpha2.InspectRule) (map[string][]interface{}, error)
  • func (e *ExecuteRule) SetPrometheusEndpoint(allRule []kubeeyev1alpha2.InspectRule) []kubeeyev1alpha2.InspectRule
  • func (e *ExecuteRule) SetRuleSchedule(rules []kubeeyev1alpha2.InspectRule) (newRules []kubeeyev1alpha2.InspectRule)

Functions

func Allocation

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

func AllocationRule

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

func RuleArrayDeduplication

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

Types

type ExecuteRule

type ExecuteRule struct {
	KubeClient *kube.KubernetesClient
	Task       *kubeeyev1alpha2.InspectTask
	// contains filtered or unexported fields
}

func NewExecuteRuleOptions

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

func (*ExecuteRule) CreateInspectRule

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

func (*ExecuteRule) GenerateJob

func (e *ExecuteRule) GenerateJob(ctx context.Context, rulesSpec map[string][]interface{}) (jobs []kubeeyev1alpha2.JobRule)

func (*ExecuteRule) GetRuleTotal

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

func (*ExecuteRule) MergeRule

func (e *ExecuteRule) MergeRule(allRule []kubeeyev1alpha2.InspectRule) (map[string][]interface{}, error)

func (*ExecuteRule) SetPrometheusEndpoint

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

func (*ExecuteRule) SetRuleSchedule

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